如何使用 EasyNetQ/RabbitMQ 进行错误处理
我在 C# 中使用带有 EasyNetQ 库的 RabbitMQ.我在这里使用 pub/sub 模式.我还有一些问题希望有人能帮助我解决: 当使用消息时出现错误，它会自动移到错误队列中.如何实现重试(以便将其放回原始队列，并且当它无法处理 X 次时，它会被移至死信队列)? 据我所知，总是有 1 个错误队列用于转储来自所有其他队列的消息.如何为每种类型设置 1 个错误队列，以便每个队列都有自
..
easynetq相关内容
EasyNetQ 无法发布到 RabbitMQ - PersistentChannel 超时
我正在尝试使用 EasyNetQ 连接到 RabbitMQ.RabbitMQ 在远程虚拟机上. _rabbitBus = RabbitHutch.CreateBus(string.Format("host={0};virtualhost={1}",_hostSettings.Host, _hostSettings.VHost),x =>x.Register(l
..
使用 EasyNetQ for RabbitMQ 时自定义错误队列名称?
与其让我未处理的异常进入 EasyNetQ_Default_Error_Queue，我想知道是否有一种方法可以明确说明应该用于给定应用程序的错误队列的名称，因此错误不会t 全部都在这个EasyNetQ_Default_Error_Queue? 我可以看到如何指定常规消息队列名称，但没有找到有关错误队列名称的任何信息. 解决方案 是的，您可以通过覆盖 IConventions 对象上的
..
无法通过 EasyNetQ 连接 RabbitMQ，拒绝用户访客访问
收到一个对我来说没有意义的奇怪错误. RabbitMQ 拒绝允许从在特定机器上使用 EasyNetQ 的 .Net 应用程序访问，但它在另一台机器上运行良好. 客户端应用清楚地解析了 DNS，权限是完全开放的，并且可以在另一种情况下使用. 这是一个开箱即用的rabbitmq安装. RabbitMQ 在 Linux Amazon 实例上运行，而客户端在 Windows Ser
..
无效字母更改类型后，如何反序列化无效字母消息?
我正在尝试编写一个死信处理程序服务，该服务从死信队列中读取消息，然后根据类型，内容等对消息进行某些处理. 在我的C#应用程序中，我正在使用EasyNetQ.我有一个称为MyMessage的基本消息类型，然后有许多子类型. EasyNetQ序列化消息，将消息发送到交换机，从队列中拉出然后将消息反序列化回原始类型都没有问题. 但是，如果我在死信处理程序中将AdvancedBus设置为使
..
如果要保留EasyNetQ的消息顺序，是否避免使用异步方法?
我已经在EasynetQ的文档中看到了这一点" EasyNetQ为每个IBus实例实现单个使用者线程，因此，如果您使用标准的非异步订阅方法，则消息处理程序将以与RabbitMQ传递消息的顺序同步触发.不需要实现锁.如果您使用异步订阅，则处理程序仍将按顺序调用，但是当然，根据您实现异步处理程序的方式，它们可能会按顺序ACK. 现在，这是否意味着如果要保留消息顺序，我应该避免在订户中使用异
..
EasyNetQ模型关闭
我使用EasyNetQ实现了RabbitMQ的简单客户端.建立连接后，我收到通知“队列的模型关闭" .这是我的代码: var _bus = RabbitHutch.CreateBus(String.Format("host={0}", hostName)).Advanced; var _exchange = Exchange.DeclareFanout(exName); var _queue
..
SignalR集线器在ASP.NET Core中的RabbitMQ订阅处理程序中解析为null
我有一个使用RabbitMQ(通过EasyNetQ)和SignalR的ASP.NET Core MVC项目. 接下来，我对RabbitMQ消息进行了订阅，该消息应通过SignalR向客户端发送通知. 但是可悲的是，集线器始终解析为. 一个有趣的发现是，当应用程序仍在启动并且队列中仍然存在未确认的消息时，该服务实际上可以很好地解决. public void Configure
..
RabbitMQ，带有NodeJS的EasyNetQ(amqplib)-订阅
我已经问过有关从amqplib-> EasyNetQ发布的问题，并在EasyNetQ的作者的帮助下进行了工作. 现在，我在尝试其他方法时遇到了麻烦. 它确实做了短暂的“工作"，但是后来我回去清理了我创建的所有队列，现在-它不起作用(从amqplib到ENQ的发布仍然有效，但是从ENq到amqplib的发布却不起作用). 如果我有此代码: Bus.SubscribeAsync
..
EasyNetQ-如何重试失败的消息在邮件正文/标题中保留RetryCount吗?
我正在使用EasyNetQ，需要重试原始队列中的失败消息.问题是:即使我成功地增加了TriedCount变量(在每个msg的正文中)，当EasyNetQ在异常发生后将消息发布到默认错误队列时，更新的TriedCount也不在msg中！大概是因为它只是将原始消息转储到错误队列，而没有使用方的更改. 更新的TriedCount适用于进程内重新发布，但不适用于通过EasyNetQ Hosepipe
..
如何在EasyNetQ中为每个使用者声明自定义错误交换?
当错误发生时，我有四个使用者，将消息发布到默认的EasyNetQ_Default_Error_Queue，是否每个队列使用者都可以编写自己的错误交换信息 例如； Queue Name : A ErrorExchange :A_ErrorExchange Queue Name : B ErrorExchange :B_ErrorExchange bus.Advanced.
..
异常时重新排队消息
我正在寻找一种可靠的方式来重新排列无法正确处理的消息-目前. 我一直在查看else //reject the message but push back to queue for later re-try { Console.WriteLine("Rejecting message and putting it back to the queue: {0}", message); model
..
EasyNetQ无法发布到RabbitMQ-PersistentChannel超时
我正在尝试使用EasyNetQ连接到RabbitMQ. RabbitMQ在远程VM上. _rabbitBus = RabbitHutch.CreateBus( string.Format("host={0};virtualhost={1}", _hostSettings.Host, _hostSettings.VHost), x => x.Register
..
怎么办误差EasyNetQ / RabbitMQ的处理
我使用C＃中的RabbitMQ与EasyNetQ库。我在这里使用的是发布/订阅模式。我仍然有，我希望有人能帮助我有几个问题： 当同时使用消息有一个错误，它会自动移到错误队列。我如何能实现重试（因此它被放回原始队列，当它无法处理X倍，它的移动到一个死信队列）？ 至于我可以看到有总是的用于从所有其他队列将消息1错误队列。怎样才可以有每类错误队列，使每个队列都有自己相关的错误队列？ 如何轻松地
..
有没有办法使用EasyNetQ.Hosepipe时指定一个不同的错误队列？
我最近公布了以下问题... ...并提供了一些关于如何使用EasyNetQ的时候，而不是让所有未处理的异常进入默认的错误队列（EasyNetQ_Default_Error_Queue）使用不同的，特定的应用程序错误队列名称的解决方案。 什么我现在想的是能够执行以下操作时使用EasyNetQ.Hosepipe.exe转储所有从哪个错误队列我指定了错误信息，因为它的默认行为，按照文档...
..
使用EasyNetQ的RabbitMQ的时候自定义错误队列名称？
而不是让我未处理的异常进入 EasyNetQ_Default_Error_Queue 我在想，如果有，我可以明确地指出应该用于特定应用的错误队列名称的方式，这样的错误不要“ •全部结束了在这其中的 EasyNetQ_Default_Error_Queue 我可以看到如何指定正常的消息队列的名字，但没有设法找到错误队列名什么。 解决方案 是的，你可以通过覆盖在IConventions代表自定义
..