Xmemcached源码阅读
Kevin Lynx发表于 2017-04-23 00:00:00
Xmemcached 是一个memcached客户端库。由于它提供的是同步API，而我想看下如何增加异步接口。所以就大致浏览了下它的源码。
主要结构
针对memcache客户端的实现，主要结构如下：
XMemcachedClient是应用主要使用的类，所有针对memcache的接口都在这里Command用于抽象二进制协议或文本协议下各个操作，这里称为Command。CommandFactory用于创建这些commandMemcachedSessionLocator用于抽象不同的负载均衡策略，或者说数据分布策略。在一个memcached集群中，数据具体存放在哪个replica中，主要就是由这个类的实现具体的，例如KetamaMemcachedSessionLocator实现了一致性哈希策略MemcachedConnector包装了网络部分，与每一个memcached建立连接后，就得到一个Session。command的发送都在MemcachedConnector中实现- 各个Session类/接口，则涉及到Xmemcached使用的网络库yanf4j。这个库也是Xmemcached作者的。
Command 类的实现中有个关键的CountDownLatch。在将Command通过session发送出去之后，就利用这个latch同步等待，等到网络模块收到数据后回调。Command会和session绑定，在这个session上收到数据后，就认为是这个command的回应。
由于本身memcached库核心东西比较少，上面的结构也就很好理解。协议的抽象和数据分布策略的抽象是必须的。接下来看看网络实现部分。
网络实现
Xmemcached的网络实现主要结构如下：
SocketChannelController，主要的类，将IO事件通知转交给sessionNioController，主要关注其成员SelectorManagrerSelectorManager内置若干个Reactor，数量由CPU核数决定Reactor，IO事件的产生器，一个Reactor对应一个线程，线程循环中不断轮询NIO selector是否产生了IO事件CodecFactory，编解码网络消息接口PoolDispatcher，Dispatcher 用于调度一个IO事件的具体处理过程，而PoolDispatcher则是放到一个单独的线程池中处理DispatcherFactory，用于创建具体的dispatcher
这个网络实现还是比较典型的Reactor模式。其中，产生IO事件后，IO事件的具体处理，默认交给了一个独立的线程池。一般网络库都会提供类似的机制，以使得IO线程不至于被业务逻辑阻塞住，导致IO处理效率下降。
写数据时，数据都会写到一个队列中，在设备可写时才具体写入。看下具体的读数据过程：
从Reactor中最终调用到Xmemcached的command，用于具体解析回应数据。要调整为异步的话，则可以修改Command的实现，增加异步回调。同时注意控制dispatcher使用的线程池。
完。