RocketMq-HAService
2021-10-09 本文已影响0人
飞哈飞
HAService管理主从同步,创建HAConnection
一个slave会对应一个HAConnection,
读数据一个ReadSocketService线程,接收心跳,更新对应slave同步点和HAService全局最大Slave同步点
写数据一个WriteSocketService线程定时一秒往从节点主动写数据
HAService管理主从同步,创建HAConnection
一个slave会对应一个HAConnection,
读数据一个ReadSocketService线程,接收心跳,更新对应slave同步点和HAService全局最大Slave同步点
写数据一个WriteSocketService线程定时一秒往从节点主动写数据