问题标签 [easynetq]

有什么方法可以使用 EasyNetQ 同步消费来自 RabbitMQ 的原始字节消息？

我需要保证对来自未以 EasyNetQ 格式发布的系统的消息进行有序处理和确认。我知道消费者在单个线程上运行，但该IAdvancedBus接口仅提供一种使用原始消息的方法：

Task返回类型意味着消费者正在异步运行回调，因此可能会乱序处理消息。

如果没有，有什么想法可以更改代码以支持这一点吗？我会制作接口方法：

并在 中实现它RabbitAdvancedBus，但我不确定代码的确切位置。

谁能指导我使用适用于 Unity 5.x (.Net 3.5) 项目的正确版本的 EasyNetQ？

我有一个针对 .Net 框架 3.5（Unity 3.5 .net 子集基类库）的统一 5.x 项目。

我的项目需要使用 RabbitMQ 系统。

但是当我尝试通过 NuGet 包管理器将 EasyNetQ（一个使用 RabbitMQ.client 库与 RabbitMQ 服务器通信的客户端库）引用到项目时，我收到一个错误，它与目标 3.5 .Net 平台不兼容.

我尝试添加不同版本的 EasyNetQ，但没有成功。我认为最新版本的构建不适用于 .Net 3.5 框架。

RabbitMQ（从 ac# 客户端调用）是否能够在队列上分发工作并允许发布者接收该工作已成功处理的确认？

似乎不添加额外队列应该是可能的，但除非我错过了一些确认/确认，否则不要告诉原始发布者消息已成功处理。所以它无法知道它的所有工作是否都得到了处理。

我目前正在使用标准的rabbit c# 客户端，但我知道easynetq 也非常成熟，因此我们将不胜感激提供一种实现此目标的好方法的建议。

我有一个应用程序，一个 asp.net mvc 4 应用程序。我想将rabbitmq 与easynetq 一起使用。在我的本地计算机上，它运行良好。但是在windows server 2012的生产环境中，它不会发送任何消息。

我不明白，为什么它不起作用。在日志消息中，没有什么异常。IIS 和 rabbitmq 在同一台机器上。

提前致谢

使用AdvancedBusforEasyNetQ时，如果连接因任何原因中断，我该如何重新连接？它会尝试自行重新连接吗？

我知道自己IBus重新连接，但AdvancedBus似乎没有这样做。例如，如果我使用 Web 管理控制台手动强制关闭连接，则连接将永远消失。如果我IAdvancedBus再次重新创建，我会看到两个新的连接。

我正在创建一个应用程序来测试不同 RabbitMQ 客户端之间的性能。
其中之一应该是 SQL Server。
我发现存在用于 SQL Server Integration Services (SSIS) 的 RabbitMQ 组件。
但似乎尚未编写可以将消息发送到交换的目标组件。
任何想法如何执行？
是否应该与向 MSMQ 发布消息类似？

我将我的 RabbitMQ 连接字符串存储在数据库中，以便我可以即时更改它，但考虑到 EasyNetQ 服务被设计为在应用程序引导期间设置和 IoC 注册为单例，似乎几乎不可能动态切换连接。我理想的解决方案是将 IBus 生命周期注册为基于自定义时间的生命周期（每 n 分钟重新构建一次），但到目前为止还没有运气。

如果我使用确认（model.ConfirmSelect）AKA basic.ack 和强制标志发布。如果消息未传递，我是否总是在 basic.ack 事件之前获得 basic.return 事件。

我想将所有 basic.return 消息添加到 ConcurrentDictionary 并在发布后检查消息是否在字典中我会抛出异常，即不存在队列/路由，并在错误或成功时将其删除。

在 Xamarin Studio (Mac OS X) F# 交互窗口中运行此 F# 脚本时出现错误：

错误：

但它在 Visual Studio 2015 (Windows) 中运行良好。我已经安装并正确引用了软件包，ServiceBusHost 在 VS 2015 (Windows) 中也可以正常工作。

目标框架：Mono / .NET 4.5 编译器配置：调试/任何 CPU 操作系统：Mac OS X

有任何想法吗？

如何使用easynetq驱动在rabbit mq中实现工作队列？

还需要发布者和订阅者的确认。

这个想法是一条消息将仅由单个订阅者处理。这是默认行为还是消息从发布者散播到订阅者？