一步步学会Thrift服务搭建和调用

简介: <p><span style="font-size:14px"><span style="white-space:pre"></span></span></p> <p align="left">       Thrift是什么,有什么优势?这里就不阐述了,百度即可。本文旨在于展现Thrift服务搭建和调用的过程,让初学者少走弯路。本文提供完整代码及所需jar和thrift-0.9.3.e

       Thrift是什么,有什么优势?这里就不阐述了,百度即可。本文旨在于展现Thrift服务搭建和调用的过程,让初学者少走弯路。本文提供完整代码及所需jar和thrift-0.9.3.exe。点击此处下载完整工程:https://github.com/zxiaofan/OpenSource_Study/tree/master/Thrift

先来张目录结构图

1、下载所需jar和thrift-0.9.3.exe

              下载地址:thrift-0.9.3.exeThrift开发所需jar

2、解压thrift-0.9.3.exe到本地目录(如:E:\Thrift ),建议全英文目录,并修改名字为thrift.exe(方便敲命令)。

 

3、添加thrift.exe目录到系统环境变量

       在系统变量path后添加“ ;E:\Thrift ”,注意分号哦。

 

4、下载ThriftTest.thrift 到thrift.exe目录点击下载

  这里提供了现成的Thrift文件,相关的编写方法,网络很多,就不赘述。亦可参照我收集的(点击访问我的个人有道云笔记)。

5、CMD定位到E:\Thrift ,执行命令

 cd /d E:\Thrift

      即可。

 

6、生成java文件

      接着在命令行输入:

thrift.exe -r -genjava ./ThriftTest.thrift

,此时会在thrift.exe目录生成gen-java文件夹,里面的就是我们所需的ThriftHelloWorld.java文件了。

 

7、接下来就是编写服务端了。

      ①首先实现我们的接口,注意要实现Iface接口哦。

package service;

import thrift.ThriftHelloWorld.Iface;
/**
 * 服务端实现类
 *
 */
public classHelloServiceImpl implements Iface {
    public String sayHello(String username) {
        return "hello " + username;
    }
 
    public String getRandom() {
        return "random";
    }
}

      ②在src目录下新建thrift包,将先前生成的ThriftHelloWorld.java拷贝进去;

      ③新建startServer用于启动服务,

package service;
 
import org.apache.thrift.protocol.TBinaryProtocol.Factory;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.server.TThreadPoolServer.Args;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TTransportException;
 
import thrift.ThriftHelloWorld;
import thrift.ThriftHelloWorld.Processor;
 
/**
 * 启动服务
 *
 */
public classStartServer {
    /**
     * 启动Thrift服务器
     */
    public void startServer() {
 
        try {
            // 定义传输的socket,设置服务端口为6789
            TServerSocket serverTransport = newTServerSocket(6789);
 
            // 设置协议工厂为 TBinaryProtocol.Factory
            Factory proFactory = newFactory(true, true);
 
            // 关联处理器与 Hello服务的实现
            ThriftHelloWorld.Processorprocessor = new Processor(new HelloServiceImpl());
 
            // 定义服务端的参数值
            Args args = newArgs(serverTransport);
            args.processor(processor);
            args.protocolFactory(proFactory);
            TServer server = newTThreadPoolServer(args);
 
            // 服务端开启服务s
            server.serve();
        } catch (TTransportException e) {
            e.printStackTrace();
        }
    }
 
    public static void main(String[] args) {
        System.out.println("ServerStart!");
        StartServer server = new StartServer();
        server.startServer();
    }
}

服务端就此完成,启动main函数,控制台输出Server Start!。

发布的时候只需将此工程导出为可执行jar或将工程稍作修改用tomcat发布。


8、编写客户端,完成服务调用

      ①同样在src目录下新建thrift包,将先前生成的ThriftHelloWorld.java拷贝进去;

      ②创建ClientTest类用于调用服务

package client;
 
import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;
import org.junit.Test;
 
import thrift.ThriftHelloWorld;
 
/**
 * 客户端实现
 *
 */
public classClientTest {
    /**
     * 调用Hello服务
     */
    @Test
    public void startClient() {
        try {
 
            // 设置调用的服务地址为本地,端口为6789
            TTransport transport = newTSocket("localhost", 6789);
            transport.open();
            // 数据传输协议有:二进制协议、压缩协议、JSON格式协议
            // 这里使用的是二进制协议
            // 协议要和服务端一致
            TProtocol protocol = new TBinaryProtocol(transport);
            ThriftHelloWorld.Client client =new ThriftHelloWorld.Client(protocol);
            // 调用服务器端的服务方法
           System.out.println(client.sayHello("zxiaofan"));
            // 关闭
            transport.close();
        } catch (TTransportException e) {
            e.printStackTrace();
        } catch (TException e) {
            e.printStackTrace();
        }
    }
}

启动startClient,控制台输出hello zxiaofan,至此客户端完成。

 



 

 

 


目录
相关文章
|
9月前
|
前端开发 Java Apache
Apache Zeppelin系列教程第七篇——运行paragraph的整个流程分析
Apache Zeppelin系列教程第七篇——运行paragraph的整个流程分析
99 0
|
9月前
|
Web App开发 前端开发 Java
Apache Zeppelin系列教程第二篇——整体架构
Apache Zeppelin系列教程第二篇——整体架构
198 0
|
9月前
|
Java 数据库连接 Shell
Apache Zeppelin系列教程第六篇——Zengine调用Interpreter原理分析
Apache Zeppelin系列教程第六篇——Zengine调用Interpreter原理分析
144 0
|
8月前
|
Java Serverless 应用服务中间件
Serverless 应用引擎操作报错合集之部署python项目时,构建过程报错,怎么解决
Serverless 应用引擎(SAE)是阿里云提供的Serverless PaaS平台,支持Spring Cloud、Dubbo、HSF等主流微服务框架,简化应用的部署、运维和弹性伸缩。在使用SAE过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
设计模式 SQL 开发框架
学PHP语言如何进阶?具体步骤是怎样的?底层原理是什么?
学PHP语言如何进阶?具体步骤是怎样的?底层原理是什么?
116 0
|
分布式计算 Hadoop
Hadoop快速入门——第二章、分布式集群(第四节、搭建开发环境)(1)
Hadoop快速入门——第二章、分布式集群(第四节、搭建开发环境)
111 0
Hadoop快速入门——第二章、分布式集群(第四节、搭建开发环境)(1)
|
存储 分布式计算 Hadoop
Hadoop快速入门——第二章、分布式集群(第四节、搭建开发环境)(2)
Hadoop快速入门——第二章、分布式集群(第四节、搭建开发环境)
137 0
Hadoop快速入门——第二章、分布式集群(第四节、搭建开发环境)(2)
|
安全 Java Linux
手把手教你搭个Frida + Sekiro Rpc框架
手把手教你搭个Frida + Sekiro Rpc框架
手把手教你搭个Frida + Sekiro Rpc框架
|
编译器 Apache
Thrift架构与使用方法
Thrift架构与使用方法
275 0
Thrift架构与使用方法
|
PHP
【laravel】第一节 访问流程
【laravel】第一节 访问流程
232 0
【laravel】第一节 访问流程