RocketMq-HAService

2021-10-09  本文已影响0人  飞哈飞

HAService管理主从同步,创建HAConnection

一个slave会对应一个HAConnection,

读数据一个ReadSocketService线程,接收心跳,更新对应slave同步点和HAService全局最大Slave同步点

写数据一个WriteSocketService线程定时一秒往从节点主动写数据

上一篇 下一篇

猜你喜欢

热点阅读