更新时间:2024-10-25 GMT+08:00

创建RabbitMQ Queue

Queue用于存储消息,每个消息都会被发送到一个或多个Queue中,生产者生产消息并最终投递到Queue中,消费者可以从Queue中拉取消息进行消费。

多个消费者可以订阅同一个Queue,此时Queue中的消息会被平均分摊给多个消费者进行处理,而不是每个消费者都收到所有的消息。

本章节指导如何在控制台创建Queue。

前提条件

创建Vhost

创建RabbitMQ Queue

  1. 登录管理控制台。
  2. 在管理控制台左上角单击,选择区域。

    此处请选择RabbitMQ实例所在的区域。

  3. 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务RabbitMQ版”,进入分布式消息服务RabbitMQ专享版页面。
  4. 单击实例名称,进入实例详情页面。
  5. 在左侧导航栏选择“Vhost列表”,进入Vhost列表页面。
  6. 单击Vhost名称,进入Vhost详情页。
  7. 在“Queue”页签中,单击“创建Queue”,弹出“创建Queue”对话框。
  8. 参考表1,设置Queue的名称和配置信息。

    表1 Queue参数说明

    参数

    说明

    名称

    系统为您自动生成了Queue名称,您可以根据需要修改。Queue名称需要符合以下规则:长度为3~128个字符,只能由英文字母、数字、百分号、竖线、中划线、下划线、斜杠、反斜杠组成。

    创建Queue后不能修改名称。

    持久化

    RabbitMQ 3.x.x版本需要设置此参数。RabbitMQ AMQP-0-9-1版本Queue默认开启持久化。

    是否开启Queue持久化。
    • 开启:该Queue在服务器重启后仍然存在。
    • 不开启:该Queue在服务器重启后会被删除,需要重新创建。

    自动删除

    是否开启自动删除Queue。

    • 开启:在订阅该Queue消息的最后一个消费者取消订阅该Queue的消息后,该Queue会被自动删除。
    • 不开启:在订阅该Queue消息的最后一个消费者取消订阅该Queue的消息后,不会删除该Queue。

    死信交换器

    在下拉框中选择死信消息发送的Exchange。

    死信路由键

    设置死信消息的Routing Key,即死信Exchange会将消息发送至匹配该死信Routing Key的Binding Key所对应的Queue。

    消息过期时间

    消息的存活时间,单位为ms。超过消息过期时间,消息还未被成功消费,就会变为死信消息,该消息将会被发送到死信Exchange。

    最大优先级

    仅RabbitMQ AMQP-0-9-1版本包含此参数。

    设置Queue的优先级,取值范围为1~9。数值越大,优先级越高。

    惰性队列模式

    仅RabbitMQ 3.x.x版本包含此参数。

    如果需要设置Queue为惰性队列,请输入“lazy”。

    惰性队列会尽可能的将消息存入磁盘中,在消费者消费到相应的消息时才会被加载到内存中,这样可以减少内存的消耗。

  9. 单击“确定”,完成Queue的创建。

    在“Queue”页签中,查询新创建的Queue。