spring cloud stream rocketmq 多通道实现 多生产者多消费者

在Spring Cloud Stream RocketMQ中实现多通道，可以通过配置多个binding来实现。首先，在application.properties文件中配置多个binding，例如：

spring.cloud.stream.bindings.output1.destination=topic1
spring.cloud.stream.bindings.output1.producer.configuration.group-id=group1
spring.cloud.stream.bindings.output2.destination=topic2
spring.cloud.stream.bindings.output2.producer.configuration.group-id=group2

这里我们定义了两个binding，一个是output1，对应的destination是topic1，group-id是group1；另一个是output2，对应的destination是topic2，group-id是group2。

接下来，我们可以定义多个生产者和消费者来使用这些binding，例如：

@EnableBinding({Source.class, Sink.class})
public class RocketMQMultipleChannelApplication {

    @Autowired
    @Qualifier("output1")
    private MessageChannel output1;

    @Autowired
    @Qualifier("output2")
    private MessageChannel output2;

    @Autowired
    @Qualifier("input1")
    private SubscribableChannel input1;

    @Autowired
    @Qualifier("input2")
    private SubscribableChannel input2;

    @StreamListener("input1")
    public void handleMessage1(String message) {
        // 处理input1通道的消息
    }

    @StreamListener("input2")
    public void handleMessage2(String message) {
        // 处理input2通道的消息
    }

    public void sendMessage1(String message) {
        output1.send(MessageBuilder.withPayload(message).build());
    }

    public void sendMessage2(String message) {
        output2.send(MessageBuilder.withPayload(message).build());
    }
}

在上面的代码中，我们使用了`@Qualifier`来指定注入的消息通道，分别对应上面定义的output1、output2、input1、input2。然后使用`@StreamListener`注解来监听消费消息，也分别对应input1、input2。

最后，在需要发送消息的地方，我们可以通过调用`sendMessage1`、`sendMessage2`方法来发送不同的消息到不同的通道。