腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
RabbitMQ
如何
处理
更少
的
消息
更多
的
消费者
?
rabbitmq
我们有一个设置,其中我们有许多
消费者
到一个队列中。 问题是,这些
消费者
中似乎只有一小部分人在实际工作。 示例 一个队列有120个
消费者
,大约有1000条
消息
? 不过,它一次似乎只能
处理
20条
消息
。
浏览 16
提问于2020-02-01
得票数 0
1
回答
哪种解决方案能更好地
处理
发布服务器/订阅服务器场景?
xmpp
、
rabbitmq
、
publish-subscribe
、
amqp
、
apache-kafka
这个场景是publisher/订户,我正在寻找一种解决方案,它可以让一个生产者在多个
消费者
之间实时发送一条
消息
的
可行性。这个场景
的
重量越轻,就越能被一个解决方案
处理
,越好!,则会有数千个左右
的
匿名队列由
rabbitmq
处理
。但是我真的不喜欢
rabbitmq
的
方法,如果
rabbitmq
能够
处理
这个使用一个队列、一个
消息
、许多
消费者
监听一个
浏览 7
提问于2014-05-18
得票数 1
1
回答
如何
实现能够消费多种产品
的
消费者
的
竞争
消费者
?
rabbitmq
、
messaging
我想使用
RabbitMQ
实现竞争
消费者
,我有两个(或
更多
)
消费者
:
消费者
2可以使用“红色”和“黑色”类型
的
信息。现在,我希望使用竞争
的
使用者模式在
消费者
之间进行负载平衡(可能还有
更多
具有相同配置
的
消费者
实例),并且我希望保持
消息
排序“松散”完整(我不需要完美的排序,但希望从2小时
浏览 0
提问于2019-02-22
得票数 0
2
回答
RabbitMQ
:为多个
消费者
从队列中发送固定
消息
rabbitmq
、
spring-amqp
是否有一种方法可以限制
RabbitMQ
队列只将固定数量
的
消息
从队列发送给
消费者
?我有两个队列Q1和Q2,10个consumers.Every使用者可以
处理
来自Q1和Q2
的
消息
,在任何给定
的
时间,只有两个
消费者
应该
处理
来自Q2
的
消息
,所有这10个
消费者
都可以同时
处理
来自Q1
的
消息
。在
RabbitMQ</e
浏览 0
提问于2019-03-09
得票数 1
回答已采纳
1
回答
一段时间后,
Rabbitmq
无法应付
rabbitmq
我有一个
rabbitmq
队列,每个发布到这个队列
的
数据大约是1MB大小。每秒钟有4或5个数据发布到此队列。
消费者
逐个地消费每个数据(Fetch=1)。当我停止消费服务30000时,排队
的
消息
就可以使用了。当我开始消费
的
时候,它
的
消费率是30/s+。现在还好。Hovewer in day light publisher从不停止发布,
消费者
可以
处理
队列。但在晚上,出版商不再发送数据(这不是错误。应该是这样
的
)
浏览 2
提问于2019-07-11
得票数 0
回答已采纳
1
回答
RabbitMQ
:按优先级选择队列
php
、
rabbitmq
我在php中使用
RabbitMQ
,在两个队列( Q1和Q2 )上有一个使用者。由于按摩在Q1中更重要,我希望它们首先被
处理
。 只有在Q2 Q1没有按摩
的
情况下,才能使
消费者
从中消费?结果是
消费者
在Q1和Q2之间交替使用。
浏览 2
提问于2017-01-06
得票数 2
回答已采纳
2
回答
如何
将
RabbitMQ
缩放到某些
消费者
?
rabbitmq
我使用
RabbitMQ
向2个或
更多
的
用户发送
消息
。看看,我可以很容易地做到这一点。但我也想扩展我
的
一些
消费者
,并允许一些
消费者
总是
处理
消息
,而一些
消费者
只在
消息
尚未被另一个‘类似的’
消费者
处理
过
的
情况下
处理
该
消息
。|-------> cAP --|-------> cB'
浏览 2
提问于2018-10-02
得票数 0
1
回答
代理
如何
确保该
消息
仅由一个使用者使用?
rabbitmq
我有一个队列和两个
消费者
c1和c2。我
的
两个
消费者
已经启动并运行。当
消息
发布到队列时,JMS broker (
RabbitMQ
)
如何
确保该
消息
只由一个使用者使用?
浏览 9
提问于2021-01-28
得票数 0
2
回答
如何
使
消费者
与狂犬病人同步
synchronization
、
rabbitmq
、
synchronous
我有以下问题:我有一个
RabbitMQ
集群、一个
消息
生成程序和一个
消费者
集群(用于高可用性)。每当
消费者
收到
消息
时,它就会根据
消息
内容生成另一个进程并运行它。这个过程很长,大约需要30分钟。我必须确保一次只
处理
一个
消息
。但是,有比一个
更多
的
消费者
,所以如果一个队列中有两个
消息
,一个
消费者
得到一个
消息
,另一个
消费者
得到另一个<em
浏览 2
提问于2017-12-06
得票数 4
回答已采纳
1
回答
如何
在不同信道中确认
Rabbitmq
中
的
消息
rabbitmq
我有一个关于
RabbitMq
消费者
确认
的
查询,我阅读了
RabbitMq
上
的
文档,声明确认
消息
应该在
消费者
接收到
的
同一个通道上。但是,由于某种原因,在收到
消息
之后,由于某种原因
消费者
进程被停止,并且没有确认
Rabbitmq
,当
消费者
进程重新启动时,
消费者
开始从
RabbitMq
获得未被确认
的
消息
,但是在这里,使用者
浏览 3
提问于2018-11-22
得票数 0
1
回答
PHP
RabbitMQ
使用者停止使用事件
php
、
rabbitmq
、
php-amqplib
我有一个使用php-amqplib
的
php守护进程,它使用来自
RabbitMQ
服务器
的
消息
。下面是它
的
要点(尽管它比这个要复杂一点): $callback = function (AMQPMessage $msg) { $channel->wait();$this->connection->close
浏览 72
提问于2021-07-22
得票数 0
回答已采纳
2
回答
如何
让
RabbitMQ
重新发送未确认
的
消息
?
rabbitmq
我这样启动
RabbitMQ
服务器:docker run -d --hostname my-rabbit-host --name my-rabbit -p 5672:5672
rabbitmq
:3使用此代码我们可以确保,即使您在
处理
消息
时使用CTRL+C杀死一个工作人员,也不会有任何损失。工作进程死后不久,所有未确认
的
消息
都将被重新传递。 我产生了两个
消费者
,当我对其中一个
消费者</e
浏览 173
提问于2017-10-10
得票数 0
1
回答
RabbitMQ
消费者
体系结构
php
、
message-queue
、
rabbitmq
我一直在研究
如何
使用
RabbitMQ
进行跨微服务
的
发布/订阅模式,其中aysnc调用是合适
的
,但是我很难理解一些概念,并且在手册中找不到任何信息。如果到目前为止我
的
理解是正确
的
,我
的
主要问题是
如何
在服务结束时
处理</e
浏览 0
提问于2019-05-15
得票数 1
1
回答
如何
确保
消息
平均发送到所有
消费者
go
、
rabbitmq
在我们公司,我们在Go中构建了一个推送服务,并将其放在四台机器上以确保传输速度,当我们需要发送通知时,我们发送
消息
给
rabbitMQ
,然后推送服务将从队列中获取
消息
,但有时我们发现只有一台机器获得
消息
。以下是
rabbitMQ
使用者
的
配置: q.Name, // queue
浏览 0
提问于2018-06-15
得票数 0
2
回答
AMQP
RabbitMQ
消费者
相互阻塞?
c
、
rabbitmq
、
amqp
、
librabbitmq
我编写了一个C(
Rabbitmq
)工作程序,它使用Python脚本(pika)发布
的
队列。 但是:在工作人员开始从队列中消费之后启动额外
的
工作人员,意味着这些工作人员看不到队列上
的
任何
消息
(message count=0),因此只需等待(即使队列中仍然有许多
消息
杀死第一个工作人员会突然启动
消息
流到所有其
浏览 11
提问于2014-08-01
得票数 4
回答已采纳
1
回答
<channel>.group获得精确
的
一次传递时,我可以使用
RabbitMQ
吗?
java
、
spring
、
spring-boot
、
rabbitmq
、
spring-cloud-stream
所以我读了这个来配置
RabbitMQ
和SpringBoot。通过
消费者
群体
的
概念对这种行为进行建模。(
消费者</
浏览 0
提问于2019-07-06
得票数 0
回答已采纳
1
回答
RabbitMQ
让使用者在完成以前
的
任务之前接收
更多
的
任务
rabbitmq
、
amqp
、
producer-consumer
根据我对
RabbitMQ
/AMQP
的
理解,我看到了一种不幸
的
权衡。 所以问题是,“我可以接受
更多
的
工作”和“我完成了这个任务”。问题是!我
的
消费者
机器被分析为并行
处理
50个任务,每个任务需要30秒左右。
如何</em
浏览 2
提问于2013-03-08
得票数 0
回答已采纳
1
回答
MassTransit -限制在多用户设置中并发
处理
哪些
消息
c#
、
rabbitmq
、
masstransit
目前,我有一个窗口服务使用
RabbitMQ
来
处理
来自web应用程序
的
消息
异步。此服务使用
消息
上
的
实体ID来查找需要
处理
的
实体。当前
的
消息
没有指明应该对实体做什么,因为这已经由内部操作日志提供了。为了帮助移动到多个竞争
的
消费者
设置,我考虑在
RabbitMQ
上实现
RabbitMQ
。 我正在研究
如何
防止具有相同实体ID
的</e
浏览 4
提问于2017-04-04
得票数 0
回答已采纳
2
回答
当
RabbitMQ
使用者崩溃时,获取
消息
会发生什么?
queue
、
rabbitmq
、
message-queue
、
amqp
如果我有一个
RabbitMQ
使用者批量检索100条
消息
,但在将这些
消息
标记为已
处理
之前就会崩溃,那么这些
消息
是否丢失了?我希望队列中
的
每条
消息
至少
处理
一次。在确认
消息
之前,有什么推荐
的
方法来
处理
那些崩溃
的
消费者
?
RabbitMQ
是否以某种方式将它们重新放到了队列中,或者我需要做些什么来实现它呢?
浏览 8
提问于2017-02-21
得票数 11
3
回答
RabbitMQ
-知道
消费者
在上升
c#
、
rabbitmq
我有几个关于
RabbitMQ
编码
的
问题.我对这个世界并不陌生,我有一些问题是根据提供给我
的
设计来实现
的
.如果我从使用者发送BasicAck或BasicAack,它是只从队列中删除相应
的
消息
,还是将Ack传递给发布者?
如何
确保发布者仅在使用者准备进行
处理
时才向服务器发送
消息
?该设计说,发布者需要等待并知道
消费者
的
处理
何时完成,以便在客户端完成特定
的
任务(取决于
浏览 4
提问于2016-03-18
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
主动学习:如何用更少的数据做更多的事情?
Kafka是如何处理Netflix每天2万亿条消息的?
Kafka与RabbitMQ千万不要乱用…
RabbitMQ教程C#版-工作队列
RabbitMQ+PHP 教程一:Hello World
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券