a rpc framework based on java
- 使用Netty作为底层网络通信框架，NIO提升网络通信效率
- 采用Netty长连接机制，避免不必要的重复连接开销
- 使用心跳包维护上述长连接，客户端定期向服务端发心跳，并期望服务端进行心跳回复
- 服务端健康检查机制：对服务端维护的连接中长时间没收到心跳的客户端主动断开，节省服务端资源
- 客户端健康检查机制：对长时间没有收到回复的服务端连接，将该连接断开，并标记该连接对应的服务端为死亡状态，从客户端缓存的服务提供者列表中移出。
- 客户端采用
Failover重连机制，应对连接远程服务端失败的情况 - 客户端实现负载均衡算法选择连接的服务端(实现权重随机负载均衡和一致性哈希负载均衡算法)
- 两种序列化和反序列化方式(java原生+protobuf)
- 自定义注解，方便服务提供者和消费者注册和消费服务
- 集成Spring框架，通过注解注册服务，通过注解消费服务
- 实现SPI机制，实现 接口实现类的动态插拔
- 采用了单例设计模式
- 异步IO场景下，使用
CompletableFuture阻塞地同步获取响应结果。优化了原本的自旋获取响应结果，减少CPU负载。 - 使用zookeeper的watch机制，配合本地缓存provider列表，异步更新本地缓存，使本地缓存中存储最新的provider列表。优化了原本每次调用都需要与zookeeper进行通信的流程。
- 添加路由策略模块，在服务结点上线时，支持自定义路由策略，辅助服务的灰度发布，定义黑名单、白名单等流量治理功能。
- 添加客户端异常重试机制，如果客户端发送请求时出现网络问题或者服务端下线等异常情况，RPC框架能够抓到异常进行重新发送，重新发送会剔除发生异常的结点。默认重试次数为5次。
- 添加客户端超时重试机制，客户端发送请求后调用future.get(timeout)等待一定时间，如果仍没有收到响应则判定本次请求超时，重新发送请求，默认超时时间为5s。
- rpc-framework-core:rpc核心功能部分代码实现
- rpc-example-client:测试用客户端
- rpc-example-server:测试用服务端
- rpc-framework-api:rpc服务api注册
使用自定义的可扩展的RPC通信协议规定数据格式，解决TCP粘包、拆包问题。
+---------------+---------------+-----------------+-------------+-----------------+-----------------+
| Magic Number | Total Length | Header Length | Version | MessageType | Serializer Type |
| 4 bytes | 4 bytes | 2 bytes | 1 bytes | 1 byte | 1 byte |
+---------------+---------------+
| Message ID |Extended Header|
| 2 bytes | unknown |
+---------------+---------------+-----------------+-------------+-----------------+
| Data Bytes | |
| Length: ${Data Length} | |
+---------------------------------------------------------------+-----------------+
字段 解释
Magic Number 魔数，表识一个 RPC 协议包，0x12345678
Total Length 整体长度
Header Length 头部长度
Version 协议版本
Message Type 消息类型，标明这是一个调用请求还是调用响应
Serializer Type 序列化器类型，标明这个包的数据的序列化方式
Message ID 消息ID
Extended Header 扩展头部
Data Bytes 传输的对象，通常是一个RpcRequest或RpcResponse对象，取决于Package Type字段，对象的序列化方式取决于Serializer Type字段。