获取扩展类加载器

反序列化 @param bytes 序列化后的字节数组 @param clazz 目标类 @param <T> 类的类型。举个例子, {@code String.class} 的类型是 {@code Class<String>}. 如果不知道类的类型的话，使用 {@

创建 ThreadFactory 。如果threadNamePrefix不为空则使用自建ThreadFactory，否则使用defaultThreadFactory @param threadNamePrefix 作为创建的线程名字的前缀 @param daemon 指定是否为

@param rpcServiceName rpc service name @return service object

@param rpcServiceConfig rpc service related attributes

Choose one from the list of existing service addresses list @param serviceUrlList Service address list @param rpcRequest @return target service addre

添加物理节点

Gets the children under a node @param rpcServiceName rpc service name eg:github.javaguide.HelloServicetest2version1 @return All child nodes under the

get the proxy object

Processing rpcRequest: call the corresponding method, and then return the method

判断地址列表是否已经发生了变化，不用加上锁

lookup service by rpcServiceName @param rpcRequest rpc service pojo @return service address

序列化 @param obj 要序列化的对象 @return 字节数组

Empty the registry of data

获取CPU的核心数 @return cpu的核心数

创建临时结点

使用SigletonFactory创建单例bean

Create persistent nodes. Unlike temporary nodes, persistent nodes are not removed when the client disconnects @param path node path

connect server and get the channel ,so that you can send rpc message to server @param inetSocketAddress server address @return the channel

This method is actually called when you use a proxy object to call a method. The proxy object is the object you get through the getProxy method.

get method execution results @param rpcRequest client request @param service service object @return the result of the target method execution

java的SPI机制

register service @param rpcServiceName rpc service name @param inetSocketAddress service address

Registers to listen for changes to the specified node @param rpcServiceName rpc service name eg:github.javaguide.HelloServicetest2version

移除物理节点

根据请求的key选择节点

send rpc request to server and get result @param rpcRequest message body @return data from server