将Spring云Spring服务连接器与RabbitMQ一起使用，并启动发布服务器配置函数

Question

我连接RabbitMQ与斯普林云配置：

@Bean
public ConnectionFactory rabbitConnectionFactory() {
    Map<String, Object> properties = new HashMap<String, Object>();
    properties.put("publisherConfirms", true);
    RabbitConnectionFactoryConfig rabbitConfig = new RabbitConnectionFactoryConfig(properties);
    return connectionFactory().rabbitConnectionFactory(rabbitConfig);
}

2.设置RabbitTemplate.set强制性（true）和setConfirmCallback（）：

@Bean
public RabbitTemplate rabbitTemplate() {
   RabbitTemplate template = new RabbitTemplate(connectionFactory);
   template.setMandatory(true);
   template.setMessageConverter(new Jackson2JsonMessageConverter());
   template.setConfirmCallback((correlationData, ack, cause) -> {
      if (!ack) {
          System.out.println("send message failed: " + cause + correlationData.toString());
      } else {
          System.out.println("Publisher Confirm" + correlationData.toString());
      }
  });
  return template;
}

3.将消息发送到队列以调用发布者确认并打印日志。

@Component
public class TestSender {

@Autowired
private RabbitTemplate rabbitTemplate;

@Scheduled(cron = "0/5 * *  * * ? ")
public void send() {
    this.rabbitTemplate.convertAndSend(EXCHANGE, "routingkey", "hello world",
        (Message m) -> {
            m.getMessageProperties().setHeader("tenant", "aaaaa");
            return m;
        }, new CorrelationData(UUID.randomUUID().toString()));
    Date date = new Date();
    System.out.println("Sender Msg Successfully - " + date);
 }
}

但出版商确认没有工作。日志尚未打印。无论真假，日志都不应该缺席。

Answer 1

确认不需要强制，只需要返回。

有些事情要尝试：

1. 打开调试日志以查看它的帮助；生成了一些关于确认的日志
2. 添加一些代码

.

template.execute(channel -> {
    system.out.println(channel.getClass());
    return null;
}

如果您没有看到PublisherCallbackChannelImpl，则表示由于某种原因配置不起作用。同样，调试日志应该有助于配置调试。

如果你仍然不能弄清楚，把你的应用程序剥离到显示行为的最低限度，然后发布完整的应用程序。