facebook的thriff 基于rpc的远程调用实现

RPC、RMI、JMS概念：

RPC与RMI的对比

-远程过程调用 (RPC)是平台中立的，它不理会操作系统之间以及编程语言之间的差异。即RPC支持多种语言，而RMI只支持Java写的应用程序。
另外RMI调用远程对象方法，允许方法返回Java对象以及基本数据类型。而RPC不支持对象的概念，传送到RPC服务的消息由外部数据表示 (External Data Representation, XDR) 语言表示，这种语言抽象了字节序类和数据类型结构之间的差异。只有由XDR定义的数据类型才能被传递，RPC不允许传递对象。可以说RMI是面向对象方式的Java RPC。

JMS

Java消息服务(Java Messaging Service, JMS) 是一种允许应用程序创建、发送、接受和读取消息的Java API。JMS与RMI的区别在于，采用JMS服务，对象是在物理上被异步从网络的某个JVM上直接移动到另一个JVM上。(严重怀疑)

而RMI对象是绑定在本地JVM中，只有函数参数和返回值是通过网络传送的。

thrift概念

是facebook提供的一种跨平台远程通信框架，效率比较高。

thirift用法

1.编写一个thrift文件`Test.thrift`，用于确定连接双方的接口。

简单例子：

1
2
3

service Test {
  void  ping(1: i32 length)
}

2.使用thrift编译

thrift可以用不同命令生成不同文件：

a.生成java文件

1	thrift -gen java Test.thrift

完成后生成一个java文件：

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

b.生成node.js文件：

thrift原生支持node.js

1	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库：

1	npm intall thrift

准备工作到此结束！

3.实战：

使用java当客户端,Node.js当服务端。
java客户端代码如下：

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;
              
public class TestUserStorage {
    public static void main(String[] args) {
        TTransport transport =new TFramedTransport(new TSocket("localhost",9799));
        try{
            transport.open();
        }catch(TTransportException e1) {
            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) {
            e.printStackTrace();
        }
    }     
}

注意两个地方：thrift在java中的实现很多，但是node-thrift模块目前只支持TFramedTransport，TBinaryProtocol，所以使用其他实现时server会出错。另外transport是需要先open进行连接的。

node服务端代码：

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);

输出结果：

1
2
3

client: UserProfile(uid:1, name:, blurb:)
server: server stored: 1
server retrieved: 1