9.18. 网络传输扩展

• org.apache.dubbo.remoting.Transporter
• org.apache.dubbo.remoting.Server
• org.apache.dubbo.remoting.Client

<!-- 服务器和客户端使用相同的传输实现 -->
<dubbo:protocol transporter="xxx" /> 
<!-- 服务器和客户端使用不同的传输实现 -->
<dubbo:protocol server="xxx" client="xxx" /> 
<!-- 缺省值设置，当<dubbo:protocol>没有配置transporter/server/client属性时，使用此配置 -->
<dubbo:provider transporter="xxx" server="xxx" client="xxx" />

• org.apache.dubbo.remoting.transport.transporter.netty.NettyTransporter
• org.apache.dubbo.remoting.transport.transporter.mina.MinaTransporter
• org.apache.dubbo.remoting.transport.transporter.grizzly.GrizzlyTransporter

• Maven 项目结构：

  src
   |-main
      |-java
          |-com
              |-xxx
                  |-XxxTransporter.java (实现Transporter接口)
                  |-XxxServer.java (实现Server接口)
                  |-XxxClient.java (实现Client接口)
      |-resources
          |-META-INF
              |-dubbo
                  |-org.apache.dubbo.remoting.Transporter (纯文本文件，内容为：xxx=com.xxx.XxxTransporter)
  

• XxxTransporter.java：

  package com.xxx;
  import org.apache.dubbo.remoting.Transporter;
  public class XxxTransporter implements Transporter {
      public Server bind(URL url, ChannelHandler handler) throws RemotingException {
          return new XxxServer(url, handler);
      }
      public Client connect(URL url, ChannelHandler handler) throws RemotingException {
          return new XxxClient(url, handler);
      }
  }
  

• XxxServer.java：

  package com.xxx;
  import org.apache.dubbo.remoting.transport.transporter.AbstractServer;
  public class XxxServer extends AbstractServer {
      public XxxServer(URL url, ChannelHandler handler) throws RemotingException{
          super(url, handler);
      }
      protected void doOpen() throws Throwable {
          // ...
      }
      protected void doClose() throws Throwable {
          // ...
      }
      public Collection<Channel> getChannels() {
          // ...
      }
      public Channel getChannel(InetSocketAddress remoteAddress) {
          // ...
      }
  }
  

• XxxClient.java：

  package com.xxx;
  import org.apache.dubbo.remoting.transport.transporter.AbstractClient;
  public class XxxClient extends AbstractClient {
      public XxxServer(URL url, ChannelHandler handler) throws RemotingException{
          super(url, handler);
      }
      protected void doOpen() throws Throwable {
          // ...
      }
      protected void doClose() throws Throwable {
          // ...
      }
      protected void doConnect() throws Throwable {
          // ...
      }
      public Channel getChannel() {
          // ...
      }
  }
  

• META-INF/dubbo/org.apache.dubbo.remoting.Transporter：

  xxx=com.xxx.XxxTransporter