java - 如何知道消息是否已被确认/确认？

Question

我想知道何时使用 RabbitMQ 和 Spring Boot 接受 (ack) 或不接受 (nack) 消息。
我想将消息发送到队列(通过交换)并检查队列是否已接受该消息。实际上我想发送到两个不同的队列，但这并不重要，我假设它是否适用于其中一个也适用于另一个。
所以我用 CorrelationData 尝试了这样的事情:

public boolean sendMessage(...) {
    CorrelationData cd = new CorrelationData();
    this.rabbitTemplate.convertAndSend(exchange, routingKey, message, cd);
    try {
        return cd.getFuture().get(3, TimeUnit.SECONDS).isAck();
    } catch (InterruptedException | ExecutionException | TimeoutException e ) {
        e.printStackTrace();
        return false;
    }
}

线路 cd.getFuture().get(3, TimeUnit.SECONDS).isAck()应该得到 false值还没有被 ack我想进入队列。但这总是正确的，即使 routingKey不存在。
所以我假设这段代码正在检查消息是否已发送到 exchange和 exchange说“是的，我收到了消息，它没有被路由，但我已经收到了”。
所以，我已经在 Rabbit/Spring 文档中寻找其他方法，但我找不到方法。
而且，再解释一下，我想要的是:
进入 Spring Boot 代码，我收到一条消息。此消息必须发送到其他队列/交换，但不能从当前队列中删除(即确认)，直到其他两个队列确认 ack .
我有手动确认和一些伪代码，我有这个:

@RabbitListener(queues = {queue})
public void receiveMessageFromDirect(Message message, Channel channel,
                                     @Header(AmqpHeaders.DELIVERY_TAG) long tag){
    boolean sendQueue1 = sendMessage(...);
    boolean sendQueue2 = sendMessage(...);

    if(sendQueue1 && sendQueue2){
        //both messages has been readed; now I can ack this message
        channel.basicAck(tag, false);
    }else{ 
        //nacked; I can't remove the message util both queue ack the message
        channel.basicNack(tag,false,true);
    }

我已经测试了这个结构，即使队列不存在，值 sendQueue1和 sendQueue2永远是真的。

Answer 1

确认为真；即使对于不可路由的消息(我不完全确定为什么)。
您需要启用返回的消息(并在 future 完成后检查它在 CorrelationData 中是否为空 - correlationData.getReturnedMessage() )。如果它不为空，则该消息不可路由到任何队列。
如果代理中存在错误，或者您正在使用带有 x-max-length 的队列，您只会收到 nacks。和溢出行为 reject-publish .