一款基于 Netty+Kryo+Zookeeper 实现的 RPC 框架。自定义starter完成与Spring的整合，简化了框架的使用。通过 SPI 机制提供了非常灵活的可扩展性。
- 注册中心：使用 Zookeeper 实现服务注册与发现
- 网络传输：使用 Netty 实现网络传输
- 序列化：支持 Kryo、Hessian、Protostuff 等
- 负载均衡：支持随机、轮询、加权轮询和一致性哈希等
- 配置灵活：序列化方式、注册中心的实现方式、负载均衡算法等均可在配置文件灵活配置
- 可拓展性：基于SPI 机制实现可插拔式拓展组件
simple-rpc
├── framework -- 框架代码
├────── common -- 基础工具类
├────── core -- 框架核心代码
├── rpc-spring-boot-starter -- 自定义starter整合Spring
├── example -- 使用示例代码
├────── api -- 服务接口定义
├────── consumer -- 服务消费者
└────── provider -- 服务提供者
- 下载代码到本地
git clone https://github.com/simplefanC/simple-rpc.git- 打包到本地
mvn clean install -DskipTests=true- 添加Maven依赖到你的项目中
<dependency>
<groupId>com.simplefanc</groupId>
<artifactId>rpc-spring-boot-starter</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>使用@RpcReference注解注入服务。
@RestController
@RequestMapping("/hello")
public class HelloController {
@RpcReference(version = "version1", group = "test1")
private HelloService helloService;
@GetMapping("/test")
public String test() {
return this.helloService.hello(new Hello("111", "222"));
}
}配置项：
| 属性 | 含义 | 可选项 |
|---|---|---|
| rpc.registry-address | 注册中心地址 | localhost:2181（默认） |
| rpc.registry-protocol | 注册中心地址协议 | zookeeper（默认），redis |
| rpc.transporter | 网络传输方式 | netty（默认），socket |
| rpc.serialization | 消息序列化协议 | kryo（默认），protostuff，hessian |
| rpc.compress | 压缩方案 | gzip（默认） |
| rpc.loadbalance | 负载均衡算法 | random round weightRound hash |
使用@RpcService注解发布服务。
@Slf4j
@RpcService(group = "test1", version = "version1")
public class HelloServiceImpl implements HelloService {
@Override
public String hello(Hello hello) {
log.info("HelloServiceImpl收到: {}.", hello.getMessage());
String result = "Hello description is " + hello.getDescription();
log.info("HelloServiceImpl返回: {}.", result);
return result;
}
}配置项：
| 属性 | 含义 | 可选项 |
|---|---|---|
| rpc.server-port | 服务暴露端口 | 9999（默认） |
| rpc.registry-address | 注册中心地址 | localhost:2181（默认） |
| rpc.registry-protocol | 注册中心地址协议 | zookeeper（默认），redis |
| rpc.transporter | 网络传输方式 | netty（默认），socket |
| rpc.serialization | 消息序列化协议 | kryo（默认），protostuff，hessian |
| rpc.compress | 压缩方案 | gzip（默认） |
| rpc.weight | 权重 | 1（默认） |
- 服务监控中心