当前位置:首页 > 短网址资讯

使用PHP和Node.js连接dubbo短网址服务

www.ft12.com9年前 (2017-05-03)短网址资讯1648
DUBBO是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,是阿里巴巴SOA服务化治理方案的核心框架,每天为2,000+个服务提供3,000,000,000+次访问量支持,并被广泛应用于阿里巴巴集团的各成员站点。

不巧的是我司也在用,之前的解决方案是JAVA包装成HTTP的restful API给中间层Node.js或者PHP调用,但是其实有时候需求比较紧急的情况下,直接RPC远程调用可能能解决一些燃眉之急。

由于技术栈是PHP和Node.js,前一阵子研究了一下,总结一下,希望能帮助到有类似场景的同学,也分享一下遇到这种根本不了解的问题是如何去解决的过程,PS,我之前没有JAVA开发背景和PHP开发背景。

一,了解dubbo和他的RPC远程调用原理。

首先是这张图分了几个角色,是从官网拿来的:

Provider: 暴露服务的服务提供方。
Consumer: 调用远程服务的服务消费方。
Registry: 服务注册与发现的注册中心。
Monitor: 统计服务的调用次调和调用时间的监控中心。
Container: 服务运行容器。

说的通俗一点,我们要拿PHP或者NodeJs实现一个Consumer,而Consumer与Monitor和Registry是有关联的,与Provider是有调用关系的。

这个图和上面这段话理解后,简单分析下,dubbo服务的Registry一般使用的都是zookeeper作为注册中心,Monitor需要在消费方和服务提供方进行监控统计,这里只需要实现Monitor消费方的通知即可。

二,实现方案。

上面只是简单的分析出来需求,那么如何实现这个Consumer呢,通过查看几个已经存在的开源项目,比如node.js比较有名的,很多人都在用的,支持hessian协议的 p412726700/node-zookeeper-dubbo,还有支持jsonrpc调用的hufeng/node-jsonrpc-dubbo,他们的实现基本上思路是一样的,包括几个PHP的项目:quickj/dubbo-php-client

既然大家都已经实现了,我讲讲我看到的源码和一些关键代码吧。

三,Node.js连接原理

1,基本所有的库都是使用alexguan/node-zookeeper-client来连接的Registry,使用zookeeper.createClient方法来创建zookeeper实例。

2,从zookeeper连接后的实例中拿到对应服务提供者提供的的dubbo协议集合,使用getChildren方法。

3,对拿到的集合遍历,记得要decodeURIComponent,然后对URL做解析,比如是http开头的dubbo协议,还是dubbo开头的协议,需要分别保存。

4,协议中是包含了RPC调用的所有dubbo方法的,此时需要把对应的方法进行保存,有的框架对方法做了属性拷贝,属性对应的方法内容就是一个invoke调用,有的则是对invoke做了API,你自己去传入RPC调用的方法名。

5,对不同协议编写不同的调用实现方法,如HTTP的调用使用node-json-rpc,而dubbo协议则使用hessian的库。

6,分析dubbo协议原理,简单概括就是基于hessian协议,传输前需要序列化,传输成功后使用hessian的反序列化方法拿到结果,传输使用socket方法连接短网址服务

7,序列化使用github.com/node-modules 自带js-to-java功能,但是这里需要注意,拿到成功返回结果后,如果decode失败,一定要检查java服务方法返回的最好是List,Map,Array这种常规JAVA数据类型,否则可能反序列化失败解析不出js对象。

8,完成调用,缓存实例,对Monitor做通知,详细格式参见dubbo Monitor源码:github.com/alibaba/dubb

四,PHP连接原理

因为我是先了解了NodeJs的大概一个调用和实现过程的,那么再看PHP的,其实就不难了。我这里做一个最小化的解释,我PHP并不太好……属于现学现卖。

1,先找能连zookeeper的类,ZooKeeper - Manual

2,同样使用getChild方法解析出dubbo的协议集合,并且urldecode,再分析保存住对应可以invoke的方法名,协议调用地址。

3,php中的invoke方法实现为先socket_create方法创建一个连接,connect之后socket_write发送请求,然后读回结果,再json_decode(包含中文结果记得转编码)。

4,write参数格式为:invoke com.xx.xx.interfaces.service.method("args")

5,发送Monitor通知,生成短链接

总结:

其实总结一下,理论上Node.js也是可以转写成PHP的实现方式,PHP也可以转写成Node.js的实现方式,语言虽然不一样,原理和调用方式都是相同,如果之后有时间,业务中经常使用这种场景,还是要自己亲自实现一个的好。

做前端真难。。所以我如果上面有说错的地方,大家指正,后续我再修改,希望帮助到想了解的朋友。


扫描二维码推送至手机访问。

版权声明:本文由短链接发布,如需转载请注明出处。

本文链接:https://www.ft12.com/article_29.html

分享给朋友:

相关文章

FT12短网址教你如何利用大数据算法定位网站性能瓶颈(BOSS)

FT12短网址教你如何利用大数据算法定位网站性能瓶颈(BOSS)

FT12短网址资讯:架构师非常关注性能问题,上篇文章中我们介绍了京东的自动化压测体系 ForceBot,这篇文章来自 LinkedIn 的技术博客,介绍如何通过大数据算法来分析调用数据,自动定位性能瓶颈。本文由高可用架构翻译。背景我们 FT…

创业者除了没有性生活,还有这些不为人知的隐疾……

创业者除了没有性生活,还有这些不为人知的隐疾……

有一篇名为《最难的时候,刘强东姚劲波是怎么过来的》的文章,生动描述了58同城的姚建波在创业最困难时,在压力下落泪的故事。美剧《硅谷》第二季中剧中主人公、创始人Richard因为创业的压力严重盗汗、甚至可能小便失禁,这一剧情真实反映了很多创业…

聊聊加密那点事——PHP加密最佳实践

聊聊加密那点事——PHP加密最佳实践

1. 加密的目的加密不同于密码,加密是一个动作或者过程,其目的就是将一段明文信息(人类或机器可以直接读懂的信息)变为一段看上去没有任何意义的字符,必须通过事先约定的解密规则才能将信息转换回有意义的可读信息,通过加密可以防止非授权的信息窃取。…

高并发秒杀系统架构设计 · 抢购、微信红包、短网址、一元夺宝

高并发秒杀系统架构设计 · 抢购、微信红包、短网址、一元夺宝

秒杀业务与难点秒杀业务在各业务中已然非常流行,这里我将互联网行业中的秒杀定义为:在非常短的时间内,将一件商品分成多份进行购买的行为。微信抢红包、短网址、一元夺宝、双11大促抢购等业务本质上都可视作秒杀业务。而最近大热的抢红包的难度在于这是和…

每天坚持不懈的写软文,得到的几点心得感悟

每天坚持不懈的写软文,得到的几点心得感悟

夜深了,我喜欢这样宁静的夜,它能让人不用去想更多的事情,专注于做自己想做的事情,我认为是一种幸福的事情,拿着手机播放了今晚的《半夜听》节目,听这个节目已经有一段时间了,虽然每天只有那么短短的几分钟,但是那些字眼确实令我欲罢不能,听完几分钟的…

他45岁成中国最富二当家,净资产超宗庆后、郭台铭,却异常低调!

在《福布斯》日前发布的《2017年华人富豪榜》上,已从腾讯退休3年的张志东,以84亿美元的净资产位列第19位,排名超过台湾的郭台铭、大陆的宗庆后,也是榜单前20位中唯一的“二当家”。而今年,他才不过45岁。作为腾讯第二号人物张志东,腾讯产品…

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。