Java thrift伺服器和客戶端建立例項
阿新 • • 發佈:2018-11-12
首先環境介紹一下:
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
1 package com.jmust.thrift.demo; 2 3 import org.apache.thrift.TException; 4 5 /** 6 * Created by Administrator on 2017/3/31. 7 */ 8 public class HelloWorldImpl implements HelloWorldService.Iface { 9 10 public HelloWorldImpl() { 11 } 12 13 @Override 14 public String sayHello(String username) throws TException { 15 return "Hi,"+username+"Welcome to my blog http://www.cnblogs.com/zfygiser"; 16 } 17 }
<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"); } }
客戶端測試成功,截圖如下: