Thrift:Apache Thrift使用简介
定义thrift服务
Tirift可以下载预编译的thrift.exe，进行开发时，首先定义接口文件，例如下面这个:
namespace cpp riguz
namespace java riguz.thrift.def
namespace csharp riguz
//通用响应消息体
struct CommonResponse{
1:bool success //调用是否成功
2:string jsonResult //调用成功，返回响应信息；调用失败，返回错误信息
//具体返回的信息根据请求方法不同而不同
//eg:{result:'abc'} {result:'接口调用失败！'}
//{result:[1,2,3,4]}
}
service RiguzService{
//PING请求，用来测试服务器是否就绪，当服务器维护时，返回错误信息
//result: OK
CommonResponse ping(),
//登录请求,返回一个token及过期时间
//result: {token:'5A3486D5-4657-287A-D3C6-2E36D97607D8',expires_in:3600}
CommonResponse login(1:string user, //用户名
2:string passwd, //密码
3:string userAgent //登录附言，用来标致客户端信息
),
//注销请求
CommonResponse logout(1:string token //客户端token
),
//跳转交易请求
//result: {trans:'office', panel:'abc.xml'}（返回交易的主界面文件名，例如XUI）
// {trans:'office', panel:'<xml?>...</xml>'}（返回交易的主界面的XML）
CommonResponse chain(1:string token, //客户端token
2:string name //交易名称，为空则返回当前交易名称
),
//预留拓展接口，用来处理其他自定义的请求
//请求及返回均以JSON格式返回
CommonResponse doJson(1:string request //JSON格式的请求，本方法作为扩展
)
}
生成客户端代码
thrift -r --gen java riguz_service.thrift
thrift -r --gen csharp riguz_service.thrift
thrift -r --gen js:jquery riguz_service.thrift
Java服务端
服务端需要实现生成的Java代码中的接口
public class ServiceHandler
implements RiguzService.Iface {
...
}
public class SocketServer {
private static ServiceHandler handler;
private static RiguzService.Processor processor;
/**
* 服务主函数，启动thrift服务
*
* @param args
*/
public static void main(String[] args) {
try {
handler = new ServiceHandler();
processor = new RiguzService.Processor(handler);
Runnable RiguzRunnable = new Runnable() {
@Override
public void run() {
start(processor, 8080);
}
};
Runnable secure = new Runnable() {
@Override
public void run() {
secure(processor, 9091);
}
};
new Thread(RiguzRunnable).start();
new Thread(secure).start();
}
catch (Exception ex) {
}
}
public static void start(RiguzService.Processor processor, int port) {
try {
// 以Socket方式传输
TServerTransport serverTransport = new TServerSocket(port);
TServer server = new TSimpleServer(new TSimpleServer.Args(serverTransport).processor(processor));
// Use this for a multithreaded server
// TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(serverTransport).processor(processor));
System.out.println("Starting thrift server@" + port + " ...");
server.serve();
}
catch (Exception e) {
e.printStackTrace();
}
}
public static void secure(RiguzService.Processor processor, int port) {
try {
/*
* Ref：
* 生成证书库（包含私钥）有效期365*50=18250天
* keytool -genkey -alias thrift -keyalg RSA -keystore E:\thrift\ca\keystore -keysize 1024 -validity 18250
*
* 导出凭证文件
* keytool -export -alias thrift -keystore E:\thrift\ca\keystore -file E:\thrift\ca\truststore.cer
*
* 把认凭证件导入到truststore文件
* keytool -import -alias thrift -file E:\thrift\ca\truststore.cer -keystore E:\thrift\ca\truststore
*
* 验证新创建的truststore文件
* keytool -list -v -keystore E:\thrift\ca\truststore
*/
TSSLTransportParameters params = new TSSLTransportParameters();
String res = SocketServer.class.getProtectionDomain().getCodeSource().getLocation().getFile();
File thisJar = new File(res);
File resourceFile = new File(thisJar.getParentFile(), "thrift.key");
params.setKeyStore(resourceFile.getAbsolutePath(), "123456", null, null);
TServerTransport serverTransport = TSSLTransportFactory.getServerSocket(port, 0, null, params);
TServer server = new TSimpleServer(new TSimpleServer.Args(serverTransport).processor(processor));
System.out.println("Starting the secure server...");
server.serve();
}
catch (Exception e) {
e.printStackTrace();
}
}
客户端
Java
C#
private static TTransport transport = new THttpClient(new Uri("http://localhost:8080/riguz/thrift"));
private static TProtocol protocol = new TJSONProtocol(transport);
private static RiguzService.Client thriftClient = new RiguzService.Client(protocol);
public static ServiceEngine GetInstance()
{
if (engine == null)
{
engine = new ServiceEngine();
transport.Open();
CommonResponse pingResult = thriftClient.ping();
Console.WriteLine("Ping:" + pingResult.Success);
}
return engine;
}
public bool Login(string userName, string passwd)
{
CommonResponse result = thriftClient.login(userName, passwd, "Wpf,1.0," + this.ClientId);
if (result.Success == true)
{
Dictionary<string, string> dict= JsonConvert.DeserializeObject<Dictionary<string, string>>(result.JsonResult);
token = dict["token"];
Console.WriteLine("login success:token=" + token);
return true;
}
return false;
}
JavaScript
var serverurl = "http://localhost:8080/riguz/webreq";
//按钮
$("input[id^=button]").each(function() {
var id = $(this).attr("id");
$(this).click(function() {
var path = $(this).attr("path");
var dataMap = {
"module" : path,
"action" : "click"
};
//Stack
$.post(serverurl, dataMap, function(data) {
var dataMap1 = {
"action" : "allstack"
};
$.post(serverurl, dataMap1, function(data) {
//操作List
jQuery.each(data.jsondata, function(i, item) {
var type = item.type;
if (type == "INFORMATION") {
var des=item.description;
var info=des.split("|");
alert(info[1]);
}
});
}, "json");
}, "json");
});
});