如果队列不存在，则消息丢失

Posted 2023-02-19

【中文标题】如果队列不存在，则消息丢失

【英文标题】：Messages lost if queue does not exist

【发布时间】：2017-10-25 20:04:05

【问题描述】：

当我们向 RabbitMQ 发送消息时，如果队列不存在，则消息会丢失而不会引发任何错误。

邮件将发布到哪里？死队列？

【参考方案1】：

这就是 RabbitMQ 的设计方式 - 发布者发布到交易所，而不是队列。

如果没有队列绑定（如果交换需要，则使用匹配的路由键），则简单地丢弃该消息。

您可以enable publisher returns 并在发布时设置mandatory 标志，代理将返回消息（但它到达不同的线程，而不是发布线程）。

【参考方案2】：

您的消息可以退回给您

如果没有绑定到交换的队列。要接收它们并且不丢失这些消息，您必须执行以下操作：

1。将这些属性添加到您的 application.yml

spring:
  rabbitmq:
    publisher-confirm-type: correlated
    publisher-returns: true
    template:
      mandatory: true

2。创建 RabbitConfirmCallback

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;

@Component
public class RabbitConfirmCallback implements RabbitTemplate.ConfirmCallback 
    private static final Logger logger = LoggerFactory.getLogger(RabbitConfirmCallback.class);

    @Override
    public void confirm(CorrelationData correlationData, boolean ack, String cause) 
        if (ack && correlationData != null && correlationData.getId() != null) 

            Message returnedMessage = correlationData.getReturnedMessage();
            String dataId = correlationData.getId();

            if (returnedMessage != null) 
                logger.error("Message wasn't delivered to Consumer; " + returnedMessage + "\nCorrelationData id = " + dataId);
             else 
                logger.info("CorrelationData with id " + dataId + " acknowledged;");
            

         else 
            if (ack) 
                logger.warn("Unknown message acknowledgement received: " + correlationData);
             else 
                logger.info("Broker didn't accept message: " + cause);
            
        
    

这个回调方法confirm(...)将被触发，在这种无限制队列的交换中尝试发送消息之后。 在correlationData 对象中，您会发现returnedMessage 字段将是您的消息的messageProperties 和body

3。将 RabbitConfirmCallback 设置为 RabbitTemplate

@Autowired
public void post(RabbitTemplate rabbitTemplate, RabbitConfirmCallback rabbitConfirmCallback)
    rabbitTemplate.setConfirmCallback(rabbitConfirmCallback);

4。发送消息时，添加 CorrelationDate 对象

带有一些唯一标识符

rabbitTemplate.convertAndSend(exchange, routingKey, wrapMessage(message),
                              new CorrelationData(stringId));