老样子,咱八股文说完了,上点干货，来点实际的操作(不懂的先去把上章 (RabbitMQ(一) 啃了)
我目前在做的项目是用springboot自带的amqp创建的RabbitMQ坐标 (如果不需要的可以去查一查RabbitMQ自身坐标进行引入) :
创建步骤(new project 选择springInitializr => 它能帮我们快速创建springboot项目)
创建的时候选好自己要的版本(我这里选的是JDK17,用的是IDEA2023.3.1版本,为了赶紧给大家制作出来,就没有去换低版本使用JDK8了,2023.3.1还没找到在哪配8的版本)
我用的是maven,所以此处以maven为例
做完这两项后创建工程,得到maven坐标
至于搭环境啥的我就不详细说了,有兴趣的兄弟姐妹可以搜来自己搞搞,如果哪家公司一进去就要你搭这玩意儿的服务,那听兄弟的,除非你真是大佬,不然赶紧跑,这公司干不长
配置方面我只提一句yaml的配置
注意:此处的yaml配置是spring amqp的配置,RabbitMQ的端口有很多个,主要端口有四个:
4369 – erlang发现口 5672 --client端通信口 15672 – 管理界面ui端口 25672 – server间内部通信口
4369：epmd，RabbitMQ节点和CLI工具使用的对等发现服务
5672、5671：由不带TLS和带TLS的AMQP 0-9-1和1.0客户端使用
25672：用于节点间和CLI工具通信（Erlang分发服务器端口），并从动态范围分配（默认情况下限制为单个端口，计算为AMQP端口+ 20000）。
除非确实需要这些端口上的外部连接（例如，群集使用联合身份验证或在子网外部的计算机上使用CLI工具），否则这些端口不应公开。
有关详细信息，请参见网络指南。
35672-35682：由CLI工具（Erlang分发客户端端口）用于与节点进行通信，并从动态范围分配（通过服务器分发端口+ 10010计算为服务器分发端口+ 10000）。
有关详细信息，请参见网络指南。
15672：HTTP API客户端，管理UI和Rabbitmqadmin （仅在启用管理插件的情况下）
61613、61614：不带TLS和带TLS的STOMP客户端（仅在启用STOMP插件的情况下）
1883、8883 ：（不带和带有TLS的MQTT客户端，如果启用了MQTT插件
15674：STOMP-over-WebSockets客户端（仅在启用了Web STOMP插件的情况下）
15675：MQTT-over-WebSockets客户端（仅在启用Web MQTT插件的情况下）
15692：Prometheus指标（仅在启用Prometheus插件的情况下）
所以,在配置完成后想查看RabbitMQ的管理界面,我们应该访问15672端口(也就是yaml中的host:15672)
进入这个页面以后,输入用户名和密码,也就是上面截图yml中配置的用户名和密码
进入这个页面,就算OK了
咱们先说说连接
Virtual host： 所属的虚拟主机。Name： 名称。User name： 使用的用户名。State： 当前的状态，running：运行中；idle：空闲。SSL/TLS： 是否使用ssl进行连接。Protocol： 使用的协议。Channels： 创建的channel的总数。From client： 每秒发出的数据包。To client： 每秒收到的数据包。
也可点击主页面的channel进入查看所有通道
channel： 名称。Virtual host： 所属的虚拟主机。User name： 使用的用户名。Mode： 渠道保证模式。 可以是以下之一，或者不是：C: confirm。T：transactional(事务)。State ： 当前的状态，running：运行中；idle：空闲。Unconfirmed： 待confirm的消息总数。Prefetch： 设置的prefetch的个数。Unacker： 待ack的消息总数。publish： producter pub消息的速率。confirm： producter confirm消息的速率。deliver/get： consumer 获取消息的速率。ack： consumer ack消息的速率。
点击Exchanges(交换机)
说明一下features的几个参数D： 是 durable 的缩写，代表这个队列中的消息支持持久化I： 是 internal 的缩写，表示这个exchange不可以被client用来推送消息，仅用来进行exchange之间的绑定。Args： 是 arguments 的缩写。代表该队列配置了 arguments 参数。TTL： 是 x-message-ttl 的缩写。设置队列中的所有消息的生存周期(统一为整个队列的所有消息设置生命周期), 也可以在发布消息的时候单独为某个消息指定剩余生存时间，单位毫秒。DLX： 说明该队列配置了 x-dead-letter-exchange。当队列消息长度大于最大长度、或者过期的等，将从队列中删除的消息推送到指定的交换机中去而不是丢弃掉。DLK： x-dead-letter-routing-key 的缩写，将删除的消息推送到指定交换机的指定路由键的队列中去。
随便点击一个交换机(这里以platform为结尾的交换机为例)
上述红框中的东西便是交换机绑定的队列
点击Queues(队列)
队列的属性Virtual host： 所属的虚拟主机。Name： 名称。Features： 功能。（参数交换机参数）State： 当前的状态，running：运行中；idle：空闲。Ready： 当前队列中等待被消费的消息数量(这些消息已经被投递到队列中，但还没有被消费者取走。Ready 数量反映了当前队列中的消息积压情况，即有多少消息处于等待状态，等待被消费者处理)Unacked： 未被消费者确认的消息数量(在消息队列中，当消费者接收到消息后，需要进行确认（acknowledge），表示已经处理了该消息。如果消息在一定时间内没有被确认，RabbitMQ 会将其重新放回队列，以便其他消费者重新处理)Total： 总数 Ready+Unacked。incoming： 消息进入的速率。deliver/get： 消息获取的速率。ack： 消息应答的速率。
再说一下admin界面
用户属性Name： 名称。Tags： 角色标签，只能选取一个。Can access virtual hosts： 允许进入的vhost。Has password： 设置了密码
好了,重点来了,环境有了,在项目中怎么编写代码并查看呢，咱们以platforms为例子
创建一个配置类(用于配置交换机、路由、队列信息)
参数1:队列名称(此处我是声明成了一个常量名,公司一般有一个专门存常量名的类,不知道这个类的问一问你老大哥在哪,去里面写去)
(没错,这个就是之前咱在RabbitMQ里面看到的那个platforms)
参数2：服务器重新启动后是否继续存在
参数3：用于声明一个独占队列(当 exclusive 参数设置为 true 时，表示该队列将只能被声明它的连接使用)
参数4：如果服务器应在队列不再使用时删除该队列，则为true，反之为false
参数5：用于声明队列的额外参数
设置完这些后,我们就可以开始编写业务代码了
(核心代码: convertAndSend => 发送数据)
再来到消费者这边
问题来了,执行完这些以后,去哪拿消费完的数据呢
当然是开个接口给前端取数据啦
到此为止整个mq的业务逻辑就结束了,接下来我们说几个对遇到的问题以及解决的小妙招
当队列有数据未消费、执行时间又过长,且后台没有报错时,我们无法确定数据到底是怎么个事儿
这个时候我们该怎么测出RabbitMQ消费者是否出错呢
这样代码出错时就可以让后台报错了，咱们就可以着手解决代码问题了
好了,RabbitMQ的使用暂时就先说到这儿,如果有不对的地方请各位正在给阿帕奇贡献的大佬们留言指证,对RabbitMQ还有补充的话我会单开一章继续补充,散会
相关文章
您阅读本篇文章共花了：
发表评论