服务器之家

服务器之家 > 正文

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

时间:2020-09-05 11:11     来源/作者:小木工

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

?
1
2
3
service helloworldservice{
string sayhello(1:string username)
}

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

?
1
thrift.exe -gen java helloworld.thrift

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

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
<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>项目的结构图当前如下所示:

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

file--project structure--modules,在main文件夹下新建java文件夹并设为soueces类型(因为在sources文件下可以新建java class文件)

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

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

<5>实现接口iface

java代码:helloworldimpl.java

?
1
2
3
4
5
6
7
8
9
10
11
12
13
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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
/**
 * 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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
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服务器和客户端创建实例代码,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对服务器之家网站的支持!

原文链接:http://www.cnblogs.com/zfygiser/archive/2017/04/01/6651645.html

相关文章

热门资讯

2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
Intellij idea2020永久破解,亲测可用!!!
Intellij idea2020永久破解,亲测可用!!! 2020-07-29
歪歪漫画vip账号共享2020_yy漫画免费账号密码共享
歪歪漫画vip账号共享2020_yy漫画免费账号密码共享 2020-04-07
最新idea2020注册码永久激活(激活到2100年)
最新idea2020注册码永久激活(激活到2100年) 2020-07-29
电视剧《琉璃》全集在线观看 琉璃美人煞1-59集免费观看地址
电视剧《琉璃》全集在线观看 琉璃美人煞1-59集免费观看地址 2020-08-12
返回顶部