rabbitmq 服务搭建与使用

Posted 2020-10-22 cjq.java

在springboot项目中配置使用

1.Erlang和rabbitmq安装部署和环境变量的配置

网上教程很多

参考：https://www.cnblogs.com/yangh965/p/5862347.html

有一篇文章找不到了，假设已经安装成功

2.安装插件

在安装根目录sbin目录下启动命令行，输入

rabbitmq-plugins enable rabbitmq_management回车

 

3.rabbitmq启动

在安装根目录sbin目录下启动命令行，输入rabbitmq-server回车

 

4.进入rabbitmq后台管理界面

rabbitmq后台地址http://localhost:15672/

 

5.配置账户以及权限

 

 

6.实例：

RabbitMQ接收消息的账号可不同，只要账户有接收消息的权限即可

RabbitMQ消息队列服务器要相同
RabbitMQ消息队列交换机名称要相同

发送：
@Autowired
private RabbitTemplate rabbitTemplate;

@Override
public void sendMsgDrawBlood(String messageId, Object data) {
    Message message = new Message();
    message.setMessageType(MessageType.DRAPBLOOD.getValue());
    message.setMessageId(messageId);
    message.setData(data);
    if (s.getSystemLogger() == Constant.SYSTEMLOG_PRINT_0)
        logger.info(s.getProjName() + "发送抽血人员数据消息-->" + message.toString());
    rabbitTemplate.convertAndSend(s.getFanoutExchageName(), "", JSON.toJSONString(message, SerializerFeature.WriteNullListAsEmpty, SerializerFeature.WriteNullStringAsEmpty));

}


接收配置：