溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
使用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");
}
}客戶端測試成功，截圖如下：
看完上述內容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業資訊頻道，感謝您對億速云的支持。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
