thrift 開發教程 - nick的日志 - 網易博客

thrift 開發教程 ?? ?

2011-05-27 15:27:29 |??分類： thrift |??標簽： ? | 字號 ? 大 中 小 ? 訂閱

1 編寫thrift文件(如aa.thrift)
namespace java? com.tv189.uc.thrift
namespace cpp thrift.vdb
namespace rb thrift.vdb
namespace perl thrift.vdb
namespace csharp thrift.vdb
namespace js thrift.vdb
namespace st thrift.vdb
namespace py thrift.vdb
namespace php thrift

?

service UCThriftService{
?string ucOperator(1:string actionType, 2:string uid, 3:string data),
}

2 生成java文件
thrift-0.6.0.exe -r --gen java uc.thrift
thrift-0.6.0.exe -r --gen java uc.thrift
thrift-0.6.0.exe -r --gen php uc.thrift
thrift-0.6.0.exe -r --gen py uc.thrift
可以生成php，py等等的

3 服務端編寫

? 1)實現 UCThriftService.Iface
public class UCThriftServiceImpl implements UCThriftService.Iface {
?public static Logger logger = Logger.getLogger(UCThriftServiceImpl.class);
?
?@Override
?public String ucOperator(String actionType, String suid, String data)
???throws TException {
??System.out.println("test");

?｝
｝

2)運行的main編寫
public class UCServiceServer {
?private static Logger logger = Logger.getLogger(UCServiceServer.class);
?
?public static void main(String... args) throws Exception {
??//這個是用properties編寫的，可以自行決定
??String server = PropertiesUtil.getValue("tserver.properties","ucserver.nio","hahs");
??if ("nio".equalsIgnoreCase(server)) {
???startNIO();
??} if ("hahs".equalsIgnoreCase(server)) {
???startHAHS();
??} else {
???start();
??}

?}

?private static void start() throws TTransportException {
??String address = PropertiesUtil.getValue("tserver.properties","ucserver.address","0.0.0.0");
??int port = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.port","5555"));
??int clientTimeout = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.clientTimeout","30000"));
??int minWorkerThreads = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.minWorkerThreads","25"));
??int maxWorkerThreads = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.maxWorkerThreads","25"));
??String protocol = PropertiesUtil.getValue("tserver.properties","ucserver.protocol","binary");
??TServerSocket socket = new TServerSocket(new InetSocketAddress(address,
????port), clientTimeout);
??UCThriftService.Processor process = new UCThriftService.Processor(
????UCThriftServiceImpl.instance());
??TThreadPoolServer.Args arg = new TThreadPoolServer.Args(socket);
??if("compact".equalsIgnoreCase(protocol)){
???arg.protocolFactory(new TCompactProtocol.Factory());
??}else if("binary".equalsIgnoreCase(protocol)){
???arg.protocolFactory(new TBinaryProtocol.Factory());
??}else{
???arg.protocolFactory(new TBinaryProtocol.Factory());
??}
??arg.transportFactory(new TFramedTransport.Factory());
??arg.maxWorkerThreads(maxWorkerThreads);
??arg.minWorkerThreads(minWorkerThreads);
??// arg.processor(process);
??arg.processorFactory(new TProcessorFactory(process));
??TServer server = new TThreadPoolServer(arg);
??Logger.getLogger(UCServiceServer.class).info(
????UCServiceServer.class.getSimpleName() + " Listen at " + port);
??while(true){
???try {
????server.serve();
???} catch (Exception e) {
????logger.error(e.getMessage(),e);
????server.stop();
????Logger.getLogger(UCServiceServer.class).info(
??????UCServiceServer.class.getSimpleName() + " Reload");
????server = new TThreadPoolServer(arg);
???}
??}
?}

?private static void startNIO() throws TTransportException {
??String address = PropertiesUtil.getValue("tserver.properties","ucserver.address","0.0.0.0");
??int port = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.port","5555"));
??int clientTimeout = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.clientTimeout","30000"));
??String protocol = PropertiesUtil.getValue("tserver.properties","ucserver.protocol","binary");
?TNonblockingServerSocket socket = new TNonblockingServerSocket(
????new InetSocketAddress(address, port), clientTimeout);
??UCThriftService.Processor process = new UCThriftService.Processor(
????UCThriftServiceImpl.instance());
??TNonblockingServer.Args arg = new TNonblockingServer.Args(socket);
??if("compact".equalsIgnoreCase(protocol)){
???arg.protocolFactory(new TCompactProtocol.Factory());
??}else if("binary".equalsIgnoreCase(protocol)){
???arg.protocolFactory(new TBinaryProtocol.Factory());
??}else{
???arg.protocolFactory(new TBinaryProtocol.Factory());
??}
??arg.transportFactory(new TFramedTransport.Factory());
??// arg.processor(process);
??arg.processorFactory(new TProcessorFactory(process));
??TServer server = new TNonblockingServer(arg);
??Logger.getLogger(UCServiceServer.class).info(
????"NIO " + UCServiceServer.class.getSimpleName() + " Listen at "
??????+ port);
??while(true){
???try {
????server.serve();
???} catch (Exception e) {
????
????server.stop();
????Logger.getLogger(UCServiceServer.class).info(
??????"NIO " + UCServiceServer.class.getSimpleName() + " Reload");
????server = new TNonblockingServer(arg);
???}
??}
?}
?
?private static void startHAHS() throws TTransportException {
??String address = PropertiesUtil.getValue("tserver.properties","ucserver.address","0.0.0.0");
??int port = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.port","5555"));
??int clientTimeout = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.clientTimeout","30000"));
??int minWorkerThreads = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.minWorkerThreads","25"));
??String protocol = PropertiesUtil.getValue("tserver.properties","ucserver.protocol","binary");
?
??TNonblockingServerSocket socket = new TNonblockingServerSocket(
????new InetSocketAddress(address, port), clientTimeout);
??UCThriftService.Processor process = new UCThriftService.Processor(
????UCThriftServiceImpl.instance());
??THsHaServer.Args arg = new THsHaServer.Args(socket);
??if("compact".equalsIgnoreCase(protocol)){
???arg.protocolFactory(new TCompactProtocol.Factory());
??}else if("binary".equalsIgnoreCase(protocol)){
???arg.protocolFactory(new TBinaryProtocol.Factory());
??}else{
???arg.protocolFactory(new TBinaryProtocol.Factory());
??}
??arg.transportFactory(new TFramedTransport.Factory());
??arg.workerThreads(minWorkerThreads);
??// arg.processor(process);
??arg.processorFactory(new TProcessorFactory(process));
??TServer server = new THsHaServer(arg);
??Logger.getLogger(UCServiceServer.class).info(
????"HAHS " + UCServiceServer.class.getSimpleName() + " Listen at "
??????+ port);
??while(true){
???try {
????server.serve();
???} catch (Exception e) {
????logger.error(e.getMessage(),e);
????server.stop();
????Logger.getLogger(UCServiceServer.class).info(
??????"HAHS " + UCServiceServer.class.getSimpleName() + " Reload");
????server = new TNonblockingServer(arg);
???}
??}
?}
?
}

4 客戶端編寫

public? void newThread() throws TException {
??
??
??String address = "0.0.0.0";
??int port = 5555;
??int clientTimeout = 30000;
??TTransport transport = new TFramedTransport(new TSocket(address, port,
????clientTimeout));
??TProtocol protocol = new TBinaryProtocol(transport);
??UCThriftService.Client client = new UCThriftService.Client(protocol);
??transport.open();
??try {
???long bt = System.currentTimeMillis();
???
????
????System.out.println(URLDecoder.decode(client.ucOperator("get", "29", "")));
????
???
??
???
??} catch (TApplicationException e) {
???System.out.println(e.getMessage() + " " + e.getType());
??}
??transport.close();
?}

5運行

先運行ucserver

client連接可在控制臺看到輸出

?

說明：

client連服務端有幾個要注意的地方：

1? 服務器的ip和端口

2 服務端和客戶端用的? transport 和協議一定要一樣

比如： 如果服務端用的TFrameTransport 那客戶端也要用TFrameTransport

?????????????如果服務端用的TBinaryProtocol,那客戶端也要用TBinaryProtocol

否則會出一個好像是TTransportException的一個異常。

thrift 開發教程 - nick的日志 - 網易博客