hasting
hasting copied to clipboard
使用java nio,oio,aio等原生态io和线程池,实现的分布式跨语言服务化框架
按照我的理解,executorShareable为true时,表示线程可以关闭;您在其他类中,connector的executorShareable设置为true,acceptor的executorShareable设置为false
RedisRpcServer.startJedisAndAddHost(RpcNetBase network) andPort.setApplication(this.getApplication());
Hi, 用findbugs检查rpc源码的时候,有几个地方需要咨询一下: 1. AbstractClientRemoteExecutor 类中 public Object invoke(RemoteCall call)方法中 针对rpcCache的KEY处理——代码中该cache的key类型是String,但是操作前后不一致: rpcCache.put(this.genRpcCallCacheKey(request.getThreadId(), request.getIndex()), sync); --- 这里key类型是string rpcCache.remove(sync.getIndex()); ----这里key类型是int 而且貌似值不匹配啊——是否是BUG 1. 注意到一些sync处理中的sleep调用, Thread.currentThread().sleep(N)——这种可否直接Thread.sleep(N) 2. 能否提供一些性能测试的example啊,对比一下dubbo(x)等