使用thrift实现java与node.js的通讯 其实之前thrift和node.js接触都很少，因为最近项目要用到node.js，并且需要涉及到java与node.js的通讯，就想到了th

使用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

.