功能:java
功能:循环处理接收客户端请求, 并将接收到的SocketChannel放入SelectorThread的acceptedQueue中apache
功能:处理队列submittedRequests
对应程序片断:org.apache.zookeeper.server.PrepRequestProcessor.run(PrepRequestProcessor.java:134)
线程
功能:请求处理链2
对应程序片断: org.apache.zookeeper.server.SyncRequestProcessor.run(SyncRequestProcessor.java:109)
code
功能:待完善server
功能:关闭超时的链接NIOServerCnxntoken
AcceptThread(接收链接请求SocketChannel)
-------> SelectorThread(从Socket读取数据, 封装成Request)
-------------> ProcessThread(处理Request) 队列
持续完善中。。。get