Spring Cloud Stream 是一个用于构建基于消息的微服务的框架，它提供了一种简单的方式来连接消息代理和应用程序，以便它们可以互相交换消息。Spring Cloud Stream 中有两个高级特性：分组和多通道。
1. 分组
分组是指将一个或多个应用程序分组在一起，这些应用程序可以共享同一个主题或队列，并独立地消费消息。在 Spring Cloud Stream 中，可以通过 spring.cloud.stream.bindings.<channel-name>.group 属性来配置分组。
例如，如果有两个应用程序 A 和 B，它们都要从名为 input 的通道消费消息，并且它们应该共享消费者组，则可以在两个应用程序的配置文件中添加以下配置：
spring.cloud.stream.bindings.input.group=my-group通过设置相同的 group 值，应用程序 A 和 B 将成为同一消费者组的成员，并且它们将共享同一主题或队列中的消息。这意味着如果一个应用程序消费了消息，其他应用程序将无法再消费该消息。
2. 多通道
多通道是指应用程序可以订阅多个通道，并在这些通道上同时进行消息处理。在 Spring Cloud Stream 中，可以使用 @StreamListener 注解来实现多通道消费。通过在 @StreamListener 注解中指定通道名称，可以让应用程序同时消费多个通道的消息。
例如，如果要让应用程序同时消费名为 input1 和 input2 的两个通道中的消息，可以编写如下代码：
@StreamListener("input1")
public void handleInput1Message(String message) {
// 处理 input1 通道上的消息
}
@StreamListener("input2")
public void handleInput2Message(String message) {
// 处理 input2 通道上的消息
}在这个例子中，handleInput1Message 方法将会接收名为 input1 的通道上的消息，handleInput2Message 方法将会接收名为 input2 的通道上的消息。
此外，还可以使用通配符来订阅多个通道。例如，如果想让应用程序同时消费所有以 input 开头的通道中的消息，可以这样做：
@StreamListener("input*")
public void handleInputMessages(String message) {
// 处理所有以 input 开头的通道上的消息
}在这个例子中，handleInputMessages 方法将会接收所有以 input 开头的通道上的消息。
