fqueue(二)

上一篇blog分析了fqueue 的数据存储层的实现。这篇主要分析通信部分。fqueue使用jmemcached做为通信层，jmemcached与客户端的交互使用netty框架。

主要的类如下：

startNewQueue：启动类，每new一个instance 都会启动一个监听了相应端口的服务。

MemCacheDaemon：负责通信的管理，包括调用netty建立监听，接受连接等，这里会根据交互数据格式的不同选择处理二进制数据或字符数据。

CacheImpl：对Cache接口的具体实现，使用FSQueue做为实际的数据存储层。

MemcachedCommandHandler：对netty收到的数据的实际处理类。

 

基本处理流程如下：

netty底层收到客户端数据 ---------->由MemcachedBinaryCommandDecoder或MemcachedCommandDecoder进行初步解析转化为内部可识的CommandMessage------------>由MemcachedCommandHandler根据CommandMessage中的cmd成员分辨具体的功能调用CacheImpl相应的方法处理----------->

FSQueue实现具体数据的增删改队列等---------->处理结果再由MemcachedBinaryResponseEncoder或MemcachedResponseEncoder进行编码-------->由netty发送给客户端。