基本功能完整的RPC框架,供学习使用。如有错误和建议,欢迎交流。
Email: [email protected]
Simple-RPC并没有达到商用的标准,但是作为一个学习参考项目,它是非常合适的。它拥有RPC框架的核心功能,会涉及到Spring、Neety、Zookeeper、JUC的某些类、序列化协议、负载均衡算法和简单并发编程等技能点。下面是Simple-RPC的一些特性
- 集成Spring,支持“一键启动”
- 将项目打包到本地仓库,即可直接当RPC框架使用
- 全局配置文件【simple-rpc.properties】+ 标签配置文件【rpc-reference.xml】和 【rpc-service.xml】,支持高度自定义、可优化
- 大部分配置项支持缺省配置和容错配置
- 使用了简单的自定义通信协议:int(序列化协议信息) + int(data长度) + data(待传输数据)
- 支持ProtoStuff和Hessian两种序列化协议,并且方便拓展
- 支持客户端和服务端选择不同的序列化协议
- 提供了 Random / WeightRandom / Polling / WeightPolling / Hash 5种负载均衡算法
- 支持组合策略配置:在 rpc-reference.xml 中引用服务时,各服务可配置不同的负载均衡策略
- 支持标签发布服务和引用服务,满足服务自动注册和发现的要求
- 支持服务地址变更自动感知:实时推送变化的服务地址到客户端
- 支持Timeout设计
- 初始化时,自动为不同的服务地址生成ChannelPool,提高连接速度
- 发布服务时可以自定义该服务的限流信号量大小,提升系统稳定性
- 客户端调用RPC服务使用统一线程池(线程池大小可配置),隔离RPC服务风险
- 使用阻塞队列同步等待Netty的异步返回结果
- 提供了简单服务治理的相关接口
简单介绍如何将本项目在你的电脑上RUN起来
-
下载zookeeper,参考这里在你的windows上安装并运行zookeeper,注意使用zookeeper时不要关闭CMD窗口
-
clone本项目到本地,使用IDEA打开(没试过Eclipse导入本项目,不建议使用),配置maven和本地仓库,等待依赖自动导入完成
-
找到
com.simple.rpc.framework.test.MainServer
,运行它的main方法,可以看到控制台打印服务端的启动日志;再找到com.simple.rpc.framework.test.MainClient
,同样运行它的main方法,可以看到控制台打印客户端的运行日志。MainClient中提供了简单的调用RPC服务测试用例,直接RUN即可。你也可以设置自己的接口和实现类,但是注意需要在rpc-service.xml和rpc-reference.xml中发布和引用你创建的服务。
本项目自定义的配置文件有:simple-rpc.properties / rpc-service.xml / rpc-reference.xml
它是全局配置文件,配置了ZK地址和参数、默认负载均衡策略、采用的序列化协议等,具体可以参考该文件中的注释说明。除了以下情况必须配置的参数项,其他配置项都支持缺省配置
- simple.rpc.zookeeper.address代表的ZK地址必须配置
- 发布服务时, 如果存在没有配置appName属性的simple:service标签, 那么simple.rpc.server.app.name必须配置
- 引用服务时, 如果存在没有配置appName属性的simple:reference标签, 那么simple.rpc.client.app.name必须配置
# 注册中心ZK地址,必须配置,没有默认值
simple.rpc.zookeeper.address=localhost:2181
# session超时时间,默认1000ms
simple.rpc.zookeeper.session.timeout=1000
# 连接超时时间,默认1000ms
simple.rpc.zookeeper.connection.timeout=1000
# 负载均衡默认策略可选值: Random / WeightRandom / Polling / WeightPolling / Hash. 如果配置错误,则使用Random策略
simple.rpc.client.clusterStrategy.default=WeightRandom
# 客户端对每个主机的初始化Channel数量,默认:10
simple.rpc.client.channelPoolSize=10
# 客户端调用RPC服务线程池的线程数,默认:10
simple.rpc.client.threadWorkers=10
# 发布服务时的默认命名空间(标签没有配置appName属性时采用)
simple.rpc.server.app.name=test
# 引入服务时的默认命名空间(标签没有配置appName属性时采用)
simple.rpc.client.app.name=test
# 服务端序列化协议,默认:Default.可选值:Default(ProtoStuff) / Hessian
simple.rpc.server.serializer=Default
# 客户端序列化协议,默认:Default.可选值:Default(ProtoStuff) / Hessian
simple.rpc.client.serializer=Default
它是发布服务的配置文件,主要包含了simple:service标签,示例如下
<simple:service id="sayServiceRegister1"
appName="simple"
interface="com.simple.rpc.framework.test.service.SayService"
ref="sayService1"
weight="50"
workerThreads="100"
serverPort="8083"
timeout="2000"
groupName="default"/>
- id:不同的simple:service要求id属性不一样
- appName:该属性如果缺失,就会采用全局配置文件 simple-rpc.properties 中的 simple.rpc.server.app.name 值,如果两者都缺失,就会报错
- interface:接口的全限定名(appName + interface是该服务在注册中心的key)
- ref:该接口的实现类bean标签的id
- weight:提供服务时该主机的权重值(范围[1,100])
- workerThreads:该主机提供该服务的限流数
- serverPort:该主机发布该服务的端口号
- timeout:服务超时时间
- groupName:应用所属分组名称, 本项目未用到。如果要在ZK中设置更复杂的注册路径,可以使用
注意到,框架是支持将服务发布在不同的端口的,同时也支持对同一个接口,发布不同的服务实现类
它是引用服务的配置文件,主要包含了simple:reference标签,示例如下
<simple:reference id="sayService"
appName="simple"
interface="com.simple.rpc.framework.test.service.SayService"
clusterStrategy="WeightRandom"
timeout="2000"
groupName="default"/>
- id:不同的simple:reference要求id属性不一样
- appName:该属性如果缺失,就会采用全局配置文件 simple-rpc.properties 中的 simple.rpc.client.app.name 值,如果两者都缺失,就会报错
- interface:接口的全限定名(appName + interface是该服务在注册中心的key)
- clusterStrategy:采用的载均衡策略,缺省时就使用全局配置文件 simple-rpc.properties 中的 simple.rpc.client.clusterStrategy.default 值, 如果两者都缺省,就使用框架的默认值(Random)
- timeout:服务超时时间
- groupName:应用所属分组名称, 本项目未用到。如果要在ZK中设置更复杂的注册路径,可以使用
因为这是一个RPC框架,它当然是可以作为jar包被其他项目依赖使用的。
使用maven的install命令,将项目打包到本地仓库,其他项目依赖时的dependency如下
<dependency>
<groupId>com.jacksu.learn</groupId>
<artifactId>simple-rpc</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
作为依赖在新项目中使用时,必须提供配置文件:simple-rpc.properties / rpc-service.xml / rpc-reference.xml, 且它们都要放在 /resource 根目录下,然后创建自己的接口和实现类,并按要求提供配置标签即可使用(和Dubbo的使用要求是类似的)
你也可以选择偷懒:直接将原项目 com.simple.rpc.framework.test 包中内容 和 /resources 下的配置文件都copy到新项目中,即可测试使用。
这里教你如何从零开发Simple-RPC框架(待补充整理)
(开发过程中,做了一些笔记,暂时放在这里作为参考,其中可能有一些地方和实际项目有出入,因为项目后面又改动了很多,没有及时更新文档,有时间再整理一下)