Toc
  1. 通信流程
  2. 通信方式
  3. 设计
Toc
0 results found
BOBO
RocketMQ通信
2020/12/28 RocketMQ

通信流程

  1. Broker 启动时将自己注册到 NameServer,之后每隔 30s 向 NameServer 上报 topic 的路由信息。
  2. Producer/Consumer 启动时和 NameServer 建立长连接,从本地缓存中获取 topic 路由信息,获取不到则从 NameServer 中拉取路由信息。
  3. Producer/Consumer 根据 topic 路由信息从 Broker 中发送或拉取消息。

通信方式

同步、异步、单向(无需关注 response,一般用来发送心跳)

设计

使用 Netty 作为底层通信库、遵循 Reactor 多线程模型。

支付宝
微信
Simple is Awesome