Thrift文件与编程语言无关,用于定义数据类型和服务接口,然后生成用来构建RPC客户和服务器所需的全部代码。
- #!/usr/local/bin/thrift --gen java
- namespace java Test
- service Something {
- i32 ping()
- }
在linux命令行下输入:Thrift –gen javatestJava.thrift
生成的源文件在./gen-java/目录下。
进入./gen-java目录,确保系统的CLASSPATH设置正确。libthrift.jar,,slf4j-api和slf4j-simple这几个包都需要包含在CLASSPATH里。
- package Test;
- import org.apache.thrift.TException;
- class SomethingImpl implements Something.Iface {
- public SomethingImpl() {}
- public int ping() throws TException {
- System.out.println( "Recieve ping from client..." );
- return 0;
- }
- }
- package Test;
- import java.io.IOException;
- import org.apache.thrift.protocol.TBinaryProtocol;
- import org.apache.thrift.protocol.TBinaryProtocol.Factory;
- import org.apache.thrift.server.TServer;
- import org.apache.thrift.server.TThreadPoolServer;
- import org.apache.thrift.transport.TServerSocket;
- import org.apache.thrift.transport.TTransportException;
- public class Server {
- private voidstart() {
- try {
- TServerSocket serverTransport = new TServerSocket(7911);
- Something.Processor processor = new Something.Processor(newSomethingImpl());
- Factory protFactory = new TBinaryProtocol.Factory(true, true);
- TServer server = new TThreadPoolServer(processor, serverTransport,protFactory);
- System.out.println("Starting server on port 7911 ...");
- server.serve();
- } catch (TTransportException e) {
- e.printStackTrace();
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- public static void main(String args[]){
- Server srv = new Server();
- srv.start();
- }
- }
创建Client.java
- package Test;
- import java.io.IOException;
- import org.apache.thrift.*;
- import org.apache.thrift.protocol.*;
- import org.apache.thrift.transport.*;
- public class Client {
- public static void main(String [] args) {
- try {
- TTransport transport = newTSocket("localhost", 7911);
- TProtocol protocol = newTBinaryProtocol(transport);
- Something.Client client =new Something.Client(protocol);
- transport.open();
- System.out.println("Client calls ping()");
- client.ping();
- transport.close();
- } catch (TException x) {
- x.printStackTrace();
- }
- }
- }
在linux命令行下输入:javac *.java,生成客户端与服务器端的class文件。
首先启动服务器。退到gen-java目录,输入java Test/Server,屏幕显示如下:
Starting server on port 7911 ...
然后启动客户端。在同一目录下输入java Test/Client,屏幕显示如下:
Client calls ping()
这时服务器端的输出多了一行:
Recieve ping from client...
相关推荐
thrift 示例项目,server端基于Java实现,client端基于Nodejs实现,与台州微信银行保持一样的通讯方式RPC: 远程过程调用,需要解决的问题: 通讯,序列化等项目结构thriftshared.thrift, tutorial.thrift 为thrift...
thrift,包括zip及其对应版本的exe.一般情况下的跨机器的通信框架都是跨软件平台的(Linux...如果编写一个服务器端程序,定义好通讯规则(在Thrift中是.thrift文件)后,以后使用的人可以采用其他编程语言来实现客户端。
thrift示例程序,服务器端用java,客户端用php
简单的节俭教程创建一个定义服务的.thrift文件thrift --gen java multiplication.thrift-这将创建用Java开发服务器和客户端所需的文件thrift --gen py multiplication.thrift-在python中创建服务器和客户端开发所需...
使用 Hadoop UserGroupInformation 通过 Thrift RPC ... 这有助于我们验证我们在服务器端是否有有效的凭据来执行请求的操作(如果我们向它发送一些格式错误/不正确的东西,依赖于 HDFS 会失败)。 建造 一个简单的mvn p
7_Netty的Socket编程详解 8_Netty多客户端连接与通信 9_Netty读写检测机制与长连接要素 10_Netty对WebSocket的支援 11_Netty实现服务器端与客户端的长连接通信 12_Google Protobuf详解 13_定义Protobuf文件及消息...
11_Netty实现服务器端与客户端的长连接通信 12_Google Protobuf详解 13_定义Protobuf文件及消息详解 14_Protobuf完整实例详解 15_Protobuf集成Netty与多协议消息传递 16_Protobuf多协议消息支援与工程最佳实践 17_...
11_Netty实现服务器端与客户端的长连接通信;12_Google Protobuf详解;13_定义Protobuf文件及消息详解;14_Protobuf完整实例详解;15_Protobuf集成Netty与多协议消息传递;16_Protobuf多协议消息支援与工程最佳实践...
第11讲:Netty实现服务器端与客户端的长连接通信 第12讲:Google Protobuf详解 第13讲:定义Protobuf文件及消息详解 第14讲:Protobuf完整实例详解 第15讲:Protobuf集成Netty与多协议消息传递 第16讲:...
cocolian-rpc-service: 服务器端和客户端共用的一些服务,比如zookeeper注册参数对象、一些共用的thrift对象等。cocolian-rpc-docker:运行rpc服务器的docker 镜像。二、cocolian-rpc-server使用Apache Thrift 作为...