如何利用.NET RabbitMQ客户端为消费者利用预取计数

作者: 甲基蓝
发布时间: 2024-04-25 10:22:42 (6天前)
转自：

3 条回复

0#
回复此人
無口君 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> 您引用的文档适用于Java客户端。你应该指的是 <a href="https://www.rabbitmq.com/dotnet-api-guide.html" rel="nofollow noreferrer"> 这个文件 </A> 代替。 您正在使用最新版本的.NET客户端（ <code> 5.1 </code> ），所以做你的工作 <code> Received </code> 事件处理程序不会阻止处理TCP数据的其他线程，也不会阻止心跳 - 两者都很好。 首先，打电话 <code> channel.BasicQos(0, 1, false) </code> 意味着您的消费者一次只能从RabbitMQ收到一条就绪消息，直到 <code> BasicAck </code> 被称为另一个消息将不会被传递。所以，没有理由在另一个线程中完成你的工作，因为你无论如何都不会得到另一个消息。 如果您增加预取值（通过实验和运行基准测试），如果您的工作运行时间超过几毫秒，则必须在后台线程中完成工作。 当你在工作时 <code> Received </code> 事件回调，它将阻止用于进行回调的线程，因为回调没有在自己的线程上执行。因此，您可以确保您的工作很短，或者在另一个线程中完成工作。 我只是花了一些时间来审查.NET客户端代码，我很确定 <code> IModel </code> 实例不是线程安全的。如果你增加预取，你将有机会同时确认几条消息，所以我建议实现一个使用它的解决方案，并确保 <code> BasicAck </code> 在创建连接的同一线程上调用。 <HR /> <子> 注意： RabbitMQ团队监控 <code> rabbitmq-users </code> <a href="https://groups.google.com/forum/#!forum/rabbitmq-users" rel="nofollow noreferrer"> 邮件列表 </A> 并且有时只回答StackOverflow上的问题。 </子> </DIV>

编辑
1#
回复此人
机器设备维修 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> 资源： <a href="https://www.rabbitmq.com/api-guide.html" rel="nofollow noreferrer"> https://www.rabbitmq.com/api-guide.html </A> <BLOCKQUOTE> 使用手动确认时，重要的是要考虑什么线程确认。如果它不同于收到交付的线程（例如Consumer＃handleDelivery 委托交付处理到另一个线程），承认多个参数设置为true是不安全的，将导致双重确认，因此是一个通道级协议关闭频道的例外。确认单个消息时间可以安全。 </BLOCKQUOTE> <code> channel.basicAck(tag, false) </code> 是线程安全的 但 <code> consumerChannel.basicAck(tag, true) </code> 不是。 还提到了一些好处 <a href="https://stackoverflow.com/questions/30695375/rabbitmq-and-channels-java-thread-safety"> RabbitMQ和渠道Java线程安全 </A> </DIV>

编辑

登录后才能参与评论