惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

D
DataBreaches.Net
Microsoft Security Blog
Microsoft Security Blog
大猫的无限游戏
大猫的无限游戏
B
Blog RSS Feed
MyScale Blog
MyScale Blog
博客园_首页
S
SegmentFault 最新的问题
WordPress大学
WordPress大学
小众软件
小众软件
V
Visual Studio Blog
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
Vercel News
Vercel News
Hugging Face - Blog
Hugging Face - Blog
The GitHub Blog
The GitHub Blog
D
Docker
宝玉的分享
宝玉的分享
博客园 - 【当耐特】
F
Fortinet All Blogs
V
V2EX
Last Week in AI
Last Week in AI
Blog — PlanetScale
Blog — PlanetScale
Microsoft Azure Blog
Microsoft Azure Blog
IT之家
IT之家
雷峰网
雷峰网
博客园 - 叶小钗
月光博客
月光博客
J
Java Code Geeks
量子位
爱范儿
爱范儿
阮一峰的网络日志
阮一峰的网络日志
Martin Fowler
Martin Fowler
H
Help Net Security
酷 壳 – CoolShell
酷 壳 – CoolShell
腾讯CDC
Latest news
Latest news
Recent Announcements
Recent Announcements
Google DeepMind News
Google DeepMind News
美团技术团队
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
T
The Blog of Author Tim Ferriss
T
Troy Hunt's Blog
B
Blog
T
Tenable Blog
S
Schneier on Security
L
LangChain Blog
L
LINUX DO - 热门话题
博客园 - 司徒正美
I
InfoQ
P
Privacy International News Feed
P
Privacy & Cybersecurity Law Blog

RabbitMQ

一个任务有 10 个处理步骤,在 mq 中把每一个步骤都设置成一个 TOPIC,在 mq 里 将这么多任务步骤细分这么多 topic 的好处该怎么回答? - V2EX 请教一下各位大佬 rabbitMq 接收数据的问题 - V2EX RabbitMQ 使用过程中,什么时候才需要新建 exchange? - V2EX RabbitMQ 在有多个消费者(单个应用部署多个实例)的情况下如何保证顺序消费 - V2EX 客户端连接 rabbitmq 如何验证客户端合法性? - V2EX rabbitMQ 的 topic 模式下,如何实现有 N 个订阅者,发布一条消息后,当 N 个消费者都拿到这个消息后将该消息销毁(确认消费) - V2EX springboot 集成 RabbitMQ 的问题 - V2EX AMQP 1.0 的现状? - V2EX RabbitMQ 不能实现消息超时之后自动重新分发吗? - V2EX 在 Mac OS X 下安装 RabbitMQ - V2EX
求问 RabbitMQ 一个 queue 多个 consumer 只有少部分能收到信息是怎么回事 - V2EX
MTMT · 2022-03-24 · via RabbitMQ

MTMT

V2EX  ›  RabbitMQ

 

MTMT · 2022 年 3 月 24 日 · 1970 次点击

这是一个创建于 1543 天前的主题,其中的信息可能已经有所发展或是发生改变。

有一个 queue ,20+个 consumer ,只有 3 ,4 个能收到消息,剩下的就是保持 idle 状态, 队列里消息明明上万条,channel.basic_consumechannel.consume 方法都试过,没有任何错误,有人遇到过这种情况吗?

客户端用 pika, queue 的设置是

queue_args = {
    "x-max-priority": 11,
    "x-max-length-bytes": 1000000000,
    "x-overflow": "reject-publish"
}
channel.queue_declare(queue=name,
                      durable=True,
                      arguments=queue_args)

没有设置 prefetch, 那些 idle 的 process 检查 queue_declare 返回结果里的 queue 里的消息数量也是 0 ,就很奇怪,有人遇到过类似的情况吗?