上一篇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发送给客户端。
分享到:
相关推荐
【目录】 FQueue简介 Fqueue的存储设计 Fqueue的使用实践 Q&A
NULL 博文链接:https://ainn2006.iteye.com/blog/1543466
fqueue 自动从code.google.com/p/fqueue导出fqueue 自动从code.google.com/p/fqueue导出
#FQueue介绍#labelsIntroductionFQueue是一个高性能、基于磁盘持久存储的队列消息系统。兼容memcached协议,能用memcached的语言都可以良好的与它通信。FQueue为你提供一个不需要特别优化,高性能的一个消息系统。...
资源来自pypi官网。 资源全名:fqueue-0.0.2.tar.bz2
队列fqueue 是一个微插件,用于排队函数执行以处理异步流和单步执行函数。 支持在队列初始化后添加或删除函数。 支持存储可用于该队列内所有功能的数据支持并行和串行异步调用。 完全控制队列,如停止、启动(从任何...
bower install angular-fqueue 新产品管理 npm install angular-fqueue 依赖关系 FixedQueue 仅依赖于 Angular。 用法 将“fqueue”添加为您的应用程序的依赖项,并将 FixedQueue 注入您的控制器或服务。 ...
BlockingFQueue基于磁盘持久存储的阻塞队列
消息中间件常用的jar集合,淘宝优秀消息队列jar包集合,MQ,fqueue,netty,log4j,