一文讲明Dubbo Remoting模块（下）

接下来看Client 和 RemotingServer 两个接口，分别抽象了客户端和服务端，两者都继承了 Channel、Resetable 等接口，也就是说两者都具备了读写数据能力。

Client、RemotingServer

都继承了 Endpoint，只是在语义上区分请求和响应职责，都具备发送数据能力。

Client 和 Server 的主要区别：

• Client 只能关联一个 Channel
  
• Server 可接收多个 Client 发起的 Channel 连接，所以在 RemotingServer 接口中定义了查询 Channel 的相关方法
  
• 
• Transporter
• Dubbo 在 Client 和 Server 之上又封装了一层Transporter 接口
  
• 
• @SPI 注解扩展接口，默认使用“netty”扩展名

@Adaptive 注解表示动态生成适配器类，会先后根据“server”“transporter”的值确定 RemotingServer 的扩展实现类，先后根据“client”“transporter”的值确定 Client 接口的扩展实现。

几乎对每个支持的 NIO 库，都有接口实现

为什么要单独抽象出 Transporter层，不直接让上层使用 Netty？

正是利用了依赖反转原则（DIP)，Netty、Mina、Grizzly 等 NIO 库对外接口和使用方式不同，若在上层直接依赖 Netty 或Grizzly，就依赖了具体的 NIO 库，而非依赖一个有传输能力的抽象，后续要切换实现的话，就需修改依赖和接入的相关代码。

有了 Transporter 层，就可通过 Dubbo SPI 修改使用的具体 Transporter 扩展实现，从而切换到不同 Client 和 RemotingServer 实现，切换底层 NIO 库，而无须修改代码。即使有更先进的 NIO 库出现，也只需开发相应的 dubbo-remoting-* 实现模块提供 Transporter、Client、RemotingServer 等核心接口的实现，即可接入，完全符合开放封闭原则。

Transporters

不是一个接口，而是门面类，封装了 Transporter 对象的创建（通过 Dubbo SPI）以及 ChannelHandler 的处理

public class Transporters {
    private Transporters() {
    ...
    public static RemotingServer bind(URL url, 
            ChannelHandler... handlers) throws RemotingException {
        ChannelHandler handler;
        if (handlers.length == 1) {
            handler = handlers[0];
        } else {
            handler = new ChannelHandlerDispatcher(handlers);
        }
        return getTransporter().bind(url, handler);
    }
    public static Client connect(URL url, ChannelHandler... handlers)
           throws RemotingException {
        ChannelHandler handler;
        if (handlers == null || handlers.length == 0) {
            handler = new ChannelHandlerAdapter();
        } else if (handlers.length == 1) {
            handler = handlers[0];
        } else { // ChannelHandlerDispatcher
            handler = new ChannelHandlerDispatcher(handlers);
        }
        return getTransporter().connect(url, handler);
    }
    public static Transporter getTransporter() {
        // 自动生成Transporter适配器并加载
        return ExtensionLoader.getExtensionLoader(Transporter.class)
            .getAdaptiveExtension();
    }
}

在创建 Client 和 RemotingServer 的时候，可指定多个 ChannelHandler 绑定到 Channel 来处理其中传输的数据。Transporters.connect() 方法和 bind() 方法中，会将多个 ChannelHandler 封装成一个 ChannelHandlerDispatcher 对象。

ChannelHandlerDispatcher 也是 ChannelHandler 接口的实现类之一，维护了一个 CopyOnWriteArraySet 集合，它所有的 ChannelHandler 接口实现都会调用其中每个 ChannelHandler 元素的相应方法。另外，ChannelHandlerDispatcher 还提供了增删该 ChannelHandler 集合的相关方法。

Endpoint 接口抽象了“端点”的概念，这是所有抽象接口的基础

上层使用方会通过 Transporters 门面类获取到 Transporter 的具体扩展实现，然后通过 Transporter 拿到相应的 Client 和 RemotingServer 实现，就可以建立（或接收）Channel 与远端进行交互

无论是 Client 还是 RemotingServer，都会使用 ChannelHandler 处理 Channel 中传输的数据，其中负责编解码的 ChannelHandler 被抽象出为 Codec2 接口。

Transporter 层整体结构图

参考

• https://dubbo.apache.org/en-us/docs/dev/design.html