RabbitMQ如何向消费者发送消息？

TLDR:您从RabbitMQ轮询消息,直到超过预取计数为止,在这种情况下,您将阻止并仅接收心跳帧,直到获取消息为止.因此,您可以进行轮询,但如果非确认消息的数量小于预取计数,则只会获得新消息.新消息放在QueueingConsumer上,理论上你应该永远不会比QueueingConsumer内部队列中的预取计数多得多.

详细信息: 低级明智(我可能会遇到一些错误)RabbitMQ本身并没有真正推送消息.客户端必须根据AMQP协议不断读取帧的连接.很难将其归类为推或拉,但只知道客户端必须不断读取连接,因为Java客户端很遗憾BIO它是一个阻塞/轮询操作.阻塞/轮询基于AMQP心跳帧和常规帧和套接字超时配置.

在Java RabbitMQ客户端中发生的事情是每个通道(或者可能是它的连接)都有线程,并且该线程从RabbitMQ循环收集帧,最终成为放入阻塞队列的命令(我相信它像SynchronousQueue也称为切换队列但兔子有自己特别的一个).

QueueingConsumer是一个更高级别的API,它将从早期提到的切换队列中拉出命令,因为如果命令留在切换队列上,它将阻止通道帧收集循环.这可能是错误的,因为连接超时.此外,QueueingConsumer允许在单独的线程上完成工作,而不是与前面提到的循环帧线程在同一个线程中.

现在,如果您查看大多数Consumer实现,您可能会注意到它们几乎总是无限制的阻塞队列.我不完全确定为什么这些队列的边界不能成为预取的乘数,但如果它们小于预取,它肯定会导致连接超时问题.