分布式消息服务RabbitMQ

队列管理

2024-06-27 02:25:46

背景信息

分布式消息服务RabbitMQ版的消息都会被投入到一个或多个队列中。Consumer Tag是消费者客户端的标识符。您可以在分布式消息服务 RabbitMQ 版的消费者客户端设置Consumer Tag。

创建队列

(1)登录管理控制台。

(2)进入RabbitMQ管理控制台。

(3)在实例列表页在操作列,目标实例行点击“管理”。

(4)点击“队列管理”后,点击“新建”按钮。

(5)点击“新建”后出现以下窗口,选择虚拟主机,输入队列名字,选择存储节点,然后点击确定即可创建队列。

参数

描述

虚拟主机

选择创建队列所属的虚拟主机

名称

队列的名称。以amq.开头的为保留字段,因此不能使用。例如:amq.test。

存储节点

队列数据存储节点

是否持久化

队列元数据是否持久化到磁盘

是否自动删除

最后一个Consumer取消订阅后,Queue是否自动删除。

其他参数

Message   TTL

     消息过期时间:number型(单位:ms)

     Auto expire

     队列过期时间,过期后队列自动删除:number型(单位:ms)

     Max length

     队列能保存的最大消息数:number型(单位:个)

     Max length bytes

     队列能保存的最大消息量:number型(单位:字节)

     Overflow behaviour

     超过队列的最大设定值后消息接收策略:drop-head,reject-publish

     drop-head:删除头部消息,一般就是最早发送的消息,保证队列可用

     reject-publish:拒绝接受新的消息,保证消息不丢失

     Dead letter exchange

     死信交换器名称

     Dead letter routing key

     死信路由键

     Maximum priority

     队列最大优先级:要开启消息的优先级,必须设置消息所在队列的优先级

     Lazy mode

     队列惰性模式:default、lazy

     default:默认值,普通队列

     lazy:惰性队列,尽可能将消息存到磁盘中,会引起I/O操作比较多,内存消耗极少(有大量堆积的持久化消息建议使用)

     Master Locator

     队列保存位置:client-local、min-masters、random

     client-local:队列创建时所用连接的节点

     min-masters: 集群中节点主数量最少的节点

     random:由rabbitmq服务器随机指定一个节点

 

查看队列

(1)点击目标队列名称,即可查看队列概况。

(2)点击“消费者”,即可查看队列的消费者。

(3)点击“绑定信息”,即可查看队列的绑定信息。

(4)点击“生产拨测”,即可进入队列的生产拨测页面。可通过生产拨测发送消息到队列。

(5)点击“消费拨测”,即可进入队列的消费拨测页面。通过消费拨测可以拉取队列的消息。

(6)点击清空消息”,即可进入清空消息页面,再点击清空队列,可以清除队列的消息。

删除队列

(1)在目标队列点击删除,即可删除队列。

注意事项: 删除队列时,队列中未被消费的消息会被同时删除,且不可恢复。请您谨慎操作。


s4euiAK7KZNx