RocketMQ通信
通信流程
- Broker 启动时将自己注册到 NameServer,之后每隔 30s 向 NameServer 上报 topic 的路由信息。
- Producer/Consumer 启动时和 NameServer 建立长连接,从本地缓存中获取 topic 路由信息,获取不到则从 NameServer 中拉取路由信息。
- Producer/Consumer 根据 topic 路由信息从 Broker 中发送或拉取消息。
通信方式
同步、异步、单向(无需关注 response,一般用来发送心跳)
设计
使用 Netty 作为底层通信库、遵循 Reactor 多线程模型。
Simple is Awesome