diff --git a/dubbo-rpc-default/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/DubboProtocol.java b/dubbo-rpc-default/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/DubboProtocol.java index 7590d3548fc3516472596daf66eb8983aabc831a..027f2c8b7ac6db11608c62b86932d2ed16186655 100644 --- a/dubbo-rpc-default/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/DubboProtocol.java +++ b/dubbo-rpc-default/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/DubboProtocol.java @@ -246,7 +246,9 @@ public class DubboProtocol extends AbstractProtocol { return exporter; } - private ExchangeServer getServer(URL url) { + private ExchangeServer getServer(URL url) { + //默认开启server关闭时发送readonly事件 + url = url.addParameterIfAbsent(Constants.CHANNEL_READONLYEVENT_SENT_KEY, Boolean.TRUE.toString()); String str = url.getParameter(Constants.SERVER_KEY, Constants.DEFAULT_REMOTING_SERVER); if (str != null && str.length() > 0 && ! ExtensionLoader.getExtensionLoader(Transporter.class).hasExtension(str)) @@ -323,7 +325,8 @@ public class DubboProtocol extends AbstractProtocol { /** * 创建新连接. */ - private ExchangeClient initClient(URL url) { + private ExchangeClient initClient(URL url) { + // client type setting. String str = url.getParameter(Constants.CLIENT_KEY, url.getParameter(Constants.SERVER_KEY, Constants.DEFAULT_REMOTING_CLIENT));