消息中间件核心功能实现 生产者设计与消息发送流程   消息构造与序列化   消息结构 // Kafka消息示例（键值对结构） public class ProducerRecord<K, V> { private String topic; // 目标主题 private K key; // 分区路由键（可选） private V value; // 消息体 private Long timestamp; // 时间戳 }    序列化：将对象转为字节流（如JSON、Protobuf、Avro）。     消息路由（分区选择）  哈希路由：按Key哈希值选择分区（保证相同Key的消...