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));
}
接收配置: