【转】Thrift入门试用 博客分类： 开源组件的应用Apache开源组件研究企业中间件J2EE开发技术指南 apchethriftsocket
程序员文章站
2024-03-20 23:58:46
...
在新的项目中公司在平台内部系统间使用Thrift通讯，都没有听说过。然后听同事说，是跨语言Socket通讯的开源组件。
功能及特点
1.跨平台和语言的Socket通讯组件。
2.根据伪代码的结构语言定义对象和服务结构，然后生成各语言的代码和接口
3.各语言根据组件提供的库，编写客户端和服务器端程序。服务器端实现接口并编写业务逻辑。
4.服务器端支持多种序列化方式（Binary，Compact，JSON等）和多种服务器实现
太晚了，以后在完善，先贴代码了
本测试使用WINDOW环境和JAVA语言
1.下载和安装
下载地址：http://thrift.apache.org
下载最新版本，当前0.7.0
解压thrift-x.x.x.tar.gz ，进入thrift-x.x.x/lib/java,在cmd模式先使用ant编译（ant安装和设置就不说了哈。然后需要上公网，昨天在公司弄不起就是公司上不了公网，热）。
数据类型：
bool,byte,i16,i32,i64,double,string,binary[二进制类型，在做文件服务器的时候使用]
structs:定义了一个类对象。其实就是一个OOP里面的类
容器类：list,set:集合,map: 字典。包括了三种容器对象
异常：这个跟传统的异常没有太大的差异
服务：类似于定义了一个接口或纯抽象类。程序员要做的就是去实现这些接口然后就可以暴露给客户端调用了。
定义完了thrift文件之后就可以写代码了
点击(此处)折叠或打开
（1）.支持的传输格式
TBinaryProtocol 二进制格式
TCompactProtocol 压缩格式
TJSONProtocol JSON格式
TSimpleJSONProtocol 提供JSON只写协议，生成的文件很容易通过脚本语言解析
TDebugProtocol 使用易懂的可读的文本格式以便于debug
（2）. 支持的数据传输方式
TSocket 阻塞式socket
THttpTransport采用HTTP传输协议进行数据传输
TFramedTransport以frame为单位传输，非阻塞式服务中使用
TFileTransport以文件形式进行传输
TMemoryTransport将内存用于I/0，
TZlibTransport使用zlib进行压缩。
TBufferedTransport对某个transport对象操作的数据进行buffer,即从buffer中读取数据进行传输，或将数据直接写入到buffer
(3). 支持的服务模型[主要是服务端类型]
TSimpleServer简单的单线程服务模型，常用于测试
TThreadedServer多线程服务模型使用标准的阻塞式IO,每个请求创建一个线程
TThreadPoolServer多线程服务模型使用标准的阻塞式IO，预先创建一组线程处理请求
TNonblockingServer多线程服务模型使用非阻塞IO（需要用TFramedTransport数据传输方式 ）
ps:什么叫阻塞与非阻塞？
阻塞IO：socket的阻塞意味着必须要做完IO包括错误才会返回
非阻塞IO：无论操作是否完成都会立刻返回，需要通过其他方式来判断具体操作是否成功
在网络阻塞严重的时候，网络层没有足够的内存来进行写操作，这时候就会出现写不成功的情况，阻塞情况下会尽可能(有可能被中断)等待到数据全部发送完毕， 对于非阻塞的情况就是一次写多少算多少,没有中断的情况下也还是会出现write 到一部分的情况.
2.建立测试工程
普通JAVA工程，目录如下：
src
+ org.acooly.thrift.demo.client 客户端代码
+ org.acooly.thrift.demo.generalcode 通过thrift工具生成的代码
+ org.acooly.thrift.demo.server 服务器端代码
lib
+拷贝前面ant编译后的build/lib下的jar和编译生成的thrift-x.x.x.jar
tools
+ thrift.exe 前面下载的
+ thriftdemo.thrift 伪代码
3.编写伪代码文件*.thrift
Java代码
- namespace java org.acooly.thrift.demo.generalcode
- struct Contact{
- 1:i32 id
- 2:string name
- 3:i64 birthday
- 4:string phoneNo
- 5:string ipAddress
- 6:map<string,string> props
- }
- service ContactManager{
- void save(1:Contact contact)
- void remove(1:i32 id)
- list<Contact> getAll();
- list<Contact> query(1:map<string,string> conditions)
- }
4.生成代码
cmd模式进入 tools目录，运行
thrift.exe -gen java thriftdemo.thrift
运行成功后，在本目录会生成gen-java目录，拷贝该目录下生成的代码到工程中对应的包。
5.服务器代码和实现业务逻辑
实现业务逻辑
Java代码
- package org.acooly.thrift.demo.server;
- import java.util.ArrayList;
- import java.util.Calendar;
- import java.util.List;
- import java.util.Map;
- import org.acooly.thrift.demo.generalcode.Contact;
- import org.acooly.thrift.demo.generalcode.ContactManager;
- import org.apache.thrift.TException;
- public class ContactManagerImpl implements ContactManager.Iface{
- public List<Contact> getAll() throws TException {
- List<Contact> contacts = new ArrayList<Contact>();
- contacts.add(new Contact(1,"zhangpu",Calendar.getInstance().getTimeInMillis(),"1389612222","192.168.2.1",null));
- return contacts;
- }
- public List<Contact> query(Map<String, String> conditions) throws TException {
- List<Contact> contacts = new ArrayList<Contact>();
- contacts.add(new Contact(1,"zhangpu",Calendar.getInstance().getTimeInMillis(),"1389612222","192.168.2.1",null));
- return contacts;
- }
- public void remove(int id) throws TException {
- System.out.println("invoke: remove,id = " + id);
- }
- public void save(Contact contact) throws TException {
- System.out.println("invoke: save,contact = " + contact);
- }
- }
编写服务器代码
Java代码
- package org.acooly.thrift.demo.server;
- import org.acooly.thrift.demo.generalcode.ContactManager;
- import org.acooly.thrift.demo.generalcode.ContactManager.Iface;
- import org.apache.thrift.protocol.TCompactProtocol;
- import org.apache.thrift.protocol.TCompactProtocol.Factory;
- import org.apache.thrift.server.TServer;
- import org.apache.thrift.server.TSimpleServer;
- import org.apache.thrift.server.TServer.Args;
- import org.apache.thrift.transport.TServerSocket;
- public class ThriftServer {
- public static void main(String[] args) throws Exception{
- TServerSocket serverSocket = new TServerSocket(8111);
- ContactManager.Processor<Iface> processor = new ContactManager.Processor<Iface>(new ContactManagerImpl());
- Factory factory = new TCompactProtocol.Factory();
- Args ag = new Args(serverSocket);
- ag.outputProtocolFactory(factory);
- ag.inputProtocolFactory(factory);
- ag.processor(processor);
- TServer server = new TSimpleServer(ag);
- server.serve();
- }
- }
6.客户端代码
Java代码
- package org.acooly.thrift.demo.client;
- import java.util.Calendar;
- import java.util.List;
- import org.acooly.thrift.demo.generalcode.Contact;
- import org.acooly.thrift.demo.generalcode.ContactManager;
- import org.apache.thrift.protocol.TCompactProtocol;
- import org.apache.thrift.protocol.TProtocol;
- import org.apache.thrift.transport.TSocket;
- import org.apache.thrift.transport.TTransport;
- public class ThriftClient {
- public static void main(String[] args) throws Exception{
- TTransport transport = new TSocket("localhost",8111);
- TProtocol protocol = new TCompactProtocol(transport);
- ContactManager.Client client = new ContactManager.Client(protocol);
- transport.open();
- List<Contact> list = client.getAll();
- System.out.println(list);
- client.save(new Contact(1,"zhangpu",Calendar.getInstance().getTimeInMillis(),"1389612222","192.168.2.1",null));
- client.remove(1);
- transport.close();
- }
- }
7.启动和测试运行
1.运行ThriftServer
2.运行ThriftClient
ThriftServer输出：
invoke: save,contact = Contact(id:1, name:zhangpu, birthday:1308591769148, phoneNo:1389612222, ipAddress:192.168.2.1, props:null)
invoke: remove,id = 1
ThriftClient输出：
[Contact(id:1, name:zhangpu, birthday:1308591769131, phoneNo:1389612222, ipAddress:192.168.2.1, props:null)]