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

            

  • 相关阅读:
    Kubernetes基础
    docker概述
    mongoDB概述
    springcloud-stream为什么被引入
    springcloud-bus+config实现动态刷新定点通知
    springcloud-bus+config实现动态刷新全局广播配置
    springcloud-bus是什么
    springcloud-动态刷新之手动版
    springcloud-服务读取Config配置中心
    springcloud-Config配置中心搭建
  • 原文地址:https://www.cnblogs.com/yjl49/p/2371925.html
Copyright © 2011-2022 走看看