lrpc

A lite RPC framework

功能特性

• 支持短连接、连接池以及长连接
• 数据可压缩
• 提供拦截器
• 连接超时重试
• 设定数据传输大小上限
• 支持多协议以及协议扩展
• 服务端自动识别协议类型
• 接口可限流
• 基于 zookeeper 实现服务注册与发现
• 支持负载均衡

快速开始

服务端配置

service.package=com.ranze.literpc.example
service.port=8020
zookeeper.ip=127.0.0.1
zookeeper.port=2181

服务端代码

public class LiteRpcServerTest {
    public static void main(String[] args) {
        LiteRpcServer liteRpcServer = new LiteRpcServer();
        liteRpcServer.start();
    }
}

客户端配置

service.protocol=lite_rpc
service.package=com.ranze.literpc.example
service.server.ip=127.0.0.1
service.server.port=8020
service.channel.type=pooled
service.compress=snappy
zookeeper.ip=127.0.0.1
zookeeper.port=2181
loadbalance=random

客户端代码

public class LiteRpcClientTest {
    public static void main(String[] args) throws InterruptedException {
        LiteRpcClient liteRpcClient = new LiteRpcClient();
        liteRpcClient.addInterceptor(new Interceptor() {
            @Override
            public RpcResponse intercept(Chain chain) {
                RpcRequest rpcRequest = chain.rpcRequest();
                System.out.println("Before proceed, request: " + rpcRequest);
                RpcResponse response = chain.proceed(rpcRequest);
                System.out.println("After proceed, response: " + response);
                return response;
            }
        });

        // 获取代理类
        HelloService helloService = (HelloService) RpcClientProxy.newProxy(liteRpcClient, HelloService.class);

        HelloServiceProto.HelloRequest request = HelloServiceProto.HelloRequest.newBuilder()
                .setName("LRPC")
                .build();
        try {
            // 调用服务
            HelloServiceProto.HelloResponse response = helloService.hello(request);
            System.out.println("Get Response success: " + response.getEcho());
        } catch (Exception e) {
            System.out.println("Get Response error: " + e.getMessage());
        }

        liteRpcClient.shutdown();

    }

}