RabbitMQ高级篇笔记

news2025/2/27 2:45:12

这是一些高级的内容。
RabbitMQ还是运行在网络上的，倘若遇到了网络故障，mq自己挂了，出异常了，都会造成最终状态不一致的问题。这就是可靠性问题。
可靠性：一个消息发送出去之后，至少被消费1次。
要解决这3个问题

消息发送的时候丢了
mq自己丢了
消费者丢了
以上都失败了，还得有一个兜底方案。这样尽可能万无一失了。

生产者重连

生产者连不上mq了，此时发送直接失败。因此有了失败重连。
失败重连配置
它会影响失败时候的性能，因为mq主打不等，所以生产环境建议禁用。

生产者确认

生产者开启确认机制后，MQ收到消息后，会返回消息给生产者

投递到MQ，但是路由失败了。（你的routingKey不对，或者交换机没绑定。）一般是开发人员的问题。
投递到了MQ，并且成功入队，告知投递成功ACK。
持久化消息，入队成功完成持久化好后，才会ACK。
其他情况都会返回NACK，告知投递失败。

如何接收ack/nack

有同步和异步两个方法
回调配置

先配置

@Configuration
public class MqConfig implements ApplicationContextAware {


  @Override
  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
    RabbitTemplate rabbitTemplate = applicationContext.getBean(RabbitTemplate.class);
    rabbitTemplate.setReturnsCallback(new ReturnsCallback() {
      @Override
      public void returnedMessage(ReturnedMessage returned) {
        log.debug("收到消息的return  callback");
      }
    });



  }
}

@Test
  
 void testConfirm() throws InterruptedException {
    CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
    correlationData.getFuture()
        .addCallback(new ListenableFutureCallback<CorrelationData.Confirm>() {
          @Override
          public void onFailure(Throwable ex) {
            log.error("消息回调失败", ex);

          }

          @Override
          public void onSuccess(Confirm result) {
            log.debug("收到回执");
            if (result.isAck()) {
              log.debug("成功");
            } else {
              log.debug("失败");
            }
          }
        });
    rabbitTemplate.convertAndSend("hmall.direct11", "blue11", "hello",correlationData);
    Thread.sleep(2000);

  }