消费RabbitMQ时的注意事项，如何禁止大量的消息涌到Consumer，保证线程安全

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

>>阅读原文<<