zoukankan      html  css  js  c++  java
  • 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发送给客户端。

            

  • 相关阅读:
    Python3与Python2的区别(转载)
    Python——通过斐波那契数列来理解生成器
    Solr4.8.1与Tomcat7整合
    Solr配置与简单Demo
    lucene 4.4 demo
    企业级搜索引擎Solr使用入门指南
    Solr使用入门指南
    使用solr搭建你的全文检索
    Solr 1.3 安装步骤
    Lucene/Solr开发经验
  • 原文地址:https://www.cnblogs.com/yjl49/p/2371925.html
Copyright © 2011-2022 走看看