hiJu 751ff1d4cf feat(rocketmq): 自研 Remoting 协议运行时 crate rocketmq-runtime ...

- 帧编解码:4B 总长 + 4B(serializeType<<24|headerLen) + JSON header
  {code,language,version,opaque,flag,remark,extFields} + body,与
  apache/rocketmq 官方 remoting 实现逐项对照
- 连接管理:opaque 配对长连接、oneshot 响应分发、请求超时、
  NameServer 多地址轮询故障切换、SSH 引用式隧道前置
- ACL:4.x HMAC-SHA1 签名(accessKey/secretKey),未配置自动跳过
- 请求码:GET_ROUTEINFO_BY_TOPIC/GET_BROKER_CLUSTER_INFO/
  GET_ALL_TOPIC_LIST_FROM_NAMESERVER(206,按源码修正)/topic
  CRUD/GET_ALL_SUBSCRIPTIONGROUP_CONFIG/GET_CONSUMER_CONNECTION_LIST/
  QUERY_MESSAGE/VIEW_MESSAGE_BY_ID(commitlog 二进制 body 解码器)/
  SEND_MESSAGE_V2
- fastjson 兼容建模:MessageQueue 序列化为 JSON 字符串键的
  TopicStatsTable/ConsumeStats DTO
- MiddlewareAdmin 13 方法全实现(集群概览/Topic 增删改查/发送/
  订阅组/客户端/三变体消息查询)
- 43 个单测(帧往返/DTO 样本/mock TCP 假服务端集成测试)+
  docs/rocketmq-runtime/TESTING.md 联调手册

2026-09-08 19:56:38 +08:00

..

TESTING.md

feat(rocketmq): 自研 Remoting 协议运行时 crate rocketmq-runtime

2026-09-08 19:56:38 +08:00