RabbitMQ推送消息
步骤一:安装RabbitMQ
具体安装可以参照作者的另外2篇文章
RabbitMQ在windows下的安装
RabbitMQ在Linux下的安装
步骤二:打开Rabbit的管理界面,地址为IP:15672
步骤三:在无登录账号的情况下,系统提供了默认的账号:guest ,密码:guest
注:guest可能出现登录不上的情况,这里系统是默认只能在本地登录guest这个账号
,如需使用,需要去RabbitMQ配置文件配置。
配置流程:进入/usr/lib/rabbitmq/lib/rabbitmq_server-3.7.7/ebin/rabbit.app
将:{loopback_users, [<<”guest”>>]},改为:{loopback_users, []},重启即可
重启命令:
systemctl restart rabbitmq-server.service
步骤四:添加一个交换机Exchanges
进入Exchanges
点击添加一个交换机
输入交换机的名字、类型、是否持久化,并点击Add exchange
按钮
查看界面出现新的交换机,则成功
步骤五:添加一个队列
选择Queues下的Add a new queue
输入队列名和是否持久化,点击Add queue
查看界面上出现一个队列,则成功
步骤六:交换机和队列绑定
点击队列名,进去详情查看
选择Banding
(绑定)
输入要绑定的交换机的名字和Routing key
Routing key
:为匹配规则,只有相对应的Exchanges和Routing key才可以访问到该队列。比如Routing key=Abc,则只有Routing key=Abc可以访问到该队列。
Routing key=Abc.*的话,那么只有Abc.xxx可以访问,Abc.xx.xx就不行
点击绑定,出现下列显示则绑定成功
步骤七:消息的推送
在java中配置rabbitmq,port一般为5672
下面${变量}形式为已经配置在了本地的环境变量中
在java代码中注入
@Autowired
private RabbitTemplate rabbitTemplate;
调用(对象被转成了json格式):
rabbitTemplate.convertAndSend("middle_exchanges","middle.save",new ObjectMapper().writeValueAsString(要传输的对象));
步骤八:查看消息
查看消息所在的队列详情,点击Get Messages
选择查看即可