Thrift之TProtocol类体系原理及源码详细解析之类继承架构分析

本文主要是介绍Thrift之TProtocol类体系原理及源码详细解析之类继承架构分析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

http://blog.csdn.net/wanweiaiaqiang/article/details/7632665



这部分相关的类主要实现与协议相关的内容,这里说的协议是指对数据传输格式封装的协议,实现不同的协议来适合不同场景下的数据传输,因为在不同的场景下不同协议对于数据传输来说效率有很大的差别。下面是这个部分相关类的类关系图:


由以上类图可以发现所有的协议类都从TProtocol类直接或间接继承,每一个协议类都有一个对应的生产对象工厂(协议工厂)。TProtocol是一个抽象的类,不能直接使用的,它有一个直接子类默认实现了所有方法(空实现),如果我们需要定义自己的数据传输协议可以直接从这个类继承。

第一节 类继承架构分析

为什么需要对这部分的类继承架构进行分析了?上面不是有很清楚的类继承关系图了吗?但是Facebook在实现时并不是简单的这样继承下来就可以了,Facebook为了后期协议的可扩展性和允许其他组织、团队或个人实现自己的数据传输(主要是数据格式的封装)协议,里面多加了一层继承关系,就是类图中的TVirtualProtocol类,从类的名称可以看出这是一个虚的协议。怎样理解这个虚的协议了?通过阅读代码我觉得可以这样理解:因为它定义为一个模板类,这个模板类有两个参数,一个用于数据传输的真正协议,一个是用来继承的,它本身没有对协议具体内容做实现,所以说它是一个虚的协议类。下面我们对这个类继承架构结合代码实现来具体分析。

抽象类TProtocol和默认实现类TProtocolDefaults

抽象类对于每一种数据类型都提供了读写的开始和介绍的方法,这里读写方法应该是针对网络IO读写,不过真正实现网络读写还不是这里的方法,这里方法主要处理数据,例如对数据格式做调整。真正实现网络IO读写是下一章介绍的TTransport相关类实现的,那里还会对传输的方式做相应控制,例如是否压缩。

除了具体的数据类型有写入和读取的方法,消息也是需要通过网络传递,所以也定义了消息的传输读写方法。当然还定义了一些公用的功能,如跳过某一个结构不读、大小端数据格式调整、主机字节序和网络字节序的相互转换等。

1)首先定义纯虚函数:

virtual uint32_t writeMessageBegin_virt(const std::string& name,

                                  const TMessageType messageType,  const int32_t seqid) = 0;

  virtual uint32_t writeMessageEnd_virt() = 0;

  virtual uint32_t writeStructBegin_virt(const char* name) = 0;

  virtual uint32_t writeStructEnd_virt() = 0;

2)然后定义调用相应纯虚函数的函数:

 uint32_t writeMessageBegin(const std::string& name, const TMessageType messageType, const int32_t seqid) {

    T_VIRTUAL_CALL();//打印调用日志函数

    return writeMessageBegin_virt(name, messageType, seqid);

  }

  uint32_t writeMessageEnd() {

    T_VIRTUAL_CALL();

    return writeMessageEnd_virt();

  }

  uint32_t writeStructBegin(const char* name) {//写结构体开始

    T_VIRTUAL_CALL();

    return writeStructBegin_virt(name);

  }

  uint32_t writeStructEnd() {//写结构体结束

    T_VIRTUAL_CALL();

    return writeStructEnd_virt();

  }

3)其他公共函数

  uint32_t skip(TType type) {

    T_VIRTUAL_CALL();

    return skip_virt(type);//跳过数据类型

  }

  virtual uint32_t skip_virt(TType type) {

    return ::apache::thrift::protocol::skip(*this, type);// 调用此命名空间下全局函数实现

  }

4)全局数据结构定义

enum TType {//Thrift协议支持的数据类型枚举定义

  T_STOP       = 0,

  T_VOID       = 1,

  T_BOOL       = 2,

  T_BYTE       = 3,

  T_I08        = 3,

  T_I16        = 6,

  T_I32        = 8,

  T_U64        = 9,

  T_I64        = 10,

  T_DOUBLE     = 4,

  T_STRING     = 11,

  T_UTF7       = 11,

  T_STRUCT     = 12,

  T_MAP        = 13,

  T_SET        = 14,

  T_LIST       = 15,

  T_UTF8       = 16,

  T_UTF16      = 17

};

enum TMessageType {//thrift支持的消息类型

  T_CALL       = 1,

  T_REPLY      = 2,

  T_EXCEPTION  = 3,

  T_ONEWAY     = 4//函数的异步调用方式

};

还定义了一个对应抽象工厂类,用于上产具体的协议对象,这就是设计模式中最常用的抽象工厂设计模式。上面代码只是简单列举了两个写入的函数,还有其他很多相关数据类型的写入和读取函数因为都相同格式定义就没有具体拿出来说明了。

至于默认实现类TProtocolDefaults主要重写了抽象类TProtocol的非虚拟化的方法,这些方法都抛出一个方法为实现(TProtocolException::NOT_IMPLEMENTED)的异常。这样做的主要目的为了下面要讲到的类TVirtualProtocol提供默认的继承基类,从而防止无限递归调用。下面分析TVirtualProtocol类时具体分析如果没有这个默认实现类怎样产生无限递归调用。

虚协议类TVirtualProtocol

首先看看这个特殊的模板类是怎样定义的:

template <class Protocol_, class Super_=TProtocolDefaults>

class TVirtualProtocol : public Super_ { 

……//省略具体内容

}

说它特殊我觉得主要是基于两个方面:

1)继承的类可以通过模板参数传递,也就是说你现在没有办法肯定它现在带地继承什么类,只是默认参数值是我们上面介绍的抽象类的默认实现类。

2)类里面的方法实现全部是采用把this指针转换为第一个模板参数的类型然后调用模板参数类型的相关方法。如下面的一个方法的定义:

  virtual uint32_t writeMessageBegin_virt(const std::string& name,

                       const TMessageType messageType, const int32_t seqid) {

    return static_cast<Protocol_*>(this)->writeMessageBegin(name, messageType, seqid);

  }//实现抽象类的writeMessageBegin_virt方法

由上面两个特点可以发现这个类只是提供一个空的架构壳,继承的类可以指定,当然也可以采用默认的,后面分析具体协议实现的时候可以发现大多数协议也确实是采用默认的继承类,且大多数继承这个虚协议的类都是传递第一个参数为自身,也就是调用自己定义的相应函数。如TBinaryProtocolT类的定义,如下:

template <class Transport_>

class TBinaryProtocolT : public TVirtualProtocol< TBinaryProtocolT<Transport_> > {

…….

}

下面来分析如果不从定义的默认实现类继承,直接从抽象类继承怎样会产生无限递归调用。现在我们假设直接从抽象类继承,那么如果一个指向子类对象的父类(TProtocol)调用writeMessageBegin方法,因为这个方法不是虚拟函数(不会动态绑定)所以就会调用父类的writeMessageBegin方法,然后父类会直接调用它的纯虚函数writeMessageBegin_virt,这个函数就会动态绑定,就会执行子类的实现,在这里就是通过虚协议类TVirtualProtocol实现的,而这个函数又会调用之类的writeMessageBegin方法,如果子类没有实现这个方法,那么就又回到父类的这个方法了,从而产生无限递归调用。那么如果默认是从默认实现类TProtocolDefaults继承,那么就会执行它的writeMessageBegin方法,从而抛出一个异常,就不会产生无限递归调用。

具体协议类或实现自己的协议类

这个就是类继承架构的最后一部分,也就是实现具体的数据传输协议。例如二进制协议类定义如下:

template <class Transport_>

class TBinaryProtocolT : public TVirtualProtocol< TBinaryProtocolT<Transport_> > { …… }

那么这个二进制协议类就不用实现那些虚拟方法了。那些具体的协议实现方式后面详细介绍。

现在对这部分的类继承架构已经分析完毕,后面开始介绍Thrift中实现的几个比较重要的协议。



这篇关于Thrift之TProtocol类体系原理及源码详细解析之类继承架构分析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/810970

相关文章

Java集合中的List超详细讲解

《Java集合中的List超详细讲解》本文详细介绍了Java集合框架中的List接口,包括其在集合中的位置、继承体系、常用操作和代码示例,以及不同实现类(如ArrayList、LinkedList和V... 目录一,List的继承体系二,List的常用操作及代码示例1,创建List实例2,增加元素3,访问元

SpringBoot整合easy-es的详细过程

《SpringBoot整合easy-es的详细过程》本文介绍了EasyES,一个基于Elasticsearch的ORM框架,旨在简化开发流程并提高效率,EasyES支持SpringBoot框架,并提供... 目录一、easy-es简介二、实现基于Spring Boot框架的应用程序代码1.添加相关依赖2.添

Java调用DeepSeek API的最佳实践及详细代码示例

《Java调用DeepSeekAPI的最佳实践及详细代码示例》:本文主要介绍如何使用Java调用DeepSeekAPI,包括获取API密钥、添加HTTP客户端依赖、创建HTTP请求、处理响应、... 目录1. 获取API密钥2. 添加HTTP客户端依赖3. 创建HTTP请求4. 处理响应5. 错误处理6.

Spring AI集成DeepSeek的详细步骤

《SpringAI集成DeepSeek的详细步骤》DeepSeek作为一款卓越的国产AI模型,越来越多的公司考虑在自己的应用中集成,对于Java应用来说,我们可以借助SpringAI集成DeepSe... 目录DeepSeek 介绍Spring AI 是什么?1、环境准备2、构建项目2.1、pom依赖2.2

Springboot中分析SQL性能的两种方式详解

《Springboot中分析SQL性能的两种方式详解》文章介绍了SQL性能分析的两种方式:MyBatis-Plus性能分析插件和p6spy框架,MyBatis-Plus插件配置简单,适用于开发和测试环... 目录SQL性能分析的两种方式:功能介绍实现方式:实现步骤:SQL性能分析的两种方式:功能介绍记录

Goland debug失效详细解决步骤(合集)

《Golanddebug失效详细解决步骤(合集)》今天用Goland开发时,打断点,以debug方式运行,发现程序并没有断住,程序跳过了断点,直接运行结束,网上搜寻了大量文章,最后得以解决,特此在这... 目录Bug:Goland debug失效详细解决步骤【合集】情况一:Go或Goland架构不对情况二:

Python itertools中accumulate函数用法及使用运用详细讲解

《Pythonitertools中accumulate函数用法及使用运用详细讲解》:本文主要介绍Python的itertools库中的accumulate函数,该函数可以计算累积和或通过指定函数... 目录1.1前言:1.2定义:1.3衍生用法:1.3Leetcode的实际运用:总结 1.1前言:本文将详

Deepseek R1模型本地化部署+API接口调用详细教程(释放AI生产力)

《DeepseekR1模型本地化部署+API接口调用详细教程(释放AI生产力)》本文介绍了本地部署DeepSeekR1模型和通过API调用将其集成到VSCode中的过程,作者详细步骤展示了如何下载和... 目录前言一、deepseek R1模型与chatGPT o1系列模型对比二、本地部署步骤1.安装oll

最长公共子序列问题的深度分析与Java实现方式

《最长公共子序列问题的深度分析与Java实现方式》本文详细介绍了最长公共子序列(LCS)问题,包括其概念、暴力解法、动态规划解法,并提供了Java代码实现,暴力解法虽然简单,但在大数据处理中效率较低,... 目录最长公共子序列问题概述问题理解与示例分析暴力解法思路与示例代码动态规划解法DP 表的构建与意义动

Spring Boot整合log4j2日志配置的详细教程

《SpringBoot整合log4j2日志配置的详细教程》:本文主要介绍SpringBoot项目中整合Log4j2日志框架的步骤和配置,包括常用日志框架的比较、配置参数介绍、Log4j2配置详解... 目录前言一、常用日志框架二、配置参数介绍1. 日志级别2. 输出形式3. 日志格式3.1 PatternL