腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
使用spring-rabbit从多个rabbit
队列
分片
中消费
rabbitmq
、
spring-rabbit
我有
一个
包含
分片
队列
的
rabbit集群(3个节点)。每个
分片
驻留在不同
的
rabbit代理节点上。我使用spring rabbit模块来使用
分片
队列
中
的
消息,但是,
使用者
总是从单个rabbit节点(因此是
分片
)连接(并使用)。我已经将缓存模式设置为“connection”,所以可以打开多个连接,我使用spring.
rabbitmq
.addresses属性来传递spring连接工厂<e
浏览 0
提问于2020-08-16
得票数 0
3
回答
Rabbitmq
队列
分片
rabbitmq
、
sharding
我必须实现这个场景:是否有可能在标准
的
交换中实现?如何动态更改client_id范围?
浏览 3
提问于2012-09-12
得票数 1
1
回答
具有
一个
使用者
的
RabbitMQ
分片
队列
.net-core
、
rabbitmq
、
sharding
有没有可能让
一个
消费者从交换中
的
所有
分片
队列
中消费?使用下面的代码,我只使用其中
一个
队列
: using (var connection = factory.CreateConnection()) {
浏览 37
提问于2021-08-11
得票数 0
1
回答
兔MQ Ctl -连接到信道映射
rabbitmq
我需要使用兔子mq ctl将
队列
映射到
使用者
的
ip。使用兔子mq ctl list_queues ->给出了
队列
和通道名称。rabbitmqctl list_queues list_consumers ->给出了
具有
通道ids
的
队列
的</em
浏览 0
提问于2018-09-26
得票数 0
回答已采纳
2
回答
多交换
队列
模型
的
RabbitMQ
消费者设计
rabbitmq
、
message-queue
、
rabbitmq-exchange
我有
一个
具有
以下配置
的
RabbitMQ
设置。 有些有效负载比其他负载需要更长
的
处理时间,这导致
使用者
即使在其他
队列
中有有效负载时也会保持空闲状态。 如何实现
使用者
以避免长时间
的
等待?我应该为每个模块运行单独
的
浏览 5
提问于2016-01-20
得票数 0
2
回答
RabbitMQ
是否像Kafka一样支持哈希分区?
rabbitmq
我有
一个
在单个
队列
上订阅了多个
使用者
的
RabbitMQ
。我希望
具有
相同散列键
的
消息每次都可以被相同
的
消费者消费。我知道
RabbitMQ
的
默认行为是循环遍历所有
使用者
,并按1分派消息。它有没有和Kafka分区一样
的
能力? 谢谢
浏览 33
提问于2020-02-14
得票数 0
1
回答
Kombu+
RabbitMQ
:检查
队列
是否为空
python
、
rabbitmq
、
kombu
架构 live事件
的
数量变化很大,在高峰时间,
使用者
无法处理负载,
队列
被上千项阻塞。 我想使系统
具有
适应性,这样如果
队列
为空
浏览 6
提问于2016-11-07
得票数 4
1
回答
为什么在
RabbitMQ
中连接恢复之后会出现重复
的
使用者
?
java
、
rabbitmq
、
amqp
我正在使用: 在我
的
应用程序中,有
一个
异步
使用者
通过回调接收消息。当我试图通过禁用与代理
的
网络通信来模拟连接失败时,会发生此
浏览 2
提问于2015-07-06
得票数 5
3
回答
芹菜广播与
RabbitMQ
扇形
rabbitmq
、
celery
它
的
配置乱七八糟,过于复杂,而且文档也不完整。 但是在芹菜中,所有的术语都是混乱
的
:在这里,您可以拥有
一个
,它向多个消费者发送消息:我甚至不明白芹菜广播
队列
是如何工作
的
,因
浏览 3
提问于2014-06-18
得票数 13
回答已采纳
1
回答
如何使用
RabbitMQ
使用
具有
自定义名称
的
队列
(动态定义)
rabbitmq
、
rabbitmq-exchange
、
php-amqplib
、
php-amqp
我有
一个
I任务,每个任务都有一些任务要做: 对于每个任务,用户数和作业数是不同
的
。我希望将所有作业放入
一个
具有
名称任务{id}
的
队列
中,以便控制任务何时完成(通过空
队列
任务{id}),并使用
rabbitMQ
帮助自动删除它,并控制处理
一个
任务{id}
的
多个
使用者
。我希望我
的
消费者一直像守护进程一样工作,并选择
具有
自动
浏览 5
提问于2019-11-24
得票数 0
1
回答
兔子MQ虚拟主题?
rabbitmq
、
virtual-topic
在兔子MQ中,是否存在与活动MQ虚拟主题相同
的
内容?或者任何其他机制都可以实现
队列
语义。一些主题订阅者需要在返回联机时传递持久消息,并进行负载平衡。编辑作为
一个
简单
的
例子,每当用户登录失败时,主应用程序就会发布一条消息。其中
一个
侦听器为每次登录失败发送一封电子邮件,而另
一个
则需要在一天5次失败
的
情况下发送一封电子邮件
浏览 3
提问于2015-07-22
得票数 2
回答已采纳
2
回答
弹性搜索与
RabbitMQ
elasticsearch
、
rabbitmq
、
elasticsearch-river
我有
一个
RabbitMQ
队列
,它摄入了一些需要转移到弹性搜索
的
文档。可能
的
备选方案: 有人能发个例子吗?
浏览 7
提问于2015-07-21
得票数 3
1
回答
RabbitMQ
消息存储和消费
rabbitmq
我是
RabbitMQ
的
新手。在
RabbitMQ
中,一旦消息被
使用者
使用,它是否仍然在
队列
中可用?来自特定
队列
的
单个消息能被多个
使用者
使用吗?与卡夫卡不同,在文件系统中存储消息是如何在
RabbitMq
中存储
的
?
浏览 4
提问于2017-06-12
得票数 1
回答已采纳
2
回答
RabbitMQ
锁定消息组
rabbitmq
、
queue
我正在向
RabbitMQ
或其他message broker用户专业人士寻求帮助。我是message broker系统
的
新手,所以如果我使用
的
措辞不正确,请耐心等待。我们有
一个
用户注册
的
SAAS平台,我们开始为他们自动化一些流程。这些过程中
的
一些需要为每个用户逐一处理。这就是我们想要使用message broker
的
地方。 该系统如下所示: ? 其中我们
的
颜色表示不同
的
用户。因此,如果C-1开始处理来自黄色用户
的
浏览 22
提问于2020-07-28
得票数 0
回答已采纳
1
回答
如何在
RabbitMQ
中将消息传递给消费者
java
、
rabbitmq
我目前正在开发
一个
使用
RabbitMQ
消息代理
的
应用程序。我对消息传递
的
工作原理感到困惑,我已经查看了他们
的
官方文档,但无法澄清我
的
担忧。假设我
的
应用程序可以从两个
队列
获取消息,对于
队列
A,生产者直接将消息推送到此
队列
,而
队列
B通过交换获取消息。我
的
问题是,如果同时有来自
队列
A和
队列
B
的
消息到达消费者,消费者将如何消费这些消息?
浏览 1
提问于2020-06-02
得票数 1
1
回答
RabbitMQ
同时发布和使用相同
的
队列
rabbitmq
、
message-queue
我有
一个
RabbitMQ
消息
队列
,我希望从web服务调用ServiceA向
队列
发布多条消息。同时,还有
一个
名为ServiceB
的
web服务,用于在10秒
的
时间间隔内使用来自
RabbitMQ
相同
队列
的
消息。对于
RabbitMQ
队列
的
实现,这种用例可能吗?
RabbitMQ
是否支持发布者和
使用者
同时(同时)访问相同
的
浏览 2
提问于2020-01-03
得票数 2
回答已采纳
1
回答
RabbitMQ
:如何限制路由密钥格式
java
、
rabbitmq
、
spring-rabbit
我
的
制片人向交易所发送消息。我有很多
使用者
,我给每个用户
一个
不同
的
路由密钥,比如"a.b.1“到第
一个
,"a.b.2”到第二个等等。我希望防止任何
使用者
使用匹配所有消息(如"a.b.#“)
的
路由密钥绑定其
队列
。知道怎么做吗?
浏览 3
提问于2015-07-28
得票数 2
回答已采纳
1
回答
Masstransit+
RabbitMQ
.在两种不同
的
消息类型之间共享
一个
队列
rabbitmq
、
message-queue
、
messaging
、
masstransit
我有
一个
发布者,它将消息发布到
rabbitmq
://localhost/test123
队列
中。
一个
消息
具有
TestMessage类型,另
一个
TestMessage2类型。://localhost/test123")); //config stuff sbc.ReceiveFrom("<em
浏览 9
提问于2017-07-07
得票数 0
回答已采纳
1
回答
RabbitMQ
/ AMQP中
的
消息组
rabbitmq
、
messaging
、
amqp
ActiveMQ / JMS有
一个
内置机制,以确保共享公共标头(即JMSXGroupID报头)
的
消息在使用竞争消费者模式时总是被
队列
的
同
一个
使用者
所使用。
队列
的
使用者
完全不知道实际
的
报头值,因为
具有
公共报头
的
消息
的
保证是在服务器端而不是在
使用者
端执行
的
。有关此操作
的
详细信息,请参阅。 用AMQP还是<
浏览 7
提问于2013-12-11
得票数 10
回答已采纳
2
回答
为什么publisher在Pika
RabbitMQ
中声明
队列
a?
python
、
rabbitmq
、
pika
我已经了解了
RabbitMQ
的
基本原理。有一件事我发现发布者不会直接在
队列
上发布。exchange根据routing-key和exchange类型决定消息应该在哪个
队列
上发布(下面的代码使用默认交换)。我还找到了publisher
的
示例代码。pdfprocess', body='User information')connection.close() 在第9行中,
队列<
浏览 5
提问于2021-02-24
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RabbitMQ和Kafka到底怎么选?
深入理解消息中间件技术之RabbitMQ服务
SpringBoot 第十二章:RabbitMQ 集成使用
RabbitMQ 集群原理和完善
急需降低系统复杂性,我们从Kafka迁移到了Pulsar
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券