rabbitmq中consumer从channel获取消息时，pre-fetch消息存放在哪里
When consumer gets message from channel in rabbitmq,where does pre-fetch messages reside
我对 rabbitmq 的配置如下
预取计数：1
确认模式：自动。
我有一个交换器，一个队列连接到该交换器，一个消费者连接到该队列。根据我的理解，如果队列有多个消息，将执行以下步骤。
- 在通道上排队写入数据。
- 由于 ack-mode 是自动的，一旦队列在通道上写入消息，消息就会从队列中删除。
- 消息到达消费者，消费者开始对该数据执行操作。
- 因为 Queue 已经得到对前一个 message.Queue 的确认，所以在 Channel 上写入下一个数据。
现在，我的疑问是，假设消费者没有完成之前的数据yet.What会发生下一个数据队列已经写入通道的情况吗？
此外，假设 prefetchCount 为 10，并且我只有一次消费者连接到队列，这 10 条消息将驻留在何处？
您所描述的场景是 RabbitMQ 文档中提到的场景，并在 this blog post 中进行了详细说明。具体来说，如果您设置了足够大的预取计数，并且发布速率相对较小，那么您的 RabbitMQ 服务器将变成一个奇特的网络交换机。当确认模式设置为自动时，预取限制实际上被禁用，因为永远不会有未确认的消息。使用自动确认，消息在传递后立即得到确认。这与具有任意大的预取计数相同。
如果预取 >1，消息将存储在客户端库的缓冲区中。确切的数据结构将取决于所使用的客户端库，但据我所知，所有实现都将消息存储在 RAM 中。此外，使用自动确认，您无法知道特定消费者何时实际阅读和处理消息。
所以，这里有一些要点：
- 预取限制与自动确认无关，因为从来没有任何未确认的消息，因此
- 使用消费者时自动确认没有多大意义
- 当 auto-ack 关闭或任何使用 autoack = on 时足够大的预取将导致消息代理不进行任何排队，而仅进行路由。
现在，这里有一些专家意见。我发现 "pushes" 向外发送消息的消息代理的整个概念有点落后，正因为如此 - 很难正确配置，而且不清楚有什么好处。队列系统非常适合基于拉取的系统。当处理完当前消息后，处理器可以向代理请求下一条消息。这种方法将确保负载自然平衡，并且当处理器断开连接或被淘汰时消息不会丢失。
因此，我的建议是完全放弃使用消费者，改用 basic.get。
我对 rabbitmq 的配置如下
预取计数：1 确认模式：自动。
我有一个交换器，一个队列连接到该交换器，一个消费者连接到该队列。根据我的理解，如果队列有多个消息，将执行以下步骤。
- 在通道上排队写入数据。
- 由于 ack-mode 是自动的，一旦队列在通道上写入消息，消息就会从队列中删除。
- 消息到达消费者，消费者开始对该数据执行操作。
- 因为 Queue 已经得到对前一个 message.Queue 的确认，所以在 Channel 上写入下一个数据。
现在，我的疑问是，假设消费者没有完成之前的数据yet.What会发生下一个数据队列已经写入通道的情况吗？
此外，假设 prefetchCount 为 10，并且我只有一次消费者连接到队列，这 10 条消息将驻留在何处？
您所描述的场景是 RabbitMQ 文档中提到的场景，并在 this blog post 中进行了详细说明。具体来说，如果您设置了足够大的预取计数，并且发布速率相对较小，那么您的 RabbitMQ 服务器将变成一个奇特的网络交换机。当确认模式设置为自动时，预取限制实际上被禁用，因为永远不会有未确认的消息。使用自动确认，消息在传递后立即得到确认。这与具有任意大的预取计数相同。
如果预取 >1，消息将存储在客户端库的缓冲区中。确切的数据结构将取决于所使用的客户端库，但据我所知，所有实现都将消息存储在 RAM 中。此外，使用自动确认，您无法知道特定消费者何时实际阅读和处理消息。
所以，这里有一些要点：
- 预取限制与自动确认无关，因为从来没有任何未确认的消息，因此
- 使用消费者时自动确认没有多大意义
- 当 auto-ack 关闭或任何使用 autoack = on 时足够大的预取将导致消息代理不进行任何排队，而仅进行路由。
现在，这里有一些专家意见。我发现 "pushes" 向外发送消息的消息代理的整个概念有点落后，正因为如此 - 很难正确配置，而且不清楚有什么好处。队列系统非常适合基于拉取的系统。当处理完当前消息后，处理器可以向代理请求下一条消息。这种方法将确保负载自然平衡，并且当处理器断开连接或被淘汰时消息不会丢失。
因此，我的建议是完全放弃使用消费者，改用 basic.get。