2. ZooKeeper - IO通信
2021-03-29 16:40:47 0 举报
登录查看完整内容
Zookeeper-IO通信原理图，包含客户端与服务端通信，及服务端与服务端之间的通信。
作者其他创作
大纲/内容
SelectorThread
客户端与服务端之间通过NIO通信
SendThread2 - I/O
AcceptThread
poll
NIOServerCnxn
SendThread3 - I/O
C- 2
RecvWorker
Selector
dout.write
LinkedBlockingQueue<ToSend> sendqueue
BlockingQueue<SocketChannel> acceptedQueue
SendThread处理读写请求
SendWorker2
3.offer
offer
2.selectnext
服务器节点间通过BIO通信
SendWorker1
SelectorThreads
BlockingQueue<ByteBuffer> bq2
Server - 1
4. poll regist-read
SendThread1 - I/O
Server - 3
Server
Server - 2
C- 3
BlockingQueue<Message> recvQueue
outgoingQueue1
outgoingQueue2
C- 1
1.registaccept
din.read
LinkedBlockingQueue<Notification> recvqueue
BlockingQueue<ByteBuffer> bq1
ZK中大量使用了阻塞队列进行异步解耦
WorkerReceiver
WorkerSender
Clients
outgoingQueue3
ServerSocketChannel
0 条评论
回复 删除
下一页
