反射不参与消息分发，仅动态加载并实例化Consumer；消息分发由RocketMQ/Kafka/Pulsar等框架的拉取、路由和回调机制完成，反射仅用于解耦创建过程，提升扩展性与配置化能力。
反射本身不参与消息分发，它只是帮你动态加载、实例化 Consumer 类；真正完成 Message 分发的是消息队列框架（如 RocketMQ、Kafka、Pulsar）的消费逻辑。关键在于：反射用于解耦 Consumer 创建过程，而分发行为由框架内部的拉取、路由、回调机制驱动。
为什么要用反射创建 Consumer？
避免硬编码依赖具体 Consumer 实现类，便于扩展和配置化管理。比如通过配置文件指定 consumer.class=cn.example.OrderPaidConsumer，运行时用反射加载并初始化，无需修改主流程代码。
常见做法包括：
- 读取配置中的全限定类名，调用 Class.forName(className).getDeclaredConstructor().newInstance()
- 若 Consumer 需要参数（如 topic、group），可定义统一构造接口或使用 Spring 的 @ConfigurationProperties 注入
- 确保目标类有无参构造器，或提前准备好构造参数列表供反射调用
Message 对象如何被传给 Consumer？
不是反射直接“分发”，而是框架在启动 Consumer 后，自动触发其消费循环。以 RocketMQ PushConsumer 为例：
- Consumer 实例注册到客户端后，框架会监听对应 Topic-Queue，主动拉取消息
- 拉到消息后，框架调用你实现的 MessageListenerConcurrently 或 MessageListenerOrderly 接口的 consumeMessage 方法
- 此时 Message 对象作为参数传入，你的业务逻辑在该方法内处理——反射只负责造出这个 Consumer 实例，不干预后续调用链
注意 Consumer 的类型与生命周期
不同消息队列对 Consumer 的抽象略有差异，但核心原则一致：Consumer 是一个具备订阅能力、能响应消息到达事件的运行实体。
- RocketMQ 中必须绑定 ConsumerGroup，且同一组内实例自动负载均衡
- Kafka 中 Consumer 属于 Group，按 Partition 分配，需手动 commit offset 或启用 auto-commit
- Pulsar 支持 Shared/Exclusive/KeyShared 等订阅模式，影响消息分发粒度
- 所有框架都要求 Consumer 在启动后显式 subscribe 主题，并调用 start() 进入工作状态
一个轻量级反射+消费示例（伪代码）
假设配置为：consumer.class=cn.demo.UserActionConsumer，且该类实现了 MessageHandler 接口：
- 加载类：Class> clazz = Class.forName("cn.demo.UserActionConsumer")
- 创建实例：MessageHandler handler = (MessageHandler) clazz.getDeclaredConstructor().newInstance()
- 注入必要资源（如 MQ 客户端）：handler.setMqClient(mqClient)
- 启动消费：handler.startConsuming("user_action_topic") —— 此方法内部调用框架 API 完成订阅与监听
整个过程里，Message 始终由框架从 Broker 拉取并回调到 handler.consume(Message msg)，反射只出现在初始化环节。
