RabbitMQ之推送消息

RabbitMQ推送消息

RabbitMQ之推送消息
步骤一:安装RabbitMQ
具体安装可以参照作者的另外2篇文章
RabbitMQ在windows下的安装
RabbitMQ在Linux下的安装
步骤二:打开Rabbit的管理界面,地址为IP:15672
RabbitMQ之推送消息

步骤三:在无登录账号的情况下,系统提供了默认的账号:guest ,密码:guest
注:guest可能出现登录不上的情况,这里系统是默认只能在本地登录guest这个账号
RabbitMQ之推送消息
,如需使用,需要去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
RabbitMQ之推送消息
点击添加一个交换机
RabbitMQ之推送消息
输入交换机的名字、类型、是否持久化,并点击Add exchange按钮
RabbitMQ之推送消息
查看界面出现新的交换机,则成功
RabbitMQ之推送消息

步骤五:添加一个队列
选择Queues下的Add a new queue
RabbitMQ之推送消息
输入队列名和是否持久化,点击Add queue
RabbitMQ之推送消息
查看界面上出现一个队列,则成功
RabbitMQ之推送消息

步骤六:交换机和队列绑定
点击队列名,进去详情查看
RabbitMQ之推送消息
选择Banding(绑定)
RabbitMQ之推送消息
输入要绑定的交换机的名字和Routing key
Routing key:为匹配规则,只有相对应的Exchanges和Routing key才可以访问到该队列。比如Routing key=Abc,则只有Routing key=Abc可以访问到该队列。
Routing key=Abc.*的话,那么只有Abc.xxx可以访问,Abc.xx.xx就不行
RabbitMQ之推送消息
点击绑定,出现下列显示则绑定成功
RabbitMQ之推送消息

步骤七:消息的推送
在java中配置rabbitmq,port一般为5672
下面${变量}形式为已经配置在了本地的环境变量中
RabbitMQ之推送消息
在java代码中注入

@Autowired
private RabbitTemplate rabbitTemplate;

调用(对象被转成了json格式):

rabbitTemplate.convertAndSend("middle_exchanges","middle.save",new ObjectMapper().writeValueAsString(要传输的对象));

步骤八:查看消息
查看消息所在的队列详情,点击Get Messages
RabbitMQ之推送消息
选择查看即可

RabbitMQ之推送消息

上一篇:IBGP Segment Routing AIGP属性


下一篇:Laravel:PHP Artisan Make:Auth不创建路由