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服务器和客户端创建实例代码,希望对大家有所帮助