我试图在同一个程序中发布和订阅同一队列，但没有消耗任何东西，我是不是遗漏了什么？代码： using System;using RabbitMQ.Client.Events;
namespace
浏览 26提问于2020-06-02得票数 1
回答已采纳
我有一个RabbitMQ消息队列，我希望从web服务调用ServiceA向队列发布多条消息。同时，还有一个名为ServiceB的web服务，用于在10秒的时间间隔内使用来自RabbitMQ相同队列的消息。对于RabbitMQ队列的实现，这种用例可能吗？RabbitMQ是否支持发布者和使用者同时(同时)访问相同的队列？
浏览 2提问于2020-01-03得票数 2
回答已采纳
我们正在构建一个系统，用于映射publishers -> rabbitMQ (交换、队列等)和消费者之间的关系。我们可以直接从RabbitMQ HTTP API获得交换、队列和消费者，但我们正在尝试找到一种方法来确定谁在发布，以及发布到什么交换。我能得到的最接近的方法似乎是使用“通道”来映射哪些is连接到vhosts，但我找不到一种方法来从API获得发布者和交易所之间的直接关系。就我所知，这根
浏览 0提问于2020-12-01得票数 0
我正在使用Masstransit和RabbitMq在两个web应用程序.net核心之间进行通信。在发布者应用程序中，我向交换“生产者”发布了一条消息。rabbitConfigurator.Message<TMessage>(x => x.SetEntityName("producer")); 在同一个应用程序中，我有一个上述消息的</e
浏览 27提问于2021-01-12得票数 1
回答已采纳
我对RabbitMQ非常陌生。exchange_type => 'topic'auto_delete => 0使用此参数发布消息：消
浏览 0提问于2011-05-27得票数 72
回答已采纳
我有一个发布者，它将消息发布到rabbitmq://localhost/test123队列中。一个消息具有TestMessage类型，另一个TestMessage2类型。=> { })); sbc.UseJsonSerializer(); sbc.ReceiveFrom(new MessageUrn("rabbitmq
浏览 9提问于2017-07-07得票数 0
回答已采纳
根据这里提到的博客：，我正在尝试演示RabbitMQ信用流机制的用法
作为演示的一部分，我希望展示如果消费者无法处理消息，RabbitMQ将阻止发布者进一步发布消息。在消费者端，我将消息持久化到数据库中。我已将RabbitMQ确认模式设置为手动。消费者端的代码在消息成功持久化到数据库后显式确认
浏览 1提问于2019-01-09得票数 0
上下文：
当返回该basic.ack时，RabbitMQ</
浏览 1提问于2016-09-17得票数 1
回答已采纳
1回答
我需要知道来自.NET客户端的RabbitMQ中的全部消息。我知道最好的解决方案是使用API HTTP，但我无法正常工作。private void message(string text) var factory = new ConnectionFact
浏览 1提问于2015-02-23得票数 1
2回答
我是RabbitMQ的新手。我希望有其他服务的“集成事件”。因此，一种为所有微服务提供消息的路由。 /T5109.2-1988商业商品、商品、商业、金融、商业、金融、金融、商业、金融、商业、金融、金融、商业、金融等行业的产品、商品、商品
服务A>推送消息>>>服务B(不应接收消息，将被
浏览 6提问于2019-10-31得票数 1
我们有两个rabbitmq经纪人。我们发布到Broker1的队列A，Broker2的队列B可以直接订阅到队列A，这样就没有延迟了，比如为它编写处理程序(使用@rabbitListener)，然后发布到另一个队列。我的问题是，Broker2是否可以使用任何rabit处理程序直接订阅broker1，或者broker2(另一个队列)是否可以直接使用broker1中的队列数据？有可能吗？注意:两个不同的<e
浏览 2提问于2019-06-07得票数 0
1回答
我们使用RabbitMQ在C# .Net (EasyNetQ Client)中排队消息。using (var advancedBus = RabbitHutch.CreateBus("host=localhost;prefetchcount=100"
浏览 1提问于2015-07-14得票数 3
回答已采纳
我有一个发布者以比消费者可以消费的速度稍大的速度推送到队列中。对于较小的数字，这是可以的，但对于非常大量的消息，RabbitMQ会开始将其写入磁盘。在某个时间点，磁盘会变满，并触发流量控制。我应该如何设计我的应用程序，使流控制永远不会被触发？我在三个具有13GRAM和10G系统磁盘空间的节点上使用RabbitMQ</em
浏览 3提问于2015-03-17得票数 0
我已经创建了项目，其中只包含rabbitmq的路由设置。 <from uri="rabbitmq:localhost/test_out_ex?web界面中查找)。为什么？因为"to“还没有消费者吗？问题是消息没有保存在输出消息队列中。这是正常情况，当应用程序向队列发送消息时，此时还没有让消费者
浏览 4提问于2014-03-17得票数 0
我有一个要求，我必须听相同的交换，相同的队列，但不同的路线。 System.out.println("New message received" + message);}
这里的问题是，消息没有一致地到达正确的方法，例如: key1消息将传递给key2，反之亦然。如果有人需要额外的</e
浏览 2提问于2017-02-07得票数 3
回答已采纳
1回答
但是，如果我随后向同一个分区发送另一条消息，使使用者不抛出异常，则会更新使用者偏移量，而我们抛出异常的原始消息在重新启动后不会再重新尝试。
这是我还没找到的地方吗？处理绑定程序的错误是特定的，还是s s抽象在各个绑定程序之间是一致的？我怀疑这是消费者补偿如何用卡夫卡活页夹更新的意外后果。我看到一个enableDlq卡夫卡消费者的财产被增加了，我准
浏览 0提问于2016-05-17得票数 4
回答已采纳
1回答
基于多实例的微服务事件驱动设计
、、、、
目前，我们设计并计划将我们的系统转换为一个微服务体系结构模式。可以使用数据存储中的锁和处理状态来处理这一问题。但是这个解决方案看起来非常昂贵，每个实例都有相同的工作。对我来说这不是一个负载平衡。
对于这种模式有什么好的解决方案
浏览 6提问于2015-04-21得票数 6
回答已采纳
我对RabbitMQ非常陌生，所以这可能是我所缺少的东西。我的“问题”是，我的应用程序将使用发布/订阅和交换通过RabbitMQ发送“事件”。但是，这些事件可能有消费者，也可能没有消费者，但一旦有了消费者，我希望该消费者获得在连接之前发生的任何事件/消息。因此，基本上我希望交换“缓冲”所有消息，一旦有一个队列绑定到交换(由<e
浏览 16提问于2021-06-30得票数 0
回答已采纳
我有一个ASP.NET核心应用程序，我想在其中使用RabbitMQ消息。如何从web应用程序中以正确的方式初始化消费者？
浏览 4提问于2017-04-25得票数 27
回答已采纳
我一直试图使用RabbitMQ perl库Net::RabbitFoot，它在底层使用AnyEvent::RabbitMQ。根据，将prefetch_count设置为1应该确保公平的调度，因为不应该向已经忙于处理另一条消息的工作人员发送消息。但是，perl实现，即使在设置了第54行所描述的服务质量之后，似乎也不能这样工作。它似乎只是做普通的循环调度，并最终分派到已经在执行任务的机器上。这是实现。你能帮我弄清楚
浏览 3提问于2014-04-02得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
