操作场景
队列(Queue)用于存储消息,每个消息都会被投入到一个或多个 Queue 里,Producer 生产消息并最终投递到 Queue 中,Consumer 可以从 Queue 中拉取消息进行消费。
多个 Consumer 可以订阅同一个 Queue,这时 Queue 中的消息会被平均分摊给多个 Consumer 进行处理,而不是每个 Consumer 都收到所有的消息并处理。
该任务指导您使用消息队列 TDMQ RabbitMQ 版时在控制台上创建,删除和查询 Queue。
前提条件
操作步骤
创建 Queue
说明:
支持创建普通队列或 Quorum 队列,可以单击以下页签查看不同类型队列的创建方式。
普通队列:主要用于高性能、低延迟的场景,适合消息吞吐量大的情况。
Quorum 队列:专注于数据安全和一致性,适合对消息可靠性要求高的场景。
1. 登录 TDMQ RabbitMQ 版控制台。
2. 在左侧导航栏选择集群管理 > Queue 页签,选择 Vhost 后,单击新建进入创建 Queue 页面。
3. 填写 Queue 基本信息。

Queue 名称:填写 Queue 名称(创建后不可修改),1-64个字符,只能包含字母、数字、“-”及“_”
类型:普通队列。
Durable:设置队列是否执行持久化。
节点:选择队列所在节点。
AutoDelete:开启后,最后一个消费者取消订阅后立即删除该 Queue。
Queue 说明:填写 Queue 说明,最多128个字符。
4. 单击下一步,填写常用参数。

Message TTL:队列中的消息将在指定时间后丢弃/发往死信 Exchange。
Auto Expire:队列在指定时间内没有被使用(访问),将会被删除。
Max Length:队列可以容纳的消息的最大数量。
Max Length Bytes:队列可存储大小上限,如果达到上限,将根据 Overflow behaviour处理。
Overflow Behaviour:当队列能力达到上限时,将丢弃队列头部的消息。
drop-head:当队列达到容量上限时,丢弃队列头部的消息。
reject-publish:当队列达到容量上限时,拒绝新消息的发布,并将发布操作标记为失败。
reject-publish-dlx:当队列达到容量上限时,拒绝新消息的发布,并将消息发送到死信交换机(Dead Letter Exchange, DLX)。
死信 Exchange:消息超过 TTL 时间未确认即投往死信 Exchange。
5. 单击下一步,设置其他高级选项。


Single Active Consumer:若开启,需确保每次有且只有一个消费者从队列中消费。
Maximum Priority:配置该队列中的消息的优先级最大值。
Lazy Mode:开启后队列会优先将推送过来的消息保存在磁盘上以减少内存占用。
Master Locator:当配置了镜像队列时,master 所在节点的分配方式。
min-masters:当配置了镜像队列时,选择托管队列master数量最少的节点,作为当前队列的master所在的节点。
client-local:当配置了镜像队列时,选择声明队列的客户端所连接到的节点,作为当前队列的master所在的节点。
random:当配置了镜像队列时,选择一个随机节点作为当前队列的master所在的节点。
6. 单击提交,完成 Queue 创建。
1. 登录 TDMQ RabbitMQ 版控制台。
2. 在左侧导航栏选择集群管理 > Queue,选择 Vhost 后,单击新建进入创建 Queue 页面。
3. 填写 Queue 基本信息。

Queue 名称:填写 Queue 名称(创建后不可修改),1-64个字符,只能包含字母、数字、“-”及“_”
类型:Quorum队列。
节点:选择队列所在节点。
Queue 说明:填写 Queue 说明,最多128个字符。
4. 单击下一步,填写常用参数。

Auto Expire:队列在指定时间内没有被使用(访问),将会被删除。
Max Length:队列可以容纳的消息的最大数量。
Max Length Bytes:队列可存储大小上限,如果达到上限,将根据 Overflow behaviour处理。
Delivery Limit:若队列内消息投递失败,允许的重试次数。
Overflow Behaviour:当队列能力达到上限时,将丢弃队列头部的消息。
drop-head:当队列达到容量上限时,丢弃队列头部的消息。
reject-publish:当队列达到容量上限时,拒绝新消息的发布,并将发布操作标记为失败。
死信策略:可选 at-most-once 和 at-least-once。只有 overflow behaviour 选择了 reject-publish 时,死信策略才可以选择 at-least-once。
死信 Exchange:消息超过 TTL 时间未确认即投往死信 Exchange。
5. 单击下一步,设置其他高级选项。

Single Active Consumer:若开启,需确保每次有且只有一个消费者从队列中消费。
Max In Memory Length:Quorum队列内存中最大消息数量。
Max In Memory Bytes:Quorum队列中最大总消息大小(字节数)。
Initial cluster size:Quorum队列初始集群大小。
Leader locator:可选 client-local 和 balanced。如果网络延迟对性能影响较大,可以选择 client-local 策略;如果需要平衡各个节点的负载,可以选择 balanced 策略。
6. 单击提交,完成 Queue 创建。
查看 Queue 详情
在 Queue 列表,单击 Queue 的“ID”,可查看该 Queue 的详情。
您可以看到:
基本信息:展示队列类型、在线消费者、死信 Exchange、AutoDelete 等信息。单击更多高级选项,可以查看该 Queue 所有参数设置信息。
消费者列表:展示订阅该 Queue 的消费者信息。
绑定关系:展示与该 Queue 绑定的路由关系。

编辑 Queue
1. 在 Queue 列表中,单击目标 Queue 操作列的编辑。
2. 在弹窗中,对 Queue 信息进行编辑。
3. 单击提交,完成修改。
删除 Queue
1. 在 Queue 列表中,找到需要删除的 Queue,单击操作列的删除。
2. 在弹出的提示框中,单击删除,完成删除。
注意:
Queue 删除后,该 Queue 下的所有配置将会被清空,且无法恢复。