阻塞获取结果 @return @throws InterruptedException @throws ExecutionException

将标准的 CompletableFuture 包装为 RpcCompletableFuture。 这样可以确保链式调用的每一步都受到 RpcCompletableFuture 的安全检查。

添加缓存 @param serviceName @param serviceList

移除服务对象 @throws Exception

注册服务对象 @param so @throws Exception

@param name String @param age age @return age

Find the extension with the given name. If the specified name is not found, then {@link IllegalStateException} will be thrown.

获得当前线程的 Kryo 实例 @return 当前线程的 Kryo 实例

获取指定服务的缓存节点 @param serviceName @return

invoke调用服务接口 @param rpcRequest @return @throws Exception

开启

将byte[]序列化为类 @param source @param clazz @param <T> @return

提取真正的异常

获取服务对象 @param name @return @throws Exception

指定服务是否有缓存节点 @param serviceName @return

编组响应 @param response @return @throws Exception

将类序列化为byte数组 @param source @param <T> @return

解组请求 @param data @return @throws Exception

⛔️ <b>已禁用提示</b> <p> 请检查是否包含 IO 操作。纯内存操作请使用 {@link #whenCompleteNonBlocking(BiConsumer)}。

重写此方法，添加异步接收到结果之后的业务逻辑 @param context @param result

压缩 @param bytes @return

解压 @param bytes @return

服务注册到zk @param serviceResource