Based on the transport layer, implement the Request-Response information exchange semantics.
org.apache.dubbo.remoting.exchange.Exchanger
org.apache.dubbo.remoting.exchange.ExchangeServer
org.apache.dubbo.remoting.exchange.ExchangeClient
<dubbo:protocol exchanger="xxx" />
<!-- The default value setting, when <dubbo:protocol> does not configure the exchanger attribute, use this configuration -->
<dubbo:provider exchanger="xxx" />
org.apache.dubbo.remoting.exchange.exchanger.HeaderExchanger
Maven project structure:
src
|-main
|-java
|-com
|-xxx
|-XxxExchanger.java (implements the Exchanger interface)
|-XxxExchangeServer.java (implements ExchangeServer interface)
|-XxxExchangeClient.java (implements ExchangeClient interface)
|-resources
|-META-INF
|-dubbo
|-org.apache.dubbo.remoting.exchange.Exchanger (plain text file, content: xxx=com.xxx.XxxExchanger)
XxxExchanger.java:
package com.xxx;
import org.apache.dubbo.remoting.exchange.Exchanger;
public class XxxExchanger implements Exchanger {
public ExchangeServer bind(URL url, ExchangeHandler handler) throws RemotingException {
return new XxxExchangeServer(url, handler);
}
public ExchangeClient connect(URL url, ExchangeHandler handler) throws RemotingException {
return new XxxExchangeClient(url, handler);
}
}
XxxExchangeServer.java:
package com.xxx;
import org.apache.dubbo.remoting.exchange.ExchangeServer;
public class XxxExchangeServer impelements ExchangeServer {
//...
}
XxxExchangeClient.java:
package com.xxx;
import org.apache.dubbo.remoting.exchange.ExchangeClient;
public class XxxExchangeClient impelments ExchangeClient {
//...
}
META-INF/dubbo/org.apache.dubbo.remoting.exchange.Exchanger:
xxx=com.xxx.XxxExchanger