操作场景
队列(Queue)用于存储消息,每个消息都会被投入到一个或多个 Queue 里,Producer 生产消息并最终投递到 Queue 中,Consumer 可以从 Queue 中拉取消息进行消费。
多个 Consumer 可以订阅同一个 Queue,这时 Queue 中的消息会被平均分摊给多个 Consumer 进行处理,而不是每个 Consumer 都收到所有的消息并处理。
该任务指导您使用消息队列 TDMQ RabbitMQ 版时在控制台上创建,删除和查询 Queue。
前提条件
操作步骤
创建 Queue
说明:
支持创建普通队列或Quorum队列,可以单击以下页签查看不同类型队列的创建方式。
1. 登录 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:当队列能力达到上限时,将丢弃队列头部的消息。
死信 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. 登录 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:当队列能力达到上限时,将丢弃队列头部的消息。
死信策略:可选 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 下的所有配置将会被清空,且无法恢复。