Spring AMQP：检查RabbitMQ配置

Question

我正试图根据这里提到的博客演示RabbitMQ信用流机制的用法：https://www.rabbitmq.com/blog/2015/10/06/new-credit-flow-settings-on-rabbitmq-3-5-5/

作为演示的一部分，我想展示如果消费者无法处理消息，RabbitMQ将阻止发布者进一步发布消息。

在消费者方面，我将消息持久保存在数据库中。我已将RabbitMQ确认模式设置为手动。消费者端的代码在消息成功地持久化到数据库中后显式地确认。

作为演示的一部分，我将rabbitmq.config文件中的credit_flow_default_credit参数设置为2。

相应地，我的拉比狗。配置文件如下所示：

[
   {rabbit,[
        {loopback_users, []},
        {credit_flow_default_credit, {2,1}} 
     ]
   }     
].

根据我的理解，如果RabbitMQ不能处理2条消息，那么发布者发布的第三条消息必须被阻止。

为了实现我想要的，我将表锁定在数据库中，这样消费者就无法持久保存记录。因此，它也将无法确认。

然而，我看不出发布者在发布消息时有任何问题，即使它已经发布了2条消息。为什么RabbitMQ不能阻止消息的进一步发布？

有没有办法让我检查一下兔子。从Spring AMQP进行配置？我想确保credit\u flow\u default\u credit确实设置为2。

Answer 1

不，它是一个代理属性；java客户端只能做AMQP协议支持的事情。

我建议你在RabbitMQ工程师活跃的RabbitMQ用户谷歌小组上问一些关于RabbitMQ内部的问题（比如为什么你没有看到你期望的行为）。

他们确实不时地在这里寻找，但是你可能会在这里得到更快的反应。

但是，您应该继续在这里询问特定于Spring AMQP的事情。