转载

RPC和服务注册框架实现

simple-rpc

RPC BASED ON NETTY Running in some business online.

内部结构

IO netty
Serialize with protostuff, kryo
Transparent service discovery and connection management

RPC和服务注册框架实现

现有功能

基本的客户端、服务端交互
提供代理实现接口
spring 集成, xml配置和Java Config配置方式
服务发布订阅 DONE
断线重连 DONE

RoadMap

服务心跳检测
连接池
服务注册发布功能
服务管理、监控
服务调用日志链路跟踪
集成swagger功能,提供文档、测试、客户端生成

消息协议

当前采用简单的在消息体前加上4byte的消息长度值

使用示例

// 需要先启动一个zookeeper作为服务注册发现中心

// 服务接口
public interface IHello {
`
    String say(String hello);

    int sum(int a, int b);
    int sum(Integer a, Integer b);
}
// 服务实现
public class HelloImpl implements IHello {
    public String say(String hello) {
        return "return " + hello;
    }

    public int sum(int a, int b) {
        return a + b;
    }

    public int sum(Integer a, Integer b) {
        return a + b * 3;
    }

}

// 客户端代码
// beanJavaConfig方式
@Bean
    public CountService countService() {
        RpcClientWithLB rpcClientWithLB = new RpcClientWithLB("fyes-counter");
        rpcClientWithLB.setZkConn("127.0.0.1:2181");
        rpcClientWithLB.init();
        CountService countService = rpcClientWithLB.newProxy(CountService.class);
        return countService;
    }

// 服务端发布
// xml配置方式
<bean class="com.github.liuzhengyang.simplerpc.ServerFactoryBean" init-method="start">
        <property name="serviceInterface" value="com.test.liuzhengyang.CountService"/>
        <property name="port" value="8888"/>
        <property name="serviceName" value="fyes-counter"/>
        <property name="serviceImpl" ref="countServiceImpl"/>
        <property name="zkConn" value="127.0.0.1:2181"/>

原文 https://github.com/liuzhengyang/simple-rpc

正文到此结束