基于netty的rpc远程调用-Toy模板网

这篇具有很好参考价值的文章主要介绍了基于netty的rpc远程调用。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

QPRC

🚀🚀🚀这是一个手写RPC项目，用于实现远程过程调用（RPC）通信🚀🚀🚀

欢迎star串门：https://github.com/red-velet/

🚀Q-PRC

一、功能特性

简单的RPC框架的实现：该RPC框架实现了基本的远程过程调用功能，允许客户端通过网络调用远程服务的方法，实现分布式系统之间的通信和协作。
基于Netty的TCP的网络通信基本机制
：RPC框架使用Netty作为底层通信框架，利用Netty提供的异步非阻塞IO特性，为了提高系统的并发处理能力，使用CompletableFuture等方式处理异步请求和结果。通过异步通信，可以在高并发情况下充分利用系统资源，提高性能和吞吐量。
服务注册与发现：通过注册中心-ZooKeeper实现：RPC框架支持服务注册与发现功能，将服务提供者的地址注册到ZooKeeper注册中心，并由客户端从注册中心获取可用的服务提供者列表。
多种序列化/反序列化、压缩协议支持
：RPC框架提供多种序列化和反序列化协议的支持，例如JSON、Hessian等，以适应不同场景下的数据传输需求。同时，还支持数据压缩协议，有效减少网络传输的数据量，提高传输效率。
多种负载均衡策略的实现：RPC框架支持负载均衡策略，用于在客户端选择合适的服务提供者。目前支持轮询、最少响应时间等负载均衡策略，可以根据实际情况选择最优的策略。
请求超时与重试机制
：为了保证系统的稳定性和性能，在RPC框架中实现了请求超时和重试机制。当请求超过设定的时间未得到响应时，会进行超时处理，避免长时间的等待。同时，也可以设置重试次数，当请求失败时，自动进行重试，提高请求成功率。
服务治理能力：RPC框架支持一定程度的服务治理能力，例如心跳检测器用于定期检测服务提供者的存活性，并维护连接池。此外，还支持服务的动态添加和移除，能够在运行时动态调整服务列表。
- 限流器：为了保护系统资源，防止过多的请求造成系统过载，RPC框架支持限流器功能。通过限制请求的并发数量或速率，可以有效地控制系统的负载，保持系统的稳定性。
- 熔断器：当服务提供者出现故障或不可用时，熔断器功能可以避免无效的请求继续发送，而是及时中断对该服务的请求。这样可以减少资源浪费，并保护系统免受故障的影响。
与Spring Boot做简单继承：RPC框架可以与Spring Boot进行简单的集成，方便在Spring
Boot项目中使用RPC功能。可以通过自定义注解或配置来注册和使用RPC服务，并将RPC框架与Spring Boot的其他功能无缝结合。

二、项目架构

1、组成和基本流程

见github

2、分层和模块

见github

二、快速开始

克隆项目到本地：

git clone https://github.com/BlueBeastMight/qprc.git
cd qprc

修改配置文件：

在qrpc-core/src/main/resources目录下，创建qprc.xml根据您的需求修改配置文件：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration SYSTEM "qrpc-config.dtd">
<configuration>
    <!--端口号-->
    <port>8095</port>

    <!--应用名-->
    <application>qrpc-default-applicationName</application>

    <!--注册中心-->
    <registry url="zookeeper://127.0.0.1:2181"/>

    <!-- 二选一 -->
    <!--序列化协议-->
    <serializeType type="hessian"/>
    <serializer code="1" name="hessian" class="icu.chiou.serialize.wrapper.impl.HessianSerializer"/>

    <!-- 二选一 -->
    <!--压缩协议-->
    <compressType type="gzip"/>
    <compressor code="1" name="gzip" class="icu.chiou.compress.wrapper.impl.GzipCompressor"/>

    <!-- 二选一 -->
    <!--负载均衡策略-->
    <loadBalancer class="icu.chiou.loadbalancer.impl.MinimumResponseTimeLoadBalancer"/>
    <loadBalancerType type="minimumResponseTime"/>

    <!--id生成器-->
    <idGenerator class="icu.chiou.IDGenerator" dataCenterId="2" MachineId="4"/>
</configuration>