Spring Cloud Stream中MessageQueueMatcher.receivesPayloadThat的替代方案是什么？

Spring Cloud Stream 从3.0版本开始正式废弃原有spring-cloud-stream-test-support依赖，替换为新版spring-cloud-stream-test-binder，原有MessageQueueMatcher.receivesPayloadThat系列匹配器已从新版测试组件中移除，有两种完全可以替代原有功能的实现方案：

• 直接通过OutputDestination/InputDestination结合通用断言工具实现
  新版测试绑定器提供了OutputDestination（用于接收生产者发出的消息）和InputDestination（用于向消费者发送测试消息）两个核心工具类，你可以直接拉取消息后对payload做断言，示例代码如下：

  // 注入OutputDestination，用来读取生产者发送的消息
  @Autowired
  private OutputDestination outputDestination;
  
  @Test
  void testMessagePayload() {
    // 先执行业务逻辑，触发消息发送
    yourBusinessService.triggerSendMessage();
  
    // 从指定输出绑定通道拉取消息，第一个参数为超时等待时间（毫秒），第二个参数为绑定的目标通道名
    Message<byte[]> receivedMsg = outputDestination.receive(1000, "your-output-binding-name");
    // 转换payload为对应类型，如果是复杂对象可以配合ObjectMapper做序列化转换
    String payload = new String(receivedMsg.getPayload());
  
    // 直接使用Hamcrest、AssertJ等断言工具校验payload，效果和原有receivesPayloadThat完全一致
    org.hamcrest.MatcherAssert.assertThat(payload, org.hamcrest.Matchers.equalTo("预期payload值"));
  }
  

• 自定义匹配器还原原有流式断言写法
  如果你习惯了原有MessageQueueMatcher的流式匹配风格，可以自行封装简易的通用匹配器，代码示例如下：

  import org.hamcrest.Description;
  import org.hamcrest.Matcher;
  import org.hamcrest.TypeSafeMatcher;
  import org.springframework.messaging.Message;
  
  public class MessageTestMatcher {
      public static <T> Matcher<Message<?>> receivesPayloadThat(Matcher<T> payloadMatcher) {
          return new TypeSafeMatcher<Message<?>>() {
              @Override
              protected boolean matchesSafely(Message<?> message) {
                  return payloadMatcher.matches(message.getPayload());
              }
  
              @Override
              public void describeTo(Description description) {
                  description.appendText("message with payload that matches: ")
                          .appendDescriptionOf(payloadMatcher);
              }
          };
      }
  }
  

  封装后使用方式和原有API几乎一致：

  @Test
  void testCustomMatcher() {
    yourBusinessService.triggerSendMessage();
    Message<byte[]> receivedMsg = outputDestination.receive(1000, "your-output-binding-name");
    assertThat(receivedMsg, receivesPayloadThat(equalTo("test payload")));
  }
  

注意：调用receive方法时传入的通道名需要和你项目application.yml/application.properties中配置的绑定目标名称保持一致。

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