simple-rpc-framework

使用Java语言开发的轻量级RPC框架

框架特性

• 封装成SpringBoot-starter，简化配置，开箱即用
• 支持全注解式开发，客户端使用JDK动态代理，并支持自动注入Spring容器，使用方便
• 网络通信支持Netty和Java Socket，通过自定义通信格式，防止粘包和拆包问题
• 使用Nacos作为注册中心, 实现服务发现与消费
• 序列化方式可配置，支持Kyro、Hessian和JDK序列化，客户端和服务端可任意搭配使用
• 客户端支持加权随机和轮询两种负载均衡算法, 通过复用 Channel 或 Socket 实现长连接，节约系统资源

使用

服务端

首先创建一个SpringBoot项目，并且引入rpc-server依赖和公共APi依赖：

<dependency>
       <groupId>com.luxiuyang</groupId>
       <artifactId>rpc-server</artifactId>
       <version>2.0</version>
</dependency>
<dependency>
       //公共API依赖
</dependency>

在配置文件（application.yml或application.properties）中配置必要的参数：

rpc-server:
  # 服务器的监听端口, 默认是10010
  port: 10010

  # 服务器的地址, 用于向注册中心注册服务, 默认是localhost
  host-address: localhost

  # 序列化器编号， 0 -> Kyro, 1 -> Hessian, 2 -> JDK，默认为0
  serializer-code: 1

  # 注解扫描的包, 用于扫描@RPCService注解，实现服务自动注册
  base-package: com.xxx.xxx

  # 服务端的类型，可以是Netty或Socket，默认是后者
  server-type: Netty

  # 注册中心的IP
  registry-host: 127.0.0.1

  # 注册中心的端口
  registry-port: 8848

  # 服务器的权重, 用于负载均衡, 默认是1
  weight: 1

在服务端编写接口的实现类，并用@RPCService注解标注：

@RPCService
public class PersonImpl implements Person{

    @Override
    public String hello(String name){
        return "Hello " + name;
    }
}

启动Spring容器，在控制台会打印一些配置信息，并显示服务器已启动：

客户端

首先创建一个SpringBoot项目，并且引入rpc-client依赖和公共APi依赖：

<dependency>
       <groupId>com.luxiuyang</groupId>
       <artifactId>rpc-server</artifactId>
       <version>2.0</version>
</dependency>
<dependency>
       //公共API依赖
</dependency>

在配置文件（application.yml或application.properties）中配置必要的参数：

rpc-client:
  # 序列化器编号， 0 -> Kyro, 1 -> Hessian, 2 -> JDK，默认为0
  serializer-code: 1

  # 注解扫描的包, 用于扫描@Reference注解，实现动态代理对象自动注入
  base-package: com.xxx.xxx

  # 客户端的类型，可以是Netty或Socket，默认是后者
  client-type: Socket

  # 注册中心的地址
  registry-host: www.luxiuyang.online

  # 注册中心的端口
  registry-port: 8848

  # 负载均衡算法, 可选Random和BoundRobin, 默认是Random
  load-balancer: Random

注意serializer-code和client-type无需和服务端保持一致，可以任意搭配使用。即客户端和服务端一个用Netty另一个用Socket可以正常使用，同理序列化器也是一样。

---

接下来编写相应的类，可以用@Reference注解直接注入接口，框架会自动帮我们完成动态代理对象注入，可以像使用本地方法一样来使用它：

@RestController
public class HelloController{
 
    @Reference
    private Person;

    @GetMapping("/hello")
    public String hello(){
        Person.hello("Luxiuyang");
    }
}