腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
仅向
RabbitMQ
中的多个使用者中的一个发送一条消息
、
、
、
我对
RabbitMQ
有一个比较独特的用例,我不确定如何解决这个问题。我希望有一个绑定了多个
消费者
的队列,然后让
RabbitMQ
一次只向一个
消费者
发送一条消息,并在向任何其他
消费者
发送另一条消息之前等待ACK。我意识
到
这会扼杀吞吐量,基本上会让其他
消费者
挨饿,但对我来说,这是可以接受的。出现这种奇怪用例的原因是,使用者与之交谈的服务一次只能处理一个并发
请求
,因此我需要一种方法来限制这种情况,但使用者也可能意外死亡,如果发生这种情况,我需要
另一个<
浏览 1
提问于2013-05-23
得票数 1
1
回答
如何在
RabbitMQ
中对
消费者
进行分组?
、
、
我们正在编写邮件同步系统,并为此使用
RabbitMQ
。每个生产者都推送邮件ids,然后使用者获取ids并将邮件插入
到
db。当我们有100个
消费者
(例如)而生产者生成In的速度太快时,每个
消费者
都会获得In并使用api获取邮件,因此并发
请求
对api的限制将是例外。С和我们限制每个生产者的使用者(例如,如果最大的3个
消费者
将接收一个生产者的if,那么下一个3将从
另一个
生产者接收,等等)?
浏览 2
提问于2016-04-06
得票数 0
1
回答
Celery为生产者和
消费者
配置单独的连接
、
、
、
芹菜应用程序使用
RabbitMQ
作为代理。我们使用heroku的AMQP附加组件作为
RabbitMQ
消息代理。这个附加组件指定了两个单独的url,一个为生产者优化,
另一个
为
消费者
优化。此外,根据
RabbitMQ
文档,建议对生产者和
消费者
使用单独的连接。 Celery文档没有提供单独指定
到
生产者和
消费者
的连接的方法。有没有办法在celery中指定两个不同的代理urls?
浏览 3
提问于2013-11-07
得票数 5
1
回答
来自MassTransit/
RabbitMQ
中的负载平衡应用程序的竞争
消费者
、
、
、
、
我刚刚创建了一个API,其中来自API的
请求
将使用
请求
/响应模式通过MassTransit/
RabbitMQ
转发到后端服务。我们现在正在考虑将其推向生产,并希望在不同的服务上运行应用程序的多个实例(包括API和服务),并使用负载均衡器在它们之间分发
请求
。我正在考虑在服务器之间创建一个
RabbitMQ
集群(每个服务器都有一个本地安装),并且想知道如何在这个实例中设置竞争的
消费者
。
RabbitMQ
或MassTransit是否会处理此问题,以便只有一个<e
浏览 0
提问于2012-06-17
得票数 1
回答已采纳
1
回答
如何将
RabbitMQ
数据返回给客户端(网站用户)
、
、
、
我正在学习
RabbitMQ
,我想知道如何将它处理的数据返回给客户端(网站用户)。换句话说,它会是这样的: 1-生产者(rest)接收
请求
并将消息发
浏览 1
提问于2019-05-07
得票数 0
回答已采纳
1
回答
在
RabbitMQ
中定义确认/确认的时间范围
、
、
在多个
消费者
的情况下,是否可以设置
消费者
应该确认
rabbitmq
服务器的时间,否则该消息应该被认为是未被
RabbitMQ
服务器确认的,并且应该被给予
另一个
消费者
?
浏览 0
提问于2013-12-14
得票数 0
1
回答
我可以在AMQP中多次使用同一个关联ID吗?
、
假设我有一个队列,其中有多个
消费者
在监听。我将一个
请求
放到队列中,其中一个
消费者
将处理它,并将应答发送给我。 现在,假设我不耐烦了,如果过了一段时间还没有得到响应,我就会发出
另一个
请求
。附注:我使用的是带有
rabbitmq
-java-client 2.2的
RabbitMQ
2.4
浏览 0
提问于2011-04-05
得票数 1
回答已采纳
2
回答
如何让
RabbitMQ
重新发送未确认的消息?
我这样启动
RabbitMQ
服务器:docker run -d --hostname my-rabbit-host --name my-rabbit -p 5672:5672
rabbitmq
:3使用此代码我们可以确保,即使您在处理消息时使用CTRL+C杀死一个工作人员,也不会有任何损失。我产生了两个
消费者
,当我对其中一个
消费者
执行CTRL+C操作时,
另一个
正在运行的
消费者
不会收到最初发往前一个
消费者</
浏览 173
提问于2017-10-10
得票数 0
1
回答
有
请求
的BasicReject实际上到哪里去了?
如果在
RabbitMQ
3.6.1中有一个如下所示的队列:我使用信息1,然后做: channel.BasicReject(ea.DeliveryTag,
浏览 2
提问于2016-06-08
得票数 12
回答已采纳
3
回答
一个队列可以订阅(监听)
到
rabbit中的
另一个
队列吗
、
、
我们有两个
rabbitmq
经纪人。我们发布
到
Broker1的队列A,Broker2的队列B可以直接订阅
到
队列A,这样就没有延迟了,比如为它编写处理程序(使用@rabbitListener),然后发布
到
另一个
队列。我的问题是,Broker2是否可以使用任何rabit处理程序直接订阅broker1,或者broker2(
另一个
队列)是否可以直接使用broker1中的队列数据?有可能吗?注意:两个不同的
RabbitMq
服务器中的两个
rabbitmq
代理
浏览 2
提问于2019-06-07
得票数 0
1
回答
等待消息生产者收到
消费者
已完成工作的确认
、
、
使用Ruby的“兔子”
RabbitMQ
客户端,我希望我的生产者(一些Ruby代码)向
消费者
(使用“运动鞋”宝石的工人)发送一条消息,并且我希望我的生产者在收到
消费者
接收到我的消息并对其做了一些处理的确认之前在我的
消费者
中,我正在做一些工作,然后调用运动鞋的ack!方法来确认消息已收到,工作已完成。但是,我的生产者似乎并没有等待
消费者
调用ack!。我同时登录了我的生产者和
消费者
,并发现我的生产者似乎认为消息在
消费者
实际确认之前就已经被确认了。如何让
RabbitMQ
浏览 4
提问于2017-09-19
得票数 0
1
回答
将多个
rabbitMQ
相互连接
我一直在搜索,但我找不到是否可以将两个
rabbitmq
实例连接在一起。我认为这是
RabbitMQ
集群特性的一个替代方案。生产者-> Broker <-> Broker ->
消费者
浏览 3
提问于2021-07-06
得票数 0
2
回答
Python Kombu -阻塞
、
、
、
、
通过生产者/
消费者
模型,我使用kombu来管理
RabbitMQ
。我启动了我的生产者,它将100个作业放在一个队列中(我只有一个队列,一个交换)。我想推出多个
消费者
,同时,并让每个
消费者
过程一次一个工作。不幸的是,
消费者
之间相互阻碍(即,当一个
消费者
从队列中抢夺一份工作时,
另一个
消费者
只是坐在那里闲着)。如果我杀死了工作中的
消费者
,那么其他
消费者
中的一个就会开始工作。是否有一种方法可以让所有的使用者同时运行,
浏览 3
提问于2014-05-30
得票数 1
回答已采纳
1
回答
RabbitMQ
中的聚合器模式
、
是否可以在中实现
RabbitMQ
?因此,我想我将有某种唯一的ID,它确保消息被路由为独占的
到
相同的
消费者
,然后等待所有的消息到达。这在
RabbitMQ
中是可能的吗?
浏览 2
提问于2017-07-06
得票数 8
1
回答
RabbitMQ
请求
到
另一个
消费者
、
、
、
、
在出现消息
请求
情况下,是否可以强制
另一个
使用者进行
请求
?例如,我的服务想要处理来自队列(其中有多个使用者)的
请求
,但在处理过程中发现它的本地空间很小。在此使用者上重试处理没有任何意义,但
另一个
使用者仍然可以处理该消息。
浏览 15
提问于2019-07-03
得票数 1
回答已采纳
1
回答
为什么我在
请求
时从
RabbitMQ
获得相同的消息?
、
背景 场景实际:传递的下一条消息是foo为什么我的
消费者
会收到它只是
请求
的信息而不是下一个呢?我如何才能得到上述结果? 我希望
请求
的消息在队列的尾部。
浏览 0
提问于2016-03-24
得票数 2
回答已采纳
2
回答
PHP继续执行脚本,但将客户端重定向
到
其他地方
、
结合使用 ignore_user_abort(true); set_time_limit(0); 是否可以将客户端发送到
另一个
页面,因为服务器已经在处理数据。由于用户可以简单地在点击提交后关闭浏览器,而不是等待页面,我想将他们发送到
另一个
页面,然后在脚本完成后给他们发送一封电子邮件。提交到表单中的视频将在失败时发送到我们的视频服务器,成功后会发送电子邮件,请转到下一步 现在,用户已作为联系人添加到我们的CRM中,如果失败,系统会在成功后发送电子邮件,然后移动到下一步 现在,用户数据全部输入
到
数据库中,失败后发送电子邮件,成功发送电子邮件,并
浏览 13
提问于2019-03-13
得票数 1
回答已采纳
2
回答
MassTransit使用者为已注册使用者抛出“未找到消息类型{ type }的约定”异常
、
、
、
我有一个在HTTP端点接受
请求
的简单服务。端点的操作使用MassTransit发布事件,提醒使用者某个实体已更新。然后,已发布事件的使用者向同步使用者发送同步
请求
,以完成工作单元。这似乎意味着我的
消费者
没有注册,但我相信它是注册的。= Configuration.GetSection("
RabbitMq
"); var url =
rabbitMq
.GetValue<string>("Url");var username = <em
浏览 1
提问于2020-07-06
得票数 4
1
回答
Masstransit+
RabbitMQ
.在两种不同的消息类型之间共享一个队列
、
、
、
我有一个发布者,它将消息发布
到
rabbitmq
://localhost/test123队列中。一个消息具有TestMessage类型,
另一个
TestMessage2类型。Publisher配置: sbc.UseRabbitMq(r => r.ConfigureHost(new MessageUrn("
rabbitmq
://localhost/test123"), c://localhost/test123&
浏览 9
提问于2017-07-07
得票数 0
回答已采纳
1
回答
在mule esb中为amqp配置多个使用者
、
、
、
、
我使用以下配置为mule中的
rabbitMQ
创建了一个连接器,但问题是只创建了一个
消费者
,我想知道是否可以将mule配置为一次创建多个
消费者
。<amqp:connector name="amqpfiledetailConnector" username="${
ra
浏览 2
提问于2015-12-02
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RabbitMQ几种工作模式,实现延时消息的两种案例
消息队列RabbitMQ原理及其Python客户端pika的使用
Python操作rabbitMQ
RabbitMQ的运用
RabbitMQ实战:可用性分析和实现
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券