dubbo心跳检测源码分析

3月 31, 2018 |

执行DubboProtocol.export会执行createServer方法创建dubbo 服务监听线程。最后由HeaderExchanger.bind完成。Transporters.bind()完成dubbo 服务监听线程的创建, HeaderExchangeServer负责心跳线程的创建

HeaderExchangeServer通过单线程的ScheduledExecutorService来完成心跳事件触发

ScheduledExecutorService 检测和对方最后一次通讯操作(无论是写还是读)是否超过了心跳检测的时间间隔,超过了就发送HEARTBEAT_EVENT 事件。

HeartbeatHandler完成心跳事件接收的操作, 接收到心跳请求消息和心跳响应消息的逻辑如下。

Posted in: MySQL practise

Comments are closed.