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

概念：

远程对象方法调用并不是新概念，远程过程调用 (RPC) 已经使用很多年了。远程过程调用被设计为在应用程序间通信的平台中立的方式，它不理会操作系统之间以及语言之间的差异。即 RPC 支持多种语言，而 RMI 只支持 Java 写的应用程序。[1]

另外 RMI 调用远程对象方法，允许方法返回 Java 对象以及基本数据类型。而 RPC 不支持对象的概念，传送到 RPC 服务的消息由外部数据表示 (External Data Representation, XDR) 语言表示，这种语言抽象了字节序类和数据类型结构之间的差异。只有由 XDR 定义的数据类型才能被传递， RPC 不允许传递对象。可以说 RMI 是面向对象方式的 Java RPC 。
Java 消息服务 ( Java Messaging Service, JMS ) 是一种允许应用程序创建、发送、接受和读取消息的Java API 。 JMS 与 RMI 的区别在于，采用 JMS 服务，对象是在物理上被异步从网络的某个 JVM 上直接移动到另一个 JVM 上。而 RMI 对象是绑定在本地 JVM 中，只有函数参数和返回值是通过网络传送的。

一个实现的demo，我上传资源文件

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

thirift用法：
1.编写一个thrift文件Test.thrift，用于确定连接双方的接口。
具体的写法参考：http://wiki.apache.org/thrift 
简单例子：

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

2.使用thrift编译
thrift可以用不同命令生成不同文件：a.java文件；b:node文件
a.生成java文件，命令是： 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,所以编译时使用命令：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 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 {

/**
* @param args
*/
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) {
// TODO Auto-generated catch block
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);

 输出结果：

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

server: server stored: 1

server retrieved: 1 

===============================================
还有个简单例子：http://linmomo02.iteye.com/blog/1306920