背景信息
分布式消息服务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)点击清空消息”,即可进入清空消息页面,再点击清空队列,可以清除队列的消息。
删除队列
在目标队列点击删除,即可删除队列。
注意事项: 删除队列时,队列中未被消费的消息会被同时删除,且不可恢复。请您谨慎操作。