MQ常见问题解决思路

Producer初始化为 confirm 模式，消息发送后会异步回调生产者，生产者即可知道消息是否发送成功

@Component
@RequiredArgsConstructor
@Slf4j
public class MqProducer {

    private final RabbitTemplate rabbitTemplate;

    @PostConstruct
    public void init() {
        // Producer初始化为 confirm 模式，消息发送后会异步回调生产者,通过ack的布尔值判断消息是否正确被MQ接收
        rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
            if (ack) {
                // 发送成功
                log.info("----> Message sent successfully.");
            } else {
                // 发送失败
                log.error("----> Failed to send message: " + cause);
            }
        });
        rabbitTemplate.setMandatory(true);
    }


    public void sendMessage(String routingKey, Object message) {
        rabbitTemplate.convertAndSend(MqConf.DIRECT_EXCHANGE, routingKey, JSON.toJSON(message));
        log.info("----> Sent message: " + message);
    }
}

spring:
  rabbitmq:
    host: xxxx
    port: 5672
    username: guest
    password: guest
    # confirm模式配置 !!!!
    publisher-confirm-type: correlated

2、MQ内部的消息丢失：

消息持久化，当消息被成功消费时再删除。

设计分段式队列，避免消息在单一队列中堆积过多导致丢失。

利用死信队列，将未成功消费的消息再发一次MQ。

通过使用集群、复制和备份等技术手段，实现 MQ 的高可用和容灾能力，避免单点故障导致消息丢失。

3、Consumer的消息丢失

RabbitMQ默认为自动签收消息，因此Consumer在监听队列时，应开启手动签收模式@RabbitListener(queues = MqConf.HELLO_QUEUE, ackMode = "MANUAL")