我使用的是.net核心2.1.0、Masstransit和Rabbitmq。 {
var host = sbc.Host(new Uri("rabbitmqservices.AddSingleton<IBusControl>(bus);
浏览 10提问于2018-09-05得票数 0
我有一个ASP.NET WebAPI，它必须与Twitter API交互，然后将这些tweet记录到RabbitMQ中，然后由RabbitMQ的另一个使用者拾取这些tweet。预计将有500到1000条推文从Tweeter中删除。
我计划采用的方法是通过内存中的读取来自Tweeter的所有1000条tweet，然后使用迭代，然后向RabbitMQ发送一条消
浏览 4提问于2017-03-13得票数 0
回答已采纳
TL;DR -通过REST向消费者公开RabbitMQ的最佳方法是什么？现在消费者的部分是我不知道如何进行。
一开始不会有排队。当一个新的使用者想订
浏览 4提问于2016-08-04得票数 0
1回答
在我的服务器端，我使用docker部署了RabbitMq消息中间件，它运行得很好。但是我把它和asp.net内核结合在一起，它不能成功地发送消息。包装： RabbitMQ采用消息响应机制，即用户收到消息后，需要发送响应，然后RabbitMQ将消息从队列中删除。如果使用者在消费过程中有异常，则断开连接并没有发送
浏览 4提问于2022-02-17得票数 0
回答已采纳
我最近学习了RabbitMQ，希望在我的工作流程中实现它。(我将用Java实现它)我刚刚完成了所有的教程，我很好奇如何实现一个“常量”队列，而不是一个“临时”队列。或者至少允许使用者获得交换发送的消息。例如，如果我发送一个主题为"kern.overflow“，但消费者离线，只要我的消费者在线，只要它在监听与"kern.#”或"#.overflow“相关的内容，我就希望它接收未收到
浏览 1提问于2014-05-21得票数 0
回答已采纳
我正在使用MT和RabbitMQ实现标准的请求/响应场景。客户端是Asp.net核心应用程序接口，消费者是windows服务。作为测试异常用例的一部分，如果我停止使用者并使用请求客户端提交来自API的请求，由于没有使用者处理，API得到请求超时异常，这很酷。但是消息位于消费者队列中，当我启动消费者时，它会挑选消息并处理这些东西(将消息发送</em
浏览 26提问于2021-03-05得票数 0
我期待着使用Websocket为我的web应用程序开发一个实时API。在最初的websocket连接建立之后，套接字对象等待来自客户端的新消息，在rabbitMQ的情况下，我们需要为它设置一个使用者，因此当它收到消息时，它将处理该消息。我们可以这样做，
客户端通过全双工websocket与服务器建立连接，所有客户端在最初的websocket握手之后都应充当RabbitMQ<
浏览 11提问于2011-07-21得票数 3
1回答
我一直在尝试创建一个.NET RabbitMQ消费者应用程序，有些问题我无法通过google找到答案，所以我想我应该在这里问他们：
在规范中，我发现IConnection.CreateModel返回的这是否只与调用IModel.BasicPublish方法有关(如果我理解正确，那么BasicPublish/BasicAck/BasickNack/ets不是线程安全的)还是也包括注册的使用者？将此参数设置为True是否意味着在通过IBasicConsume
浏览 1提问于2015-01-05得票数 2
回答已采纳
范围：1)有人创造了一个“话题”3)将发布到某一“主题”的任何消息推送到所述“主题”的订阅者手中。RabbitMQ:现在我已经通过RabbitMQ框架建模了问题，我需要那些被“推送
浏览 4提问于2014-02-27得票数 11
故事中定义的事件
的下游端点是否对文件进行了一些工作如果这就是why...should在CorrelationId以外的字段中传递correlationId的原
浏览 2提问于2016-08-26得票数 11
回答已采纳
1回答
我有一个发布者(使用RabbitMQ .NET客户端)和多个使用者(使用Python模块)。它们使用的是单一主题交换，并且使用者有单独的队列。我想要实现一个分布式RPC风格的调用，它要求我在继续或超时之前等待答复(JSON)。
当我发布我的消息时，我需要等待并得到来自“所有”收到我消息的客户的回复。(可能是发行者一方的单一消费者。)我用路由密钥发
浏览 0提问于2013-09-19得票数 1
回答已采纳
我是RabbitMQ新手，在阅读RabbitMQ文档时，我在下面找到了用于生产者的代码public class Send {
private final static String正如上面的问题描述所述，我必须从具有不同日期标记目录的服务器读取日志信息，所以是否只需要编写一个无限循环(因为日志不断更新)并递归读取所有目录和文件，然后为每一行文件编写一条消息，然后将其发布给接收方？在这种情况下，我们的通道将永远不会关闭，并且连接将始终打开，这是
浏览 0提问于2014-06-23得票数 1
回答已采纳
我是RabbitMQ的初学者，我从RabbitMQ的官方网站开始了我的冒险。现在，我已经得到了在层中使用broker的以下模式：
Backend Server(Business logic) -> (push message) -> RabbitMQ -> Customer(receiver关于这个逻辑，我有一个简单的问题:如果将这些物理组件放置在不同的服务器上，那么客户和RabbitMQ代理之间以
浏览 2提问于2017-10-06得票数 0
回答已采纳
我正在尝试向外扩展RabbitMQ消息传递系统。当前的系统非常简单-生产者向扇出交换发送消息，该消息由多个消费者处理-经典的扇出路由。我有来自不同类型的多个使用者(例如:一个打印到屏幕，一个记录到文件，一个保存到数据库，...)。我的挑战--我不确定扩展消费者的最佳方式是什么。如果我添加来自相同类型的其他使用者-我将在数据库中获
浏览 0提问于2017-01-16得票数 2
1回答
我使用MASSERSIT7.0.0与使用者一起处理来自RabbitMQ的消息。我已经观察到，当使用者处理消息的速度很慢时，或者当我将调试点放在visual studio中供使用者使用时，过了一段时间，我的使用者再次收到消息。我的假设是，Masstransit认为消费者崩溃了，并再次发送了信息。
在我的例子中，我
浏览 2提问于2020-08-25得票数 1
回答已采纳
2回答
在我的应用程序中，我使用RabbitMQ在客户机和服务器之间进行通信。我有大量的客户(大约10000)。那么，打开10000个队列，每个客户端一个队列可以吗？
浏览 4提问于2015-09-27得票数 3
回答已采纳
我们有三种不同类型的对象: 1. ObjectA 2. ObjectB
我们需要将这些对象信息发送到三个不同的API :1.api A-我们只需要发送ObjectA。2.API b-我们只需要发送ObjectB。3. API我们需要发送ObjectA和ObjectB。由于这些对象将以非常高的频率推送到我们的系统，并且需要异步处理，所以我们决定使用rabbitmq将
浏览 3提问于2017-04-27得票数 0
回答已采纳
2回答
我有三个码头集装箱：
使用者和生产者都能够连接到rabbitmq队列，但是从生产者发送的消息永远无法到达使用者。)，但不允许发送消息。从主机上，我必须使用http://0.0.0.0:55673连接到管理
浏览 3提问于2016-05-11得票数 0
1回答
有没有一个很好的例子(C#)来说明如何在RabbitMQ中直接回复？我想要做的是让X生产商发布一条信息(“我有一些工作给某人”)，我希望X的一个消费者拿起它，做这个工作，然后把回复发回。不是一个基本的Ack，而是一些数据的计算结果。当然，反应必须回到正确的生产者。Console.WriteLine(" Press [enter] to exit."); }
从最低限度<e
浏览 4提问于2016-06-28得票数 6
回答已采纳
我已经了解了RabbitMQ的基本原理。有一件事我发现发布者不会直接在队列上发布。exchange根据routing-key和exchange类型决定消息应该在哪个队列上发布(下面的代码使用默认交换)。我还找到了publisher的示例代码。例如，如果它使用的是扇出exchange，并且有100个具有不同名称的队列，那么使用者如何知道并声明100个队列？
浏览 5提问于2021-02-24得票数 0
回答已采纳
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
