Java thrift服务器和客户端创建实例代码
作者:小木工 时间:2022-01-23 04:38:29
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服务器和客户端创建实例代码网站的支持!
来源:http://www.cnblogs.com/zfygiser/archive/2017/04/01/6651645.html
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
JAVA基本概念详解
![](https://img.aspxhome.com/file/2023/6/70996_0s.jpg)
java实现打砖块游戏算法
利用Lambda表达式创建新线程案例
JAVA 枚举单例模式及源码分析的实例详解
IDEA中创建maven项目引入相关依赖无法下载jar问题及解决方案
![](https://img.aspxhome.com/file/2023/5/88505_0s.png)
ASP.NET C#中Application的用法教程
同步调用和异步调用WebService
![](https://img.aspxhome.com/file/2023/7/82177_0s.png)
Java扑克牌速算24的方法
java中TreeMap排序的示例代码
浅析Spring Security登录验证流程源码
![](https://img.aspxhome.com/file/2023/7/72287_0s.jpg)
SpringBoot 如何从容器中获取对象
![](https://img.aspxhome.com/file/2023/5/75775_0s.png)
Java探索之Thread+IO文件的加密解密代码实例
Java设计模式之java装饰者模式详解
![](https://img.aspxhome.com/file/2023/6/68726_0s.png)
详解Spark Sql在UDF中如何引用外部数据
![](https://img.aspxhome.com/file/2023/4/64124_0s.jpg)
Java BIO,NIO,AIO总结
![](https://img.aspxhome.com/file/2023/1/61551_0s.png)
如何使用BufferedReader循环读文件
![](https://img.aspxhome.com/file/2023/4/84174_0s.png)
浅析java 归并排序算法
![](https://img.aspxhome.com/file/2023/4/80944_0s.png)
Java8 HashMap键与Comparable接口小结
![](https://img.aspxhome.com/file/2023/3/60563_0s.jpg)
Java中实现双数组Trie树实例
IDEA中打jar包的2种方式(Maven打jar包)
![](https://img.aspxhome.com/file/2023/2/75502_0s.png)