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发送给客户端。

        

原文地址:https://www.cnblogs.com/yjl49/p/2371925.html