基于RabbitMQ+Hessian+spring实现远程RPC调用

1.对Rpc的简单阐述 

对RPC通俗的理解就是,调用远程服务和调用本地服务一样透明化无感知。使用过dubbo和motan的同学肯定有这种感觉。实现RPC调用过程,无非解决两个问题:

1.数据的传输:这里使用RabbitMQ来收发消息,保证消息的可靠性

2.请求和响应数据的序列化和反序列化:采用Hessian

如果有自己的序列化方案,还得确定传输的消息体结构,这里不做考虑

2.远程调用过程

首先:消费者和生产者spring容器初始化的时候,会根据配置的的api在RabbitMQ上建立相应的队列,消费者会监听相关队列

1)生产者(client)调用以本地调用方式调用服务;

2)client 接收到调用后通过Hessian将方法、参数等组装成能够进行网络传输的消息体; 3)client 通过代理类,执行invoke方法,统一将消息发送到MQ监听的服务端; 4)server 收到消息后通过Hessian进行解码; 5)server 根据解码结果调用本地的服务; 6)本地服务执行并将结果返回给server ; 7)server 将返回结果通过Hessian打包发送至消费方; 8)client 接收到消息,并进行解码; 9)生产者得到最终结果。

3.具体实现过程(如下类图)

简述:MQClientProxy是继承InvocationHandler的代理类,MQClientProxyFactoryBean实现了FactoryBean接口,在spring初始化bean的时候,由MQClientProxy类提供代理类,所有的接口方法调用,最终都会执行MQClientProxy的invoke方法,只是每个接口传过来的的Invoke实参会不一样,然后内容经过Hessian打包后,由RabbitTemplate发送到队列。MQServerEndpoint在服务端容器初始化的时候会根据接口名称监听相应的队列,收到消息后经由Hessian的HessianSkeleton的方法invoke执行后返回

4.源码地址

我的coding地址:https://coding.net/u/kailingchen/p/MqRpc/git

spring boot版地址:https://coding.net/u/kailingchen/p/springboot-mqrpc/git

有些时日没有写博客了,越写越费劲了,市场上成熟的RPC框架有很多,比如Dubbo,Motan,Thrift等,写这篇博文只为加深对RPC原理的认识,有兴趣的可以直接看源码

原创声明,本文系作者授权云+社区发表,未经许可,不得转载。

如有侵权,请联系 yunjia_community@tencent.com 删除。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏零基础使用Django2.0.1打造在线教育网站

利用Flask搭建微电影视频网站(五):访问控制器

努力与运动兼备~~~有任何问题可以加我好友或者关注微信公众号,欢迎交流,我们一起进步!

3392
来自专栏Java技术栈

dubbo服务调试管理实用命令

公司如果分项目组开发的,各个项目组调用各项目组的接口,有时候需要在联调环境调试对方的接口,可以直接telnet到dubbo的服务通过命令查看已经布的接口和方法,...

3827
来自专栏Laoqi's Linux运维专列

Saltstack 远程操作(grains,pillar)服务安装+配置管理

2277
来自专栏Linux驱动

第4阶段——制作根文件系统之分析init进程(2)

本节目标: (1) 了解busybox(init进程和命令都放在busybox中) (2) 创建SI工程,分析busybox源码来知道init进程做了哪些事情 ...

2519
来自专栏Golang语言社区

Golang语言学习-并发

goroutine: 由GO运行环境管理的轻量级线程 channel: 有类型的管道,操作符为 <- 数据流向箭头指向的方向 使用make(chan ...

28711
来自专栏小尘哥的专栏

springboot中使用tk.mybatis代码生成器

tk.mybatis是对mybatis的进一步封装,它对基本的单表的增删改查又做了进一步封装,springboot中的使用之前已经写过了,如果没用过,请参考我之...

2752
来自专栏游戏杂谈

使用node-webkit实现打包工具的小结

之前一直使用的hta在开发工具,最近转到node-webkit上了,对比一下二者的优劣势。hta单个文件,体积较小,但有兼容性的问题(兼容ie6、7、8就行了...

1892
来自专栏iKcamp

系列3|走进Node.js之多进程模型

文:正龙(沪江网校Web前端工程师) 本文原创,转载请注明作者及出处 之前的文章“走进Node.js之HTTP实现分析”中,大家已经了解 Node.js 是...

4197
来自专栏有趣的django

10.Flask上下文

 应用上下文和请求上下文都是存放在一个‘LocalStack’的栈中,和应用app相关的操作就必须要用到应用上下文,比如通过current_app获取当前的这个...

861
来自专栏互联网技术杂谈

beanstalkc Tutorial 中文版

英文原版:https://github.com/earl/beanstalkc/blob/wip-doc-rtfd/doc/tutorial.rst

3248

扫码关注云+社区

领取腾讯云代金券