当前位置: 首页 > 知识库问答 >
问题:

RabbitMQ 工作队列配置问题

穆飞龙
2023-03-14

关于RabbitMQ工作队列,我有两个问题:

>

  • 正如我从RabbitMQ教程中了解到的,如果我有一个基本的队列使用者客户端(只是一个基本“Hello,World!”使用者),然后我为同一个队列添加第二个使用者客户端,那么RabbitMQ将以循环方式自动在这两个队列之间分派消息。这是真的吗(没有添加任何额外的配置)?

    我的消费者客户端被配置为一次只接收一条消息,使用(GetResponse响应= channel.basicGet("my_queue", false)。由于我一次只收到一条消息,是否还需要设置prefetchCount(channel.basicQos(1))以公平调度?

  • 共有1个答案

    皇甫夕
    2023-03-14

    您问题的答案:

    但是,您的两个问题 1 和 2 不兼容。如果您使用的是使用者,则它旨在将消息推送到它,并且您不使用 Basic.Get。使用使用者时,需要使用 Basic.QoS 指定使用者一次只能“拥有”一条未确认的消息。RabbitMQ 不会推送超出 QoS 限制的额外消息。

    您的替代方法是使用Basic. Get从队列中“拉取”,您将控制自己的命运,只要您一次运行多少条消息。

    这有道理吗?

     类似资料:
    • 我有一个spring jms应用程序,目前使用ibm mq server进行队列管理。我们计划将中间件改为rabbitmq,以获得更好的性能并有效地控制它,但希望保持spring jms代码的原样。我遵循了以下链接中提到的所有步骤。https://www.rabbitmq.com/jms-client.html

    • 我需要配置我的应用程序,以便发送和消费消息从/到一个队列坐在一个服务器上。我的应用程序中有以下配置。属性: 在我的控制器中: 然而,我得到了错误,说不满足的依赖通过字段'rabbit template'表示;嵌套异常为Org.SpringFramework.Beans.Factory.UnsatisfiedDependencyException。 有人帮忙吗? 错误的全部跟踪 unsatisfie

    • 我已经用RabbitMQ(3.7.6)设置了一个Laravel(5.6)应用程序,使用最新的Laradock和作曲家安装的https://github.com/vyuldashev/laravel-queue-rabbitmq。当我启动Laravel消息工作人员与我得到以下错误 但是,我可以使用telnet 127.0连接到Rabbit。0.1 5672(连接在不活动10秒后关闭)。听众似乎工作正

    • 我目前正在尝试使用RabbitMQ(具有出色的RabbitMQBundle)来处理大量的异步工作。 目标是让一个队列发布相同类型的消息,并让多个服务器上的X个工作者在同一时间内查看消息。 每个工人都要偷看一条消息,完成工作,然后偷看另一条消息,等等。 这里是我的conf: 在我的consumer中,我有一个日志文件中的条目和120秒的睡眠。 我启动了php app/console rabbitmq

    • rabbitMQ 工作队列 轮询分发 >[danger] 简单队列是一对一的关系,一个生成者对应一个消费者,实际开发中,一般消费者是以业务相结合的,需要时间去处理业务,如果只有一个消费者,那么生产者就会积压很多消息,消费不出去 代码演示: 'use strict'; const Controller = require('egg').Controller; /** * 队列一对多演示 * 生产

    • 工作队列接口 结构体 struct   rt_workqueue   工作队列控制块 更多...   struct   rt_work   工作回调函数信息 更多...   函数 struct rt_workqueue *  rt_workqueue_create (const char *name, rt_uint16_t stack_size, rt_uint8_t priority)   创

    • 首先,我为我的英语感到抱歉。我正在做一份高中的工作,我需要在YAML文件中为我的侦听器设置RabbitMQ队列名称,但我做不到。我用application创建了应用程序。属性,它工作了,但我需要更改为YAML。你能帮帮我吗? 我的application.yaml 谢谢=)

    • 我正在尝试扩展RabbitMQ消息传递系统。当前的系统非常简单——生产者向扇出交换发送消息,消息由多个消费者处理——经典的扇出路由。 我有多个不同类型的消费者(例如:一个打印到屏幕,一个记录到文件,一个保存到数据库,…)。我的挑战——我不确定扩大消费者规模的最佳方式是什么。如果我添加来自同一类型的其他使用者,我将在数据库中获得两个日志或两个条目。。。(假设两个DB消费者从同一扇出交换中消费)。 我