Spring Cloud Stream中Post Processing执行状态判断方法问询

有几种实用的方案可以区分消息发布的成功与失败场景：

• 使用SendCallback回调区分状态
  调用StreamBridge.send()或者绑定的MessageChannel发送消息时，传入SendCallback接口实现即可。这个接口的两个方法会分别对应成功和失败场景：

  streamBridge.send("your-output-destination", message, new SendCallback() {
      @Override
      public void onSuccess(SendResult result) {
          // 这里处理消息发送成功的逻辑
      }
  
      @Override
      public void onFailure(Throwable ex) {
          // 这里处理消息发送失败的逻辑
      }
  });
  

  异步发送时，这个回调能精准捕获两种状态，比单纯依赖Post Processing更直接。

• 通过同步发送的返回结果判断
  如果是同步发送消息，send()方法会返回SendResult对象。你可以直接通过result.getException()是否为null来判断：

  SendResult result = streamBridge.send("your-output-destination", message);
  if (result.getException() == null) {
      // 发送成功
  } else {
      // 发送失败，可通过result.getException()获取具体错误原因
  }
  

  这种方式适合不需要异步处理的场景，能直接拿到发送状态。

• 结合绑定器的专属特性
  不同消息中间件的绑定器有各自的扩展支持：

  • Kafka绑定器：可以使用KafkaSendCallback，它能返回分区、偏移量等Kafka专属元数据，失败时会携带Kafka相关的具体异常。
  • RabbitMQ绑定器：同步发送失败时会抛出AmqpException子类，异步则通过SendCallback捕获异常，还能结合Rabbit的确认机制进一步验证。

内容的提问来源于stack exchange，提问作者Tilak