前言

Dubbo源码阅读分享系列文章，欢迎大家关注点赞

SPI实现部分

1. Dubbo-SPI机制

2. Dubbo-Adaptive实现原理

3. Dubbo-Activate实现原理

4. Dubbo SPI-Wrapper

注册中心

1. Dubbo-聊聊注册中心的设计

2. Dubbo-时间轮设计

通信

1. Dubbo-聊聊通信模块设计

RPC

1. 聊聊Dubbo协议

整体介绍

Dubbo的RPC其实是对Protocol的封装，整体的结构与Remoting类似，dubbo-rpc-api是对具体协议、服务暴露、服务引用、代理等的抽象，是整个RPC中的核心，其他模块是对该层具体的实现，每个模块都是Dubbo具体支持的协议。

dubbo-rpc-api

dubbo-rpc-api整体模块如图所示，整体接口包括了filter、listener、protocol、proxy、support以及核心API，接下来我们先来看下核心的接口介绍。

核心接口

开始之前我们来先来回顾一下之前介绍RPC请求的过程，

1. Rpc Client通过传入的IP、端口号、调用类以及方法的参数，通过动态代理找到具体的调用类的方法，将请求的类、方法序列化，传输到服务端；

2. 当Rpc Service收到请求以后，将传入类和方法反序列化，通过反射找到对应的类的方法进行调用，最后将返回结果进行序列化，返回客户端；

3. Rpc Client收到返回值以后，进行反序列化，最后将结果展示；

这里为什么要回顾整个过程，这样后面介绍抽象的接口的时候大家会更更容易理解为什么这么抽象。

Invoker

Invoker接口内部有三个方法，分别是getInterface、invoke、destroyAll，getInterface该方法主要是获取服务接口相关的信息，invoke主要是发起一次调用以及相应信息，destroyAll主要用于销毁调用请求。

public interface Invoker extends Node {//获取服务接口Class getInterface();//发起调用Result invoke(Invocation invocation) throws RpcException;//销毁调用连接default void destroyAll() {destroy();}}

Invocation

Invocation是invoke的参数，内部抽象了RPC调用的目标服务、方法信息、相关参数信息、具体的参数值以及一些附加信息。

public interface Invocation {//调用Service的唯一标识String getTargetServiceUniqueName();String getProtocolServiceKey();//调用的方法名称String getMethodName();//服务名称String getServiceName();//参数类型集合Class[] getParameterTypes();//参数签名集合default String[] getCompatibleParamSignatures() {return Stream.of(getParameterTypes()).map(Class::getName).toArray(String[]::new);}//调用具体的参数值Object[] getArguments();//调用关联的Invoker对象Map getAttachments();@Experimental("Experiment api for supporting Object transmission")Map getObjectAttachments();void setAttachment(String key, String value);@Experimental("Experiment api for supporting Object transmission")void setAttachment(String key, Object value);@Experimental("Experiment api for supporting Object transmission")void setObjectAttachment(String key, Object value);void setAttachmentIfAbsent(String key, String value);@Experimental("Experiment api for supporting Object transmission")void setAttachmentIfAbsent(String key, Object value);@Experimental("Experiment api for supporting Object transmission")void setObjectAttachmentIfAbsent(String key, Object value);/*** get attachment by key.** @return attachment value.* @serial*/String getAttachment(String key);@Experimental("Experiment api for supporting Object transmission")Object getObjectAttachment(String key);/*** get attachment by key with default value.** @return attachment value.* @serial*/String getAttachment(String key, String defaultValue);@Experimental("Experiment api for supporting Object transmission")Object getObjectAttachment(String key, Object defaultValue);/*** get the invoker in current context.** @return invoker.* @transient*/Invoker getInvoker();//Invoker对象可以设置一些KV属性，这些属性并不会传递给ProviderObject put(Object key, Object value);Object get(Object key);Map getAttributes();
}

Result

Result接口是Invoker.invoke方法的返回值，该返回值包含了被调用方返回值（或是异常）以及附加信息，我们也可以添加回调方法，在 RPC 调用方法结束时会触发这些回调。

public interface Result extends Serializable {//调用的返回值Object getValue();void setValue(Object value);//异常处理方法Throwable getException();void setException(Throwable t);boolean hasException();//复合操作，如果调用发生异常，则直接抛出异常，如果没有异常，则返回结果Object recreate() throws Throwable;//携带附加信息Map getAttachments();@Experimental("Experiment api for supporting Object transmission")Map getObjectAttachments();void addAttachments(Map map);@Experimental("Experiment api for supporting Object transmission")void addObjectAttachments(Map map);void setAttachments(Map map);@Experimental("Experiment api for supporting Object transmission")void setObjectAttachments(Map map);String getAttachment(String key);@Experimental("Experiment api for supporting Object transmission")Object getObjectAttachment(String key);String getAttachment(String key, String defaultValue);@Experimental("Experiment api for supporting Object transmission")Object getObjectAttachment(String key, Object defaultValue);void setAttachment(String key, String value);@Experimental("Experiment api for supporting Object transmission")void setAttachment(String key, Object value);@Experimental("Experiment api for supporting Object transmission")void setObjectAttachment(String key, Object value);//添加回调 当RPC调用完成时，会触发回调Result whenCompleteWithContext(BiConsumer fn); CompletableFuture thenApply(Function fn);//阻塞线程，等待此次RPC调用完成Result get() throws InterruptedException, ExecutionException;Result get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException;
}

public interface Exporter {//获取Invoker对象Invoker getInvoker();//取消Invoker对象void unexport();}

@SPI("dubbo")
public interface Protocol {//默认端口int getDefaultPort();//将一个Invoker暴露，该方法必须是幂等的@Adaptive Exporter export(Invoker invoker) throws RpcException;//引用一个Invoker，返回一个Invoker对象@Adaptive Invoker refer(Class type, URL url) throws RpcException;//销毁export方法以及refer方法使用到的Invoker对象，释放当前Protocol对象底层占用的资源void destroy();//返回当前Protocol底层的全部ProtocolServerdefault List getServers() {return Collections.emptyList();}}

@SPI
public interface Filter {//将请求传给后续的Invoker处理Result invoke(Invoker invoker, Invocation invocation) throws RpcException;//监听响应以及异常interface Listener {void onResponse(Result appResponse, Invoker invoker, Invocation invocation);void onError(Throwable t, Invoker invoker, Invocation invocation);}}

@SPI("javassist")
public interface ProxyFactory {//将Invoker对象转为代理对象@Adaptive({PROXY_KEY}) T getProxy(Invoker invoker) throws RpcException;@Adaptive({PROXY_KEY}) T getProxy(Invoker invoker, boolean generic) throws RpcException;//将proxy对象转为Invoker@Adaptive({PROXY_KEY}) Invoker getInvoker(T proxy, Class type, URL url) throws RpcException;
}