创建RabbitMQ Queue
Queue用于存储消息,每个消息都会被发送到一个或多个Queue中,生产者生产消息并最终投递到Queue中,消费者可以从Queue中拉取消息进行消费。
多个消费者可以订阅同一个Queue,此时Queue中的消息会被平均分摊给多个消费者进行处理,而不是每个消费者都收到所有的消息。
本章节指导如何在控制台创建Queue。
前提条件
已创建Vhost。
创建RabbitMQ Queue
- 登录管理控制台。
- 在管理控制台左上角单击,选择区域。
此处请选择RabbitMQ实例所在的区域。
- 在管理控制台左上角单击,选择“应用服务 > 分布式消息服务 RabbitMQ”,进入分布式消息服务RabbitMQ专享版页面。
- 单击实例名称,进入实例详情页面。
- 在左侧导航栏选择“Vhost列表”,进入Vhost列表页面。
- 单击Vhost名称,进入Vhost详情页。
- 在“Queue”页签中,单击“创建Queue”,弹出“创建Queue”对话框。
- 参考表1,设置Queue的名称和配置信息。
表1 Queue参数说明 参数
说明
名称
系统为您自动生成了Queue名称,您可以根据需要修改。Queue名称需要符合以下规则:长度为3~128个字符,只能由英文字母、数字、百分号、竖线、中划线、下划线、斜杠、反斜杠组成。
创建Queue后不能修改名称。
持久化
是否开启Queue持久化。- 开启:该Queue在服务器重启后仍然存在。
- 不开启:该Queue在服务器重启后会被删除,需要重新创建。
自动删除
是否开启自动删除Queue。
- 开启:在订阅该Queue消息的最后一个消费者取消订阅该Queue的消息后,该Queue会被自动删除。
- 不开启:在订阅该Queue消息的最后一个消费者取消订阅该Queue的消息后,不会删除该Queue。
死信交换器
在下拉框中选择死信消息发送的Exchange。
死信路由键
设置死信消息的Routing Key,即死信Exchange会将消息发送至匹配该死信Routing Key的Binding Key所对应的Queue。
消息过期时间
消息的存活时间,单位为ms。超过消息过期时间,消息还未被成功消费,就会变为死信消息,该消息将会被发送到死信Exchange。
惰性队列模式
仅RabbitMQ 3.x.x版本包含此参数。
如果需要设置Queue为惰性队列,请输入“lazy”。
惰性队列会尽可能的将消息存入磁盘中,在消费者消费到相应的消息时才会被加载到内存中,这样可以减少内存的消耗。
- 单击“确定”,完成Queue的创建。
在“Queue”页签中,查询新创建的Queue。