在新的项目中公司在平台内部系统间使用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安装和设置就不说了哈。然后需要上公网,昨天在公司弄不起就是公司上不了公网,热)。
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
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.服务器代码和实现业务逻辑
实现业务逻辑
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);
}
}
编写服务器代码
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.客户端代码
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)]
分享到:
相关推荐
thrift入门学习教程
thrift入门教程+代码
thrift入门简介共22页.pdf.zip
Thrift入门.docx
Thrift作为可伸缩的跨语言服务开发框架,网上的资源较少,这里是一个简单的入门小程序,文件中的mylib下包含了依赖的jar包,并且在file目录下放了一个简单的thrift文件和生成thrift-0.9.0.exe工具,直接使用 thrift-...
Thrift是Facebook开发出的一个软件库和一组代码生成工具,以加快高效率、可扩展的后端服务的开发与实现的速度。它通过对各语言最常用的部分加以抽象,把它们放进一个通用库里,再用各个语言实现,来实现跨编程语言的...
thrift基础入门,讲解thrift基本语法
Thrift入门及Java实例演示,文档及java演示源代码。包括thrift-0.11.0.exe
通俗简单的介绍了什么是thrift,适用于thrift或RPC扫盲。
thrift基础教学文档,适合新手入门学习,大家可以下载下来学习!
然后运行 restart_thrift.sh 脚本就可以直接启动 ps 一下进程是否正常,如果错误请查看日志 然后就可以使用线下的php直接调用, 代码是从网上找到的,比较容易入门 当然也可以直接导入java目录下的java工程,直接运行...
thrift --gen py example.thrift ./client.py 提交 节俭文件 一个简单的节俭文件。 一种服务扩展了另一种服务,并且存在异常。 目的是在尽可能小的空间内呈现出许多深奥的案例。 产生节俭服务 注意main.go顶部的//...
thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码thrift源码...
Apache Thrift is an open source cross language serialization and RPC framework. With support for over 15 programming languages, Apache Thrift can play an important role in a range of distributed ...
thrift 安装包。
网上一直搜不到Windows下QT使用thrift的例子,自己整了个 QT版本 5.8.0 Boost版本 boost_1_61_0 Thrift版本 thrift-0.10.0
使用wireshark抓取thrift协议接口调用
thrift官方代码+与dubbo集成支持原生thrift协议