初探 thrift

简介: 初探 thrift

什么是thrift?

thrift是一个软件框架,用来进行可扩展且跨语言的服务的开发。它结合了功能强大的软件堆栈和代码生成引擎,以构建在 C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, and OCaml 这些编程语言间无缝结合的、高效的服务。

thrift介绍

thrift只构建系统中的RPC层。

img


安装thrift

在mac下安装thrift,只需要执行

    brew install thrift

如何使用

建立一个后缀为.thrift的文件,用于让thrift代码引擎知道你需要生成哪些服务、错误类型以及rpc接口等。
这里我们先创建一个test.thrift,内容如下。

/**
 * 错误类型
 */
enum AirExceptionType {
    PASSWD_EXCEPTION = 0;
    
    USER_DIONLINE = 1;
}

/**
 * 调用错误
 */
exception AirException {
    /** 错误类型 */
    1: required AirExceptionType type;

    /** 错误码 */
    2: required i64 errorCode;

    /** 错误消息 */
    3: required string errorMessage;

    /** 调试信息 */
    4: required string debugMessage;
}

/*一个thrift的服务,里面包含一些rpc接口*/
service thriftTest {
        /**
     * 连接服务器,返回Session
     */
     string connectServer (
        /** 设备编码(加密) */
        1: string strDevCode;    

    ) throws (
        /** 抛出异常 */
        1: AirException ex;
    );

    /**
     * 与服务器断开连接
     */
     void disconnectServer (
        /** 用户Session */
        1: string Session;    

    ) throws (
        /** 抛出异常 */
        1: AirException ex;
    );
    
    
    /**
     * 保活
     */
     void keepAlive (
        /** 用户Session */
        1: string Session;    

    ) throws (
        /** 抛出异常 */
        1: AirException ex;
    );

    /**
     * 输入密码
     */
    void inputPasswd (
        /** 用户Session */
        1: string Session;

        /** 锁类型 */
        2: i32 iLockType;
        
        /** 密码 */
        3: string strPassword;

    ) throws (
        /** 抛出异常 */
        1: AirException ex;
    );
}

接着我们执行thrift语句,比如我们需要生成一个cpp的代码。

    thrift -gen cpp test.thrift

这时候我们可以发现,在同级目录下已经出现了一个gen-cpp的文件夹。

    ranmodeMacBook-Pro:thriftDemo ranmo$ thrift -gen cpp test.thrift
    ranmodeMacBook-Pro:thriftDemo ranmo$ ls
    gen-cpp        test.thrift

文件夹里是一些自动生成的.cpp文件以及.h头文件。

    ranmodeMacBook-Pro:thriftDemo ranmo$ cd gen-cpp/
    ranmodeMacBook-Pro:gen-cpp ranmo$ ls
    test_constants.cpp        test_types.cpp            thriftTest.cpp            thriftTest_server.skeleton.cpp
    test_constants.h        test_types.h            thriftTest.h
    ranmodeMacBook-Pro:gen-cpp ranmo$

同样,如果是c#语言,只需要执行

    thrift -gen csharp test.thrift

下面以C#语言为例,来说一下这些文件的作用以及如何使用这些产生的文件。


产生的文件

可以看到运行命令以后产生了三个.cs文件

    ranmodeMacBook-Pro:gen-csharp ranmo$ ls
    AirException.cs        AirExceptionType.cs    thriftTest.cs

AirException.cs是抛出错误的文件
AirExceptionType.cs是定义错误类型的文件
thriftTest.cs是一个类,里面提供了一个interface Iface用来作为服务端的基类,继承后实现其接口作为RPC接口。class Client是一个客户端类,用来创建客户端调用服务端接口的实例。


服务端

首先导入thrift相关模块

    /*Thrift相关*/
    using Thrift.Collections;
    using Thrift.Protocol;
    using Thrift.Server;
    using Thrift.Transport;

    /*线程相关*/
    using System.Threading;

    /*IO相关*/
    using System.IO.Ports;

初始化thrift服务端

    const int THRIFT_MAIN_SERVER_PORT = 7911;//thrift服务端口号   

    TServerSocket serverTransport = new TServerSocket(THRIFT_MAIN_SERVER_PORT, 0, false);
    passwordLock.Processor processor = new passwordLock.Processor(new CThrift());
    //TServer server = new TSimpleServer(processor, serverTransport);
    TThreadedServer server = new TThreadedServer(processor, serverTransport);//使用多线程方法启动thrift服务

    /*thrift服务启动*/
    server.Serve();

注意,这边开启thrift进程的时候,传入了一个CThrift的实例,这个实例就是具体的服务端接口实现。将基类中的相关方法继承并且实现,形成RPC接口。

    /*Thrift实现类*/
        public class CThrift : passwordLock.Iface
        {

            public CThrift()
            {
                //...实现
            }

            //...继承后rpc接口实现
        }

客户端

客户端需要用到thrift文件中的一个client类,用它创建实例来完成接口调用工作。

    TTransport transport = new TSocket(strIP, iPort);
    TProtocol Potocol = new TBinaryProtocol(transport);
    passwordLock.Client client = new passwordLock.Client(Potocol);
    transport.Open();

初始化好客户端段client实例后,就可以直接用这个实例的方法来调用服务端的接口了。

    client.connectServer("devCode");

Demo

这是我写的一个Demo,希望可以给你带来帮助。

目录
相关文章
|
缓存 网络协议 安全
计算机网络 TCP、RPC、GRPC、HTTP 对比
【1月更文挑战第1天】计算机网络 TCP、RPC、GRPC、HTTP 对比
|
Cloud Native Devops 持续交付
构建未来:云原生技术在企业数字化转型中的关键作用
【5月更文挑战第30天】 随着企业加速其数字化转型的步伐,云原生技术已成为推动创新和维持竞争力的重要驱动力。本文探讨了云原生技术的核心组件,包括容器化、微服务架构、持续集成/持续部署(CI/CD)、以及DevOps实践,并分析了它们如何共同促进敏捷性、可扩展性和可靠性。我们深入讨论了这些技术如何帮助企业实现快速迭代,优化资源使用,以及提高服务质量,同时降低运营成本。通过案例研究和行业趋势分析,本文揭示了云原生技术在未来企业IT战略中的关键地位,并为采纳这些技术的决策者提供了见解。
|
11月前
|
存储 Serverless API
打造你的专属语音助手,基于函数计算托管 CosyVoice 语音模型
今天分享一下,基于阿里云函数计算 FC 以及 CAP(云应用开发平台),极速托管专属的 CosyVoice 应用。并且我们提供了 API 调用方案以及镜像构建源码方便您根据自己的业务任意 DIY。
961 11
|
11月前
|
存储 自然语言处理 搜索推荐
大模型 Agent 概述
大模型Agent是基于大型预训练模型构建的智能体,具有强大的语言理解和生成能力,能完成多任务处理。其记忆功能包括短期记忆和长期记忆,支持上下文保持、知识积累、计划决策及内容创作,广泛应用于自然语言处理、问答系统、信息检索、辅助决策、教育、创意应用和客服等领域。
1145 0
|
Java API 计算机视觉
图像处理之添加高斯与泊松噪声
图像处理之添加高斯与泊松噪声
240 1
|
数据采集 API 开发者
🚀告别网络爬虫小白!urllib与requests联手,Python网络请求实战全攻略
【7月更文挑战第29天】在广阔的网络世界里,Python以其简洁的语法和强大的库支持成为网络爬虫开发的首选。本文聚焦于两大网络请求库——urllib和requests。urllib是Python内置库,虽API稍显复杂,却有助于理解HTTP本质。示例代码展示了如何使用`urlopen`函数发起GET请求并读取网页内容。相比之下,requests库则更加人性化,极大地简化了HTTP请求流程,使开发者能更专注于业务逻辑。
115 1
|
负载均衡 Java 应用服务中间件
springcloud3-服务到服务调用ribbon及openfeign
springcloud3-服务到服务调用ribbon及openfeign
173 0
|
SQL 监控 前端开发
Springboot过滤器和拦截器详解及使用场景
过滤器和拦截器触发时机不一样,过滤器是在请求进入容器后,但请求进入servlet之前进行预处理的。请求结束返回也是,是在servlet处理完后,返回给前端之前。