facebook的thriff 基于rpc的远程调用实现
发布日期:2021-10-05 07:45:35 浏览次数:3 分类:技术文章

本文共 3507 字,大约阅读时间需要 11 分钟。

概念:

远程对象方法调用并不是新概念,远程过程调用 (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

转载地址:https://blog.csdn.net/lixld/article/details/29562389 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:javascript问题的一些小结
下一篇:SSH的乱七八糟【过滤器+拦截器+监听器】

发表评论

最新留言

不错!
[***.144.177.141]2024年04月14日 10时00分22秒