pipepi
diff --git a/Collapse file
‎note/Dubbo/Dubbo底层源码学习——服务引用.md‎
Copy file name to clipboard
+23Lines changed: 23 additions & 0 deletions
Display the source diff
Display the rich diff b/Collapse file
‎note/Dubbo/Dubbo底层源码学习——服务引用.md‎
Copy file name to clipboard
+23Lines changed: 23 additions & 0 deletions
Display the source diff
Display the rich diff
diff --git a/Collapse file
‎note/Dubbo/Dubbo底层源码学习——服务暴露.md‎
Copy file name to clipboardExpand all lines: note/Dubbo/Dubbo底层源码学习——服务暴露.md
+3Lines changed: 3 additions & 0 deletions
Display the source diff
Display the rich diff b/Collapse file
‎note/Dubbo/Dubbo底层源码学习——服务暴露.md‎
Copy file name to clipboardExpand all lines: note/Dubbo/Dubbo底层源码学习——服务暴露.md
+3Lines changed: 3 additions & 0 deletions
Display the source diff
Display the rich diff
@@ -0,0 +1,23 @@
+## 前言
+
+## 正文
+
+就DubboProtocolTest类下的testDubboProtocol()方法，服务引用流程：
+
+1. ProtocolFilterWrapper#refer()
+2. ProtocolListenerWrapper#refer()
+3. AbstractProtocol#refer()
+4. DubboProtocol#protocolBindingRefer()
+5. DubboProtocol#getClients()
+6. DubboProtocol#getSharedClient()
+7. DubboProtocol#buildReferenceCountExchangeClientList()
+8. DubboProtocol#buildReferenceCountExchangeClient()
+9. DubboProtocol#initClient()
+10. Exchangers#connect()
+11. HeaderExchanger#connect()
+12. Transporters#connect()
+13. Transporter$Adaptive，代理出来的类，在服务暴露中有代码
+14. NettyTransporter#connect()
+15. NettyClient#init()
+16. AbstractClient#init()
+17. NettyClient#doOpen()
@@ -13,6 +13,7 @@ public class Protocol$Adaptive implements org.apache.dubbo.rpc.Protocol {
 		org.apache.dubbo.common.URL url = arg1;
 		String extName = ( url.getProtocol() == null ? "dubbo" : url.getProtocol() );
 		if(extName == null) throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.Protocol) name from url (" + url.toString() + ") use keys([protocol])");
+        // 这里extension为ProtocolFilterWrapper类
 		org.apache.dubbo.rpc.Protocol extension = (org.apache.dubbo.rpc.Protocol)ExtensionLoader.getExtensionLoader(org.apache.dubbo.rpc.Protocol.class).getExtension(extName);
 		return extension.refer(arg0, arg1);
 	}
@@ -40,8 +41,10 @@ public class ProxyFactory$Adaptive implements org.apache.dubbo.rpc.ProxyFactory
 		if (arg0 == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument == null");
 		if (arg0.getUrl() == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument getUrl() == null");
 		org.apache.dubbo.common.URL url = arg0.getUrl();
+        // 判断如果取不到proxy，则使用默认值javassist
 		String extName = url.getParameter("proxy", "javassist");
 		if(extName == null) throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.ProxyFactory) name from url (" + url.toString() + ") use keys([proxy])");
+        // 这里extension是StubProxyFactoryWrapper对象
 		org.apache.dubbo.rpc.ProxyFactory extension = (org.apache.dubbo.rpc.ProxyFactory)ExtensionLoader.getExtensionLoader(org.apache.dubbo.rpc.ProxyFactory.class).getExtension(extName);
 		return extension.getProxy(arg0);
 	}