[Enhancement] Enhancement title 实现了一个同时支持多instance的RocketMQ的starter组件，抽象了重复的binder代码

[helloworldtang]

Before Creating the Enhancement Request

• I have confirmed that this should be classified as an enhancement rather than a bug/feature.

Summary

用过RocketMQ的都知道，官网只提供了一个集群的starter，如果业务域进行消息隔离，使用了不同的集群，就只能copy、paste这种样板式代码，好烦！！！

Motivation

去除样板式的重复代码，通过封装让RocketMQ接入更高效

Describe the Solution You'd Like

这是一个用于 Spring Boot 应用接入 RocketMQ 的 Starter 组件。它旨在解决单一应用需要连接多个 RocketMQ 集群或实例的场景，并提供声明式的消息消费能力，简化了 RocketMQ 的集成过程。

主要解决的问题：

多实例支持：允许在一个应用中配置和连接多个不同的 RocketMQ Nameserver/Broker。
声明式消费：通过注解@RocketMQListener即可完成消费者的定义和注册，无需编写繁琐的样板代码。
兼容性：同时支持 Spring Boot 2.x 和 3.x 版本，基于 JDK 1.8+。

Describe Alternatives You've Considered

中台建设过程中，不同业务域之间的MQ消息通过集群来实现物理隔离，划分系统边界，提高系统可用性

Additional Context

最新版本：0.1.0

快速开始

1. 引入依赖
   在你的 pom.xml 中添加如下依赖：

io.github.helloworldtang rocketmq-multi-instance-spring-boot-starter 0.1.0 2. 配置文件 在 application.yml 或 application.properties 中配置 RocketMQ 实例信息：

rocketmq:
instances:
instance1:
name-server: 127.0.0.1:9876
# access-key: your-access-key (可选)
# secret-key: your-secret-key (可选)
instance2:
name-server: 192.168.1.100:9876
3. 发送消息
组件提供了灵活的方式获取 DefaultMQProducer 实例。

方式一：静态工具类（推荐）
在任何地方（包括非 Spring 管理的类）均可使用：

// 直接获取指定实例的 Producer
DefaultMQProducer producer = RocketMQProducerContainer.get("instance1");
if (producer != null) {
producer.send(new Message("TopicTest", "TagA", "Hello World".getBytes()));
}
方式二：Spring 注入
使用 @qualifier 指定 Bean 名称，Bean 名称规则为 {instanceId}Producer：

@RestController
public class ProducerController {

@Autowired
@Qualifier("instance1Producer")
private DefaultMQProducer producer;

@GetMapping("/send")
public String send(@RequestParam("msg") String msg) {
    try {
        Message message = new Message("TopicTest", "TagA", msg.getBytes());
        producer.send(message);
        return "Sent: " + msg;
    } catch (Exception e) {
        return "Failed: " + e.getMessage();
    }
}

}
4. 消费消息
实现 RocketMQMessageListener 接口，并在类上添加 @RocketMQListener 注解。

@component
@RocketMQListener(
instanceId = "instance1", // 指定使用哪个实例配置
topic = "TopicTest", // 订阅的主题
consumerGroupId = "my-group", // 消费者组ID
tags = "" // 订阅的Tag，默认
)
public class MyConsumer implements RocketMQMessageListener {

@Override
public void onMessage(MessageExt message) {
    System.out.println("Received message: " + new String(message.getBody()));
    // 如果抛出异常，消息将会在稍后重试
}

}
验证与验收
本项目包含一个 rocketmq-demo 模块，用于演示和验证功能。

环境准备：

启动本地 RocketMQ NameServer (默认端口 9876) 和 Broker (默认端口 10911)。
确保 NameServer 地址为 127.0.0.1:9876 (或修改 demo 的 application.yml)。
启动应用：

运行 rocketmq-demo 模块下的 DemoApplication。
观察日志，确认 RocketMQConsumerContainer 成功启动并注册了消费者。
功能验证：

发送消息： 访问 http://localhost:8081/send?msg=Hello 浏览器应返回 Sent: Hello。
消费消息： 查看控制台日志，应能看到如下格式的日志：
Received message. Instance: instance1, GroupId: my-group, Topic: TopicTest, Tag: TagA, MsgId: ..., Body: Hello
Consumed message successfully. ...
技术亮点
无侵入设计：基于 Spring Boot 自动配置机制，引入 Starter 即可使用，不破坏原有项目结构。
多实例隔离：通过 instanceId 逻辑隔离不同集群的配置和客户端实例，互不干扰。
优雅的 API：
提供 @RocketMQListener 注解，屏蔽了底层消费者创建、订阅、监听器注册等复杂细节。
提供 RocketMQProducerContainer 静态访问入口，解决了在 Utils 等非 Spring Bean 中获取 Producer 的痛点。
健壮性：
自动重试：消费异常自动返回 RECONSUME_LATER。
全链路日志：内置详细的收发消息日志，包含 GroupId、MsgId 等关键信息，便于排查问题。
高兼容性：
Spring Boot: 同时兼容 2.x 和 3.x。
JDK: 兼容 JDK 8 及以上版本。