Spring RabbitMQ确认回调未按预期工作

Question

我试图测试spring rabbitmq confirm callback的行为，根据api描述，如果通过consumer发送了任何否定确认，则confirm callback应该给出ack的false值，但在我的例子中总是给出true。即使我将消息发布到deleted队列，我也在confirm回调中获得了true值。请告诉我如何得到否定的承认。

下面是我如何创建RabbitTemplate bean的代码。

@Bean
    public RabbitTemplate rabbitTemplate( ConnectionFactory connectionFactory ) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate( connectionFactory );
        ((CachingConnectionFactory)rabbitTemplate.getConnectionFactory()).setPublisherConfirms( true );
        rabbitTemplate.setConfirmCallback( new ConfirmCallback() {

            @Override
            public void confirm( CorrelationData corData, boolean ack, String cause ) {
                System.out.println( "devconfig.rabbitTemplate(...).new ConfirmCallback() {...}.confirm()"+corData );
                System.out.println( "devconfig.rabbitTemplate(...).new ConfirmCallback() {...}.confirm()"+ack );
            }
        } );
        return rabbitTemplate;

    }

Answer 1

这不是ack的工作方式-ack意味着它被交付给一个交易所-很少会得到nack-根据RabbitMQ文档，只有在代理本身存在问题时，您才会得到nack。

否定承认

在特殊情况下，当代理无法成功处理消息时，代理将发送basic.ack而不是basic.nack。在此上下文中，basic.nack的字段与basic.ack中的相应字段具有相同的含义，并且应该忽略requeue字段。通过拒绝一个或多个消息，代理表明它无法处理这些消息，并拒绝对这些消息负责；此时，客户端可以选择重新发布消息。

basic.nack只有在负责队列的Erlang进程中发生内部错误时才会传递。

此外，如果连接在接收到ack之前关闭，那么Spring AMQP会生成Nack（同样--非常罕见）。

如果您希望得到消息无法传递到队列的通知，则必须启用publisher returns并将mandition设置为true，消息将返回给您。