KO | EN

GitLite

Minimalist Open Source Repository Search Engine

gitlite — search

#dsh #dsh-plugin #developer-tools #ai-agent #codex #typescript #cli #deepseek-harness #claude-code #ai-agents #mcp #rust

lcRpc

★ 30 Open GitHub ↗

简易版Dubbo（RPC框架）

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

## 简易版的Dubbo基于Spring，Zookeeper，Netty实现
小手一点，给个Star~
- 实现了同步调用（支持超时时间配置），异步回调调用（基于Future和CountDownLatch实现）。

```JAVA
@RpcAutowired//实现了类似@Reference的注解，可以直接注入Rpc服务
HelloService helloService;

/**
* 异步调用+callback支持
* @throws ExecutionException
* @throws InterruptedException
*/
@Test
public void asyncTest() throws ExecutionException, InterruptedException {
  AsyncInvokeFuture future = helloService.asyncHello("World");
  future.addCallBack(new AsyncCallBack() {
    @Override
    public void success(RpcResponse response) {
      System.out.println("执行成功");
    }
    @Override
    public void fail(RpcResponse response) {
      System.out.println("执行失败");
    }
  });
  System.out.println("已发送请求");
  System.out.println(future.get());
}
/**
* 同步调用支持
*/
@Test
public void helloTest2() {
  String world = helloService.hello("World");
  System.out.println(world);
}
```

- 实现了类似Dubbo的@Reference注解及@Service注解。主要通过在Spring的Bean加载过程中，使用定义好的**代理类对象**来替换掉域中**已经注入的helloService对象**。从而实现代理类对象自动注入。

```JAVA
@RpcAutowired
HelloService helloService;//在生产方只需这样注入服务即可

@RpcService(HelloService.class)//在消费者端只需加入这个注解即可
public class HelloServiceImpl implements HelloService
```

- 利用ThreadLocal和TraceId简单实现了RPC框架的**链路跟踪**。

```JAVA
public class RpcContext {
    private static final ThreadLocal<RpcContext> LOCAL = new ThreadLocal<RpcContext>() {
        @Override
        protected RpcContext initialValue() {
            return new RpcContext();
        }
    };

protected RpcContext() {
    }

public static RpcContext getContext() {
        return LOCAL.get();
    }

private String curThreadId;
    private String traceId;
}
```

- 实现了基于消费者端的负载均衡。目前使用轮询，后续支持包括：轮询、随机、LRU等；

### quckStart

1. 下载zookeeper并启动在默认端口。
2. 启动server模块中的RpcBootstrap中的run方法即可
3. 启动client模块中ServiceTest中的test方法即可测试。

Ref：

https://github.com/xuxueli/xxl-rpc

https://github.com/luxiaoxun/NettyRpc

https://github.com/tang-jie/NettyRPC

lcRpc

Explore Similar Repositories

Was this content helpful?

Recent Feedback

Download README