Spring Cloud Stream同一通道根据消息内容分发不同的消费逻辑

应用场景 有的时候，我们对于同一通道中的消息处理，会通过判断头信息或者消息内容来做一些差异化处理，比如：可能在消息头信息中带入消息版本号，然后通过if判断来执行不同的处理逻辑，其代码结构可能是这样的： @StreamListener(value = TestTopic.INPUT) public void receiveV1(String payload, @Header("version") S

>>阅读原文<<