netty-rpc

一个简单的RPC实现，基于Spring, Zookeeper, Netty

正在开发

• 异常处理 √
• AOP埋点监控 √
• 集成断路器
• 支持跨平台
• 提供API文档支持,Restful调用
• 更高的性能...

简易使用

1. 创建一个RPC接口

public interface MathService {
    public int max(int a, int b);
}

2. 实现该接口并加上@RpcService注解

@RpcService(MathService.class)
public class MathServiceImpl implements MathService {

    @Override
    public int max(int a, int b) {
        return Math.max(a, b);
    }
}

3. 运行zookeeper

1. 官网下载最新的releases版本(源码版本是无法运行的) https://zookeeper.apache.org/releases.html
2. 运行zoopeeker，比如zookeeper默认运行在127.0.0.1:2181上

4. 启动服务

1. 在rpc-config.properties中修改rpc服务地址和zoopeeker地址
2. 启动ServerApplication即可

5. 使用客户端

ServerDiscovery discovery = new ServerDiscovery("127.0.0.1:2181");
rpcClient rpcClient = new RpcClient(serviceDiscovery);

MathService mathService = rpcClient.create(MathService.class);
System.out.println("最大值：" + mathService.max(233, 19));

rpcClient.stop();

服务监控

引入了AOP数据埋点之后，可以记录客户发起的RPC请求，包括成功和失败的，通过服务监控类"com.zihua.rpc.aop.RpcMonitor"记录客户端对服务器发起的调用。

比如我用如下代码连续请求10次：

public static void main(String[] args) {
    ServiceDiscovery serviceDiscovery = new ServiceDiscovery("127.0.0.1:2181");
    RpcClient rpcClient = new RpcClient(serviceDiscovery);
    
    MathService mathService = rpcClient.create(MathService.class);
    for (int i = 1; i <= 10; i++) {
        System.out.println("最大值：" + mathService.max(233, 19));            
    }
    rpcClient.stop();
}

然后查看服务端日志：

如果我发起了错误的调用，那么也会记录，比如我将请求的包名改成错误的：

@MarkClassName(className = "com.zihua.rpc.demo.MathService123")
public interface MathService {
    public int max(int a, int b);
}

然后服务端会记录如下日志：

第一行的INFO包含出错的Throwable，第二行就是ERROR了。

可以根据实际场景把日志改成xml或者文本，

架构设计

服务端

客户端

注意

1. 发起调用的接口须与服务端路径一致

比如服务端实例接口路径是"com.zihua.rpc.demo.MathService"
那么客户端就在"com.zihua.rpc.demo"下创建MathService

2. 如果路径不一致的情况下使用@MarkClassName设置包路径

比如客户端类的路径是"com.zihua.rpc.MathService"
服务端的路径是"com.zihua.rpc.demo.MathService"
加上@MarkClassName注解后可以手动更正

@MarkClassName(className = "com.zihua.rpc.demo.MathService")
public interface MathService {
    public int max(int a, int b);
}

ServerDiscovery discovery = new ServerDiscovery("127.0.0.1:2181");
rpcClient rpcClient = new RpcClient(serviceDiscovery);

MathService mathService = rpcClient.create(MathService.class);
System.out.println("最大值：" + mathService.max(233, 19));

rpcClient.stop();