HAService管理主从同步,创建HAConnection
一个slave会对应一个HAConnection,
读数据一个ReadSocketService线程,接收心跳,更新对应slave同步点和HAService全局最大Slave同步点
写数据一个WriteSocketService线程定时一秒往从节点主动写数据
HAService管理主从同步,创建HAConnection
一个slave会对应一个HAConnection,
读数据一个ReadSocketService线程,接收心跳,更新对应slave同步点和HAService全局最大Slave同步点
写数据一个WriteSocketService线程定时一秒往从节点主动写数据
本文标题:RocketMq-HAService
本文链接:https://www.haomeiwen.com/subject/rubfoltx.html
网友评论