Java thrift服务器和客户端创建实例代码

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

Thrift最初由facebook开发，07年四月开放源码，08年5月进入apache孵化器。thrift允许你定义一个简单的定义文件中的数据类型和服务接口。以作为输入文件，编译器生成代码用来方便地生成RPC客户端和服务器通信的无缝跨编程语言。

首先环境介绍一下：

1.IntelliJ IDEA 2017.1

2.thrift-0.9.3

相信大家在看我这篇文章的时候已经对thrift通信框架已有所调研，这里就不再赘述了，直接进入正题：

<1>创建HelloWorld.thrift

namespace java com.thrift.demo

service HelloWorldService{
string sayHello(1:string username)
}

 <2>利用thrift生成HelloWorld.java文件，cmd指令下进入thrift当前目录下输入命令

thrift.exe -gen java HelloWorld.thrift

java为要生成文件的类型,HelloWorld.thrift为前面的文件。

<3>创建IDEA 下的maven项目，其中的好处就不一一说明了，最重要的一条就是可以在pom.xml文件中添加dependency，能够在项目中自行下载库文件，方便协同开发中出现的开发包不对应的情况。

<dependency>
      <groupId>javax.servlet</groupId>
      <artifactId>javax.servlet-api</artifactId>
      <version>3.1.0</version>
    </dependency>
    <dependency>
      <groupId>jstl</groupId>
      <artifactId>jstl</artifactId>
      <version>1.2</version>
    </dependency>
    <dependency>
      <groupId>org.apache.thrift</groupId>
      <artifactId>libthrift</artifactId>
      <version>0.9.3</version>
    </dependency>
    <dependency>
      <groupId>org.slf4j</groupId>
      <artifactId>slf4j-log4j12</artifactId>
      <version>1.7.5</version>
    </dependency>

上述pom引入相应的依赖项就可以让它自行下载。

<4>项目的结构图当前如下所示：

File--Project Structure--Modules，在main文件夹下新建java文件夹并设为Soueces类型（因为在Sources文件下可以新建java class文件）

同时将thrift生成的HelloWorld.java文件复制到该目录下

<5>实现接口Iface

java代码：HelloWorldImpl.java

package com.jmust.thrift.demo;
import org.apache.thrift.TException;
/**
 * Created by Administrator on 2017/3/31.
 */
public class HelloWorldImpl implements HelloWorldService.Iface {
  public HelloWorldImpl() {
  }
  @Override
  public String sayHello(String username) throws TException {
    return "Hi,"+username+"Welcome to my blog http://www.cnblogs.com/zfygiser";
  }
}

<6>服务端TSimpleServer

java代码：HelloServer.java

/**
 * Created by Administrator on 2017/3/31.
 */
package com.jmust.thrift.demo;
import org.apache.thrift.TProcessor;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TSimpleServer;
import org.apache.thrift.transport.TServerSocket;
public class HelloServer {
  public final static int SERVER_PORT = 7099;
  private static String SERVER_IP = "localhost";
  public void startServer() {
    try {
      System.out.println("HelloWorld Server start...");
      TServerSocket serverTransport = new TServerSocket(SERVER_PORT);
      TServer.Args args = new TServer.Args(serverTransport);
      TProcessor process = new HelloWorldService.Processor(new HelloWorldImpl());
      TBinaryProtocol.Factory portFactory = new TBinaryProtocol.Factory(true, true);
      args.processor(process);
      args.protocolFactory(portFactory);
      TServer server = new TSimpleServer(args);
      server.serve();
    } catch (Exception e) {
      System.out.println("Server start error");
      e.printStackTrace();
    }
  }
  public static void main(String[] args) {
    HelloServer server = new HelloServer();
    server.startServer();
  }
}

<7>编写客户端代码

java代码：Client.java

package com.jmust.thrift.demo;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
/**
 * Created by Administrator on 2017/4/1.
 */
public class Client {
  public static final int SERVER_PORT = 7099;
  public static final String SERVER_IP = "localhost";
  public void startClient(String username) {
    TTransport tTransport = null;
    try {
      tTransport = new TSocket(SERVER_IP, SERVER_PORT);
      //协议要和服务端一致
      TProtocol protocol = new TBinaryProtocol(tTransport);
      HelloWorldService.Client client = new HelloWorldService.Client(protocol);
      tTransport.open();
      String result = client.sayHello(username);
      System.out.println("Thrift client result=" + result);
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
  public static void main(String[] args) {
    Client client = new Client();
    client.startClient("zfy");
  }
}

客户端测试成功，截图如下：

以上所述是小编给大家介绍的Java thrift服务器和客户端创建实例代码，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对网站的支持！

# java  # thrift  # 服务器和客户端  # 客户端  # Vue+Java 通过websocket实现服务器与客户端双向通信操作  # Java利用TCP协议实现客户端与服务器通信(附通信源码)  # Java实现UDP通信过程实例分析【服务器端与客户端】  # java UDP通信客户端与服务器端实例分析  # java Tcp通信客户端与服务器端实例  # java模拟TCP通信实现客户端上传文件到服务器端  # java模拟客户端向服务器上传文件  # java实现客户端向服务器发送文件  # Java实现文件上传服务器和客户端  # java实现上传文件到服务器和客户端  # Java Socket编程服务器响应客户端实例代码  # java多线程实现服务器端与多客户端之间的通信  # 教你怎么用java实现客户端与服务器一问一答  # 小编  # 服务端  # 编程语言  # 是一个  # 目录下  # 在此  # 结构图  # 最重要  # 设为  # 给大家  # 看我  # 所示  # 让它  # 这篇文章  # 说明了  # 介绍一下  # 所述  # 给我留言  # 直接进入 

相关文章： 在线制作视频网站免费,都有哪些好的动漫网站？  如何通过可视化优化提升建站效果？  如何彻底卸载建站之星软件？  武汉网站设计制作公司,武汉有哪些比较大的同城网站或论坛，就是里面都是武汉人的？  企业在线网站设计制作流程,想建设一个属于自己的企业网站，该如何去做？  css网站制作参考文献有哪些,易聊怎么注册？  定制建站流程步骤详解：一站式方案设计与开发指南  如何在阿里云部署织梦网站？  哈尔滨网站建设策划,哈尔滨电工证查询网站？  大连网站设计制作招聘信息,大连投诉网站有哪些？  如何用5美元大硬盘VPS安全高效搭建个人网站？  网站图片在线制作软件,怎么在图片上做链接？  如何在万网开始建站？分步指南解析  c# Task.ConfigureAwait(true) 在什么场景下是必须的  微信网站制作公司有哪些,民生银行办理公司开户怎么在微信网页上查询进度？  香港服务器建站指南：外贸独立站搭建与跨境电商配置流程  php8.4新语法match怎么用_php8.4match表达式替代switch【方法】  javascript基本数据类型及类型检测常用方法小结  油猴 教程,油猴搜脚本为什么会网页无法显示？  如何通过商城自助建站源码实现零基础高效建站？  高端云建站费用究竟需要多少预算？  c++怎么用jemalloc c++替换默认内存分配器【性能】  建站上传速度慢？如何优化加速网站加载效率？  成都网站制作公司哪家好,四川省职工服务网是做什么用？  我的世界制作壁纸网站下载,手机怎么换我的世界壁纸？  宝塔新建站点为何无法访问？如何排查？  如何快速搭建FTP站点实现文件共享？  网站制作员失业,怎样查看自己网站的注册者？  建站之星收费标准详解：套餐费用及年费价格表一览  学校为何禁止电信移动建设网站？  合肥制作网站的公司有哪些,合肥聚美网络科技有限公司介绍？  c++23 std::expected怎么用 c++优雅处理函数错误返回【详解】  浅析上传头像示例及其注意事项  制作充值网站的软件,做人力招聘为什么要自己交端口钱？  如何做网站制作流程,*游戏网站怎么搭建？  建站主机选哪家性价比最高？  ,网站推广常用方法？  网站制作的步骤包括,正确网址格式怎么写？  建站之星3.0如何解决常见操作问题？  微课制作网站有哪些,微课网怎么进？  C++用Dijkstra(迪杰斯特拉)算法求最短路径  电商网站制作公司有哪些,1688网是什么意思？  网站建设制作、微信公众号,公明人民医院怎么在网上预约？  h5在线制作网站电脑版下载,h5网页制作软件？  小型网站制作HTML,*游戏网站怎么搭建？  c# await 一个已经完成的Task会发生什么  北京制作网站的公司,北京铁路集团官方网站？  如何通过cPanel快速搭建网站？  建站主机选购指南与交易推荐：核心配置解析  如何快速搭建二级域名独立网站？