脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → java thrift 服务器和客户端

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

 更新时间：2017年04月01日 11:38:22   作者：小木工  
Thrift是一个软件框架，用来进行可扩展且跨语言的服务的开发。接下来通过本文给大家介绍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服务器和客户端创建实例代码，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持！

您可能感兴趣的文章:

相关文章

  • springboot aop添加日志方式

    springboot aop添加日志方式

    这篇文章主要介绍了springboot aop添加日志方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-05-05
  • springboot项目数据库密码如何加密

    springboot项目数据库密码如何加密

    在我们日常开发中，我们可能很随意把数据库密码直接明文暴露在配置文件中，今天就来聊聊在springboot项目中如何对数据库密码进行加密，感兴趣的可以了解一下
    2021-07-07
  • 浅谈MyBatis执行SQL的两种方式

    浅谈MyBatis执行SQL的两种方式

    本文介绍MyBatis执行SQL语句的2种方式，主要是SqlSession和Mapper接口以及它们的区别，具有一定的参考价值，感兴趣的可以了解一下
    2021-08-08
  • 由浅入深快速掌握Java 数组的使用

    由浅入深快速掌握Java 数组的使用

    Java 数组 数组对于每一门编程语言来说都是重要的数据结构之一,当然不同语言对数组的实现及处理也不尽相同。 Java 语言中提供的数组是用来存储固定大小的同类型元素
    2022-04-04
  • SpringCloud让微服务实现指定程序调用

    SpringCloud让微服务实现指定程序调用

    这篇文章主要介绍了SpringCloud让微服务实现指定程序调用,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-06-06
  • SpringBoot利用切面注解及反射实现事件监听功能

    SpringBoot利用切面注解及反射实现事件监听功能

    这篇文章主要介绍了springboot事件监听，通过利用切面、注解、反射实现，接下来将对这几种方式逐一说明，具有很好的参考价值，希望对大家有所帮助
    2022-07-07
  • springboot集成swagger3与knife4j的详细代码

    springboot集成swagger3与knife4j的详细代码

    这篇文章主要介绍了springboot集成swagger3与knife4j，本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-08-08
  • 启用Spring事务管理@EnableTransactionManagement示例解析

    启用Spring事务管理@EnableTransactionManagement示例解析

    这篇文章主要为大家介绍了启用Spring事务管理@EnableTransactionManagement示例解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-09-09
  • SpringCloud的Eureka模块详解

    SpringCloud的Eureka模块详解

    这篇文章主要介绍了SpringCloud的Eureka模块详解,Spring Cloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务治理,就是提供了微服务架构中各微服务实例的快速上线或下线且保持各服务能正常通信的能力的方案总称,需要的朋友可以参考下
    2023-07-07
  • Java获取汉字拼音的全拼和首拼实现代码分享

    Java获取汉字拼音的全拼和首拼实现代码分享

    这篇文章主要介绍了Java获取汉字拼音的全拼和首拼实现代码分享,本文直接给出实现代码,需要的朋友可以参考下
    2015-06-06

最新评论