本帖最后由 phoben 于 2024-1-3 13:56 编辑
假设你已经成功的部署好了RabbitMQ,那么恭喜你,你可以使用插件来轻松的管理它。 安装好插件后,在活字格设计器内的服务端命令下拉框里,就可以看到整个插件包的内容
插件看起来多,但不是每一个我们都需要频繁的用,大部分是用来做配置的 如果你对RabbitMQ熟悉,其实你也可以完全自己在它的web管理后台来配置,可能更加方便。 这里将插件分为几个类,让大家更好了解它的作用:
类别 | 包含插件 | 作用描述 | 服务器连接 conneciton | 创建服务器连接 删除服务器连接 获取所有连接名 | 用来与Rabbit MQ服务器建立连接,可连接本机/内网/外网/云服务器等等... | 交换机管理 Exchange
| 创建交换机 删除交换机 | 用来创建或删除一个交换机Exchange 交换机是Rabbit MQ里的重要概念,它负责将消息分配到不同列队。 | 队列管理 Queue | 创建一个队列 删除队列 清空队列 | 用来创建或删除一个队列 队列是用来存放待发布的消息的,交换机通过规则将消息存放到队列,消费者通过订阅队列拿到消息 | 绑定 Binding | 绑定交换机与队列
| 将交换机与队列按一定规则进行绑定 | 通道 Channel | 创建连接通道 关闭连接通道 | 这是消费者与服务器通信的通道,也可以理解为信道,它包括一些独特的配置,来定义本次通信的规则 | 订阅 | 开始订阅队列 停止订阅队列 | 这是最常用也是最核心的功能,它用来订阅或取消订阅一个队列,当你订阅后,有新的消息会主动的推送过来 从而触发我们实现编排好的处理命令 |
一般来说,开启web管理插件后,在服务器的15672端口会开放一个web系统,登录即可查看。
订阅列队的方法 如果你已经完成了交换机、列队的创建和绑定,你可以直接使用插件发送一条消息来测试。
第1步:连接服务器 连接后会得到一个“连接标识”,记得保存哦!
第2步:订阅消息 使用第一步的“连接标识”和你要订阅的“队列名称”来完成订阅。 订阅成功后,会返回一个“消费者标识”,取消订阅的时候需要用到。
这是核心中的核心了,我们必须定义消息到达后,如何处理该消息? 有了这些数据,我们就可以任意编辑需要处理消息的逻辑了
PS:这样做的好处显而易见,我收到了一条消息,但是我没有处理好它,如果这时RabbitMQ以为我处理完了,直接删掉了该消息,那我再也没有机会去处理了,也间接的导致该条消息的丢失。
第3步:发送消息 剩下的就是发布消息了,只需要提供消息内容即可,其他配置均可默认即可; 消息发布后,会返回一个“唯一消息标识”用于和你的业务数据形成关联;
发布消息和订阅消息,都可以很多服务器一起参与,比如说:你有三台服务器都部署了活字格应用,他们可能都是不同应用,但是不妨碍他们都朝RabbitMQ发布消息、订阅消息。
|