RocketMQ怎么写才能使同一个group分组中的不同topic消息用对应的listener监听呢

在RocketMQ中，同一个Consumer Group下的不同Topic的消息需要通过对应的Listener来监听，可以按照以下步骤实现：

使用RocketMQ 4.x版本的客户端，因为在RocketMQ 5.x版本中，ACL和接入Canal等功能可能存在一些问题。

创建不同的Listener实例来处理不同Topic的消息。可以根据需要创建多个Listener类，并分别实现消息处理的逻辑。

在每个Listener实例中，使用不同的Subscribe方法订阅对应的Topic。在RocketMQ 4.x版本中，Subscribe方法接受两个参数：Topic和Tag。可以通过指定不同的Topic和Tag来订阅具体的消息。

在每个Listener实例中，实现messageListener接口的consumeMessage方法，并实现对应Topic的消息处理逻辑。每个Listener实例只会监听和处理其订阅的Topic的消息。
示例代码如下：
```js// Listener1，处理topic1的消息
public class Listener1 implements MessageListenerConcurrently {
public void consumeMessage(List messages, ConsumeConcurrentlyContext context) {
// 处理topic1的消息逻辑
}
}

// Listener2，处理topic2的消息
public class Listener2 implements MessageListenerConcurrently {
public void consumeMessage(List messages, ConsumeConcurrentlyContext context) {
// 处理topic2的消息逻辑
}
}

// 创建Consumer实例
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup");
// 设置NameServer地址
consumer.setNamesrvAddr("localhost:9876");
// 注册Listener1来处理topic1的消息
consumer.subscribe("topic1", "");
consumer.registerMessageListener(new Listener1());
// 注册Listener2来处理topic2的消息
consumer.subscribe("topic2", "");
consumer.registerMessageListener(new Listener2());
// 启动Consumer
consumer.start();

在上述示例中，Listener1和Listener2分别处理topic1和topic2的消息。通过指定不同的Topic和对应的Listener实例，可以实现同一个Consumer Group下的不同Topic使用不同的Listener处理。

请注意，在使用RocketMQ时，Consumer Group和Topic的概念是关键。确保Consumer Group和Topic的配置正确，并根据实际需求创建对应的Listener实例，并订阅和处理相应的消息。
```