使用thrift实现java与node.js的通信

使用thrift实现java与node.js的通信

   其实以前thrift和node.js接触都不多，由于最近项目要用到node.js，而且须要涉及到java与node.js的通信，就想到了thrift。由于使用的系统是Lion，因此这篇文章也从安装和配置方面，记录下MAC平台下这些服务的搭建方式。

   node.js是一种能够在后端运行的js语言，由于使用了回调机制避免了线程膨胀的问题，因此在处理简单而且高性能要求的web服务方面有必定优点。具体能够看这篇文章

我为何向后端工程师推荐Node.js。http://nodejs.org/，有MAC下的pkg安装包。最新版彷佛是0.6.7。

   thrift是facebook提出的一种跨平台远程通讯框架，效率比较高。thrift能够从http://www.apache.org/dyn/closer.cgi?path=/thrift/0.8.0/thrift-0.8.0.tar.gz下载到，须要编译安装，目前最新彷佛是0.8.0。这个版本跟svn下来的版本不一样，不须要执行./bootstrap进行初始化，直接使用./configure编译并安装就能够了。

   thrift的使用比较复杂，首先须要编写一个thrift文件，用于肯定链接双方的接口。具体的thrift文件写法能够参考http://wiki.apache.org/thrift。下面是一个简单的例子：

Test.thrift

namespace java net.johnc.thrift
 service Test {
  voidping(1: i32 length)
}

   使用thrift编译成java文件：thrift --gen java Test.thrift。完成后生成一个java文件，大概是这样子：

public class Test {
                                      
  public interfaceIface {
                                      
    public void ping(int length)throws org.apache.thrift.TException;
                                      
  }

}

   thrift原生支持node.js，因此在编译时，只用使用thrift --gen js:node Test.thrift就能够了。编译完以后生成Test.js和Test_types.js两个文件。

var Thrift = require('thrift').Thrift;
                                
var ttypes = require('./Test_types');
//HELPER FUNCTIONS AND STRUCTURES
                                
var Test_ping_args =function(args) {
  this.length =null;
  if(args) {
    if(args.length !== undefined) {
      this.length = args.length;
    }
  }
}

   最后，须要在node.js里加载thrift库，使用npm install thrift命令就能够了。准备工做到此为止，下一步就能够进行实战了！

    这里咱们使用java当客户端，node.js当服务端，客户端代码以下：

package apache.thrift;
              
import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TFramedTransport;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;
              
/**
 * @author cairne
 * @date Jan 11, 2012
 */
public class TestUserStorage {
              
    /**
     * @param args
     */
    public static void main(String[] args) {
        TTransport transport =new TFramedTransport(new TSocket("localhost",9799));
        try{
            transport.open();
        }catch(TTransportException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }
        TProtocol protocol =new TBinaryProtocol(transport);
              
        UserStorage.Client client =new UserStorage.Client(protocol);
        try{
            client.store(new UserProfile(1,"",""));
            System.out.println(client.retrieve(1));
        }catch(TException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
              
    }
              
}

   注意两个地方：thrift在java中的实现不少，可是node-thrift模块目前只支持TFramedTransport，TBinaryProtocol，因此使用其余实现时server会出错。另外transport是须要先open进行链接的。

   node.js代码：

var thrift = require('thrift');
       
var UserStorage = require('./gen-nodejs/UserStorage.js'),
    ttypes = require('./gen-nodejs/user_types');
       
var users = {};
       
var server = thrift.createServer(UserStorage, {
  store:function(user, success) {
    console.log("server stored:", user.uid);
    users[user.uid] = user;
    success();
  },
       
  retrieve:function(uid, success) {
    console.log("server retrieved:", uid);
    success(users[uid]);
  },
});
       
server.listen(9799);

   输出结果：

   client:     UserProfile(uid:1, name:, blurb:)

   server:    server stored: 1
                 server retrieved: 1

 

参考文章：http://liuchangit.com/development/407.html