Java中统一MQ消息契约的核心是定义轻量泛型接口Message<T>，仅含getPayload()等业务方法，解耦序列化与传输，Producer/Consumer均面向该接口编程，支持多中间件无缝切换。
Java 中用接口统一 MQ 消息发送契约，核心不是写一堆抽象类，而是定义一个轻量、稳定、可扩展的泛型消息契约接口，并让 Producer 与所有消息中间件（Kafka、RocketMQ、RabbitMQ 等）都面向它编程。
定义泛型消息接口 Message
只暴露业务关心的部分：消息体类型 + 必要元信息，不掺杂序列化、传输细节。
- 只含 getPayload()：返回 T 类型数据，保证编译期类型安全，避免 consumer 里强转 Object
- 可选补充 getId()、getTimestamp()、getHeaders() —— 后者返回不可变 Map<String, String>，用于透传 traceId、tenantId 等上下文，不污染业务 payload
- 不定义 set 方法、不强制继承、不绑定具体序列化方式，允许用户自由实现 JsonMessage<Order>、AvroMessage<Event> 等
Producer 统一接收 Message，内部适配不同 MQ
每个 MQ 客户端封装成独立的 Producer 实现，但对外签名完全一致：
- public <T> void send(Message<T> msg) —— 所有生产者共用该方法
- 内部根据 msg 的实际类型（如 Class<Order>）和配置的 Serializer<T>（如 JacksonSerializer 或 ProtobufSerializer）完成序列化
- 例如 RocketMQ Producer 将 payload 转为 byte[] 并设入 MessageExt；Kafka Producer 则包装为 ProducerRecord<byte[], byte[]>
Consumer 回调签名也统一为 Message
框架负责反序列化并确保类型正确，开发者只处理业务逻辑：
立即学习“Java免费学习笔记（深入）”；
- 注册回调时显式声明类型：consumer.listen(Order.class, msg -> process(msg.getPayload()))
- 或使用 TypeReference 支持复杂泛型：consumer.listen(new TypeReference<List<User>>(){}, list -> {...})
- 反序列化失败、类型不匹配等异常由框架拦截并记录，不抛到业务层
契约与传输解耦，支持多协议切换
消息体结构（契约）和底层传输（Kafka/RocketMQ/HTTP fallback）完全分离：
- 同一份 Message<PaymentEvent> 可被 KafkaProducer 发送，也可被本地 EventBus 或 REST Gateway 转发
- 只需替换 Producer 实现类，无需修改业务代码；headers、traceId 等跨协议字段自动携带
- 契约本身可导出为 OpenAPI Schema 或 AsyncAPI 定义，供前端、测试、文档工具消费
