消费RabbitMQ时的注意事项，如何禁止大量的消息涌到Consumer

约定不等于承诺〃 2022-05-27 02:54 213阅读 0赞

转载于：https://www.cnblogs.com/atwind/p/5606120.html

2016-06-22 10:09 by 咒语, 14185 阅读, 1 评论, [收藏][Link 1], [编辑][Link 2]

按照官网提供的订阅型写法（ [Retrieving Messages By Subscription ("push API")][Retrieving Messages By Subscription _push API]） 我发现，RabbitMQ服务器会在短时间内发送大量的消息给Consumer，然后，如果你没有来得及Ack的话，那么服务端会积压大量的UnAcked消息，而Consumer如果来不急处理也会处于假死（也可能引起程序崩溃）。

![18288-20160622095819985-699437237.png][]

仅有两个Channel，结果积压了大量的UnAcked消息。

这明显是与我们的目的不一致，我们不能保证Consumer一 定会急时快速的处理消息。所以这种方式带来的后果就是Consmer崩溃后，UnAcked消息又ReQueue，这肯定会消耗MQ的宝贵资源。

我试图在官网上找到一种方法，让每条消息明确的Ack后再接受下一条。但是好没有。好在在[ gitbooks.io/rabbitmq-quick/][gitbooks.io_rabbitmq-quick] 这儿找到了，通过设置Channel的QOS即可

<table style="border:1px solid #C0C0C0;width:844px;background:none;float:none;height:auto;line-height:1.1em;margin:0px;padding:0px;vertical-align:baseline;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:12px;min-height:auto;"> 
 <tbody style="background:none;float:none;height:auto;line-height:1.1em;margin:0px;padding:0px;vertical-align:baseline;width:auto;min-height:auto;"> 
  <tr style="background:none;border-top:0px;float:none;height:auto;line-height:1.1em;margin:0px;padding:0px;vertical-align:baseline;width:auto;min-height:auto;"> 
   <td style="border-color:#C0C0C0;padding:3px;border-collapse:collapse;background:none;float:none;height:auto;line-height:1.1em;margin:0px;vertical-align:baseline;width:35px;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:12px;min-height:auto;color:rgb(175,175,175);"> 
    <div style="background:rgb(244,244,244) none;border-width:0px 2px 0px 0px;border-right-style:solid;border-right-color:rgb(108,226,108);float:none;height:auto;line-height:1.8em;margin:0px;padding:0px .5em;text-align:right;vertical-align:baseline;width:auto;min-height:auto;white-space:nowrap;">
      1 
    </div> 
    <div style="background-image:none;border-width:0px 2px 0px 0px;border-right-style:solid;border-right-color:rgb(108,226,108);float:none;height:auto;line-height:1.8em;margin:0px;padding:0px .5em;text-align:right;vertical-align:baseline;width:auto;min-height:auto;white-space:nowrap;">
      2 
    </div></td> 
   <td style="border-color:#C0C0C0;padding:3px;border-collapse:collapse;background:none;float:none;height:auto;line-height:1.1em;margin:0px;vertical-align:baseline;width:auto;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:12px;min-height:auto;"> 
    <div style="background:none;border:0px;float:none;height:auto;line-height:1.1em;margin:0px;padding:0px;vertical-align:baseline;width:auto;min-height:auto;"> 
     <div style="background:rgb(244,244,244) none;border:0px;float:none;height:auto;line-height:1.8em;margin:0px;padding:0px 1em;vertical-align:baseline;width:auto;min-height:auto;white-space:nowrap;"> 
      <code style="background:none;border:0px;float:none;height:auto;line-height:1.8em;margin:0px;padding:0px;vertical-align:baseline;width:auto;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;min-height:auto;white-space:nowrap;color:rgb(0,0,255);">var</code>&nbsp; 
      <code style="background:none;border:0px;float:none;height:auto;line-height:1.8em;margin:0px;padding:0px;vertical-align:baseline;width:auto;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;min-height:auto;white-space:nowrap;color:rgb(0,0,0);">channel = Connect.CreateModel();</code> 
     </div> 
     <div style="background-image:none;border:0px;float:none;height:auto;line-height:1.8em;margin:0px;padding:0px 1em;vertical-align:baseline;width:auto;min-height:auto;white-space:nowrap;"> 
      <code style="background:none;border:0px;float:none;height:auto;line-height:1.8em;margin:0px;padding:0px;vertical-align:baseline;width:auto;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;min-height:auto;white-space:nowrap;color:rgb(0,0,0);">channel.BasicQos(0,1,</code> 
      <code style="background:none;border:0px;float:none;height:auto;line-height:1.8em;margin:0px;padding:0px;vertical-align:baseline;width:auto;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;min-height:auto;white-space:nowrap;color:rgb(0,0,255);">false</code> 
      <code style="background:none;border:0px;float:none;height:auto;line-height:1.8em;margin:0px;padding:0px;vertical-align:baseline;width:auto;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;min-height:auto;white-space:nowrap;color:rgb(0,0,0);">);&nbsp;</code> 
      <code style="background:none;border:0px;float:none;height:auto;line-height:1.8em;margin:0px;padding:0px;vertical-align:baseline;width:auto;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;min-height:auto;white-space:nowrap;color:rgb(0,130,0);">//RabbitMQ客户端接受消息最大数量</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

设置后的结果：

![18288-20160622100531719-1401548681.png][]

在开启4个Consumer的情况下，每条消息处理要耗时2秒。然后问题解决了。Unacked的消息只有4个。

[Link 1]: https://www.cnblogs.com/atwind/p/5606120.html#
[Link 2]: https://i.cnblogs.com/EditPosts.aspx?postid=5606120
[Retrieving Messages By Subscription _push API]: http://www.rabbitmq.com/dotnet-api-guide.html
[18288-20160622095819985-699437237.png]: /images/20220527/bc0e0550015d4272ba83f4bd9155b2e8.png
[gitbooks.io_rabbitmq-quick]: https://geewu.gitbooks.io/rabbitmq-quick/content/RabbitMQ%E5%8E%9F%E7%90%86%E5%88%86%E6%9E%90.html
[18288-20160622100531719-1401548681.png]: /images/20220527/1aada3dfbcae4e8d9ea699e6b4d7812b.png