Thrift下java服务器与客户端开发指南.doc

THRIFTJava服务器及客户端开发指南文档编号BUPT-BNRC-CNGI-201005071333-UsageManual文档级别公共文档状态 草稿 讨论稿 正式发布文档作者张晴文档版本1.0创建日期2010-10-17 16:33修改日期2010-10-17 17:23文档所属：THRIFT文档名称：JAVA服务器与客户端开发指南修订历史记录日期版本说明作者2010-05-071.0用Thrift开发Java服务器及客户端程序张晴相关联系人姓名电子邮件电话角色正文目录1 创建THRIFT文件41.1 编写testJava.thrift41.2 运行thrift编译器，生成项目源文件42 创建JAVA服务器52.1 编写SomethingImpl.java52.2 创建Server.java53 创建JAVA客户端74 编译及运行84.1 编译84.2 运行81 创建Thrift文件Thrift文件与编程语言无关，用于定义数据类型和服务接口，然后生成用来构建RPC客户和服务器所需的全部代码。1.1 编写testJava.thrift#!/usr/local/bin/thrift -gen javanamespace java Testservice Something i32 ping()1.2 运行thrift编译器，生成项目源文件在linux命令行下输入：Thrift gen java testJava.thrift生成的源文件在./gen-java/目录下。2 创建Java服务器进入./gen-java目录，确保系统的CLASSPATH设置正确。libthrift.jar,，slf4j-api和slf4j-simple这几个包都需要包含在CLASSPATH里。2.1 编写SomethingImpl.javapackage 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;2.2 创建Server.javapackage Test;import java.io.IOException;import tocol.TBinaryProtocol;import tocol.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 void start() try TServerSocket serverTransport = new TServerSocket(7911); Something.Processor processor = new Something.Processor(new SomethingImpl(); 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(); 3 创建Java客户端创建Client.javapackage Test;import java.io.IOException;import org.apache.thrift.*;import tocol.*;import org.apache.thrift.transport.*;public class Client public static void main(String args) try TTransport transport = new TSocket(localhost, 7911); TProtocol protocol = new TBinaryProtocol(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(); 4 编译及运行4.1 编译在linux命令行下输入：javac *.java，生成客户端与服务器端的class文件。4.2 运行首先启动服务器。退到gen-java目录，输入java Test/Server，屏幕