Zookeeper Watcher 源码 收获
QuorumPeer的run方法中会setupRequestProcessor(组装processor),setupRequestProcessor被重写,根据单机或是集群,组装成三种不同的责任链,下图为单机模式服务端接收到客户端请求的时候,会通过NIOServerCnxn submitRequest 提交请求,提交请求之后进入责任链模式每经过责任链其中一个的processor时,会先将re...
·
QuorumPeer的run方法中会setupRequestProcessor(组装processor),setupRequestProcessor被重写,根据单机或是集群,组装成三种不同的责任链
,下图为单机模式
服务端接收到客户端请求的时候,会通过NIOServerCnxn submitRequest 提交请求,提交请求之后进入责任链模式
每经过责任链其中一个的processor时,会先将request放入队列,processor本身是一个线程,自身的run方法从队列中拿到数据再调用下个责任链,实现异步。
更多推荐
已为社区贡献4条内容
所有评论(0)