Dubbo服务发布

超、凢脫俗 2022-04-18 06:41 257阅读 0赞

dubbo配置示例

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns="http://www.springframework.org/schema/beans" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
        
        <dubbo:application name="demo-provider"/>
        
        <dubbo:registry address="zookeeper://localhost:2181"/>
        
        <dubbo:protocol name="dubbo" port="20880"/>
        
        <bean id="demoService" class="com.alibaba.dubbo.demo.provider.DemoServiceImpl"/>
        
        <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService"/>
    </beans>

## 服务的发布 ##

代码分析

com.alibaba.dubbo.config.spring.ServiceBean#onApplicationEvent
    	>com.alibaba.dubbo.config.ServiceConfig#export
    		>com.alibaba.dubbo.config.ServiceConfig#doExport
    			>com.alibaba.dubbo.config.ServiceConfig#doExportUrls
    				// dubbo是基于URL驱动的
    				>com.alibaba.dubbo.config.AbstractInterfaceConfig#loadRegistries 返回URL的list，
    				// 调用doExportUrlsFor1Protocol()方法，此时protocolConfig是<dubbo:protocol name="dubbo" port="20880"/>
    				>com.alibaba.dubbo.config.ServiceConfig#doExportUrlsFor1Protocol
    					
    					// 本地export
    					>com.alibaba.dubbo.config.ServiceConfig#exportLocal
    						
    						// 生成service对应Invoker
    						>com.alibaba.dubbo.rpc.ProxyFactory#getInvoker
    							// 生成的代理类去选择proxyFactory
    							>ProxyFactory$Adpative.getInvoker
    								>com.alibaba.dubbo.rpc.proxy.javassist.JavassistProxyFactory#getInvoker
    									>com.alibaba.dubbo.common.bytecode.Wrapper#getWrapper
    										// 缓存获取
    										>WRAPPER_MAP.get(c);
    										// 生成service对应的Invoker
    										>com.alibaba.dubbo.common.bytecode.Wrapper#makeWrapper
    						
    						>com.alibaba.dubbo.rpc.protocol.ProtocolListenerWrapper#export	
    							>com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper#export
    								// 组装责任链Filter
    								>com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper#buildInvokerChain
    									>com.alibaba.dubbo.rpc.protocol.injvm.InjvmProtocol#export
    									
    						>com.alibaba.dubbo.rpc.protocol.ProtocolListenerWrapper#export	 返回new ListenerExporterWrapper<T>
    
    									
    					
    					// 远程export
    					
    					// 生成service对应Invoker
    					>com.alibaba.dubbo.rpc.ProxyFactory#getInvoker
    							// 生成的代理类去选择proxyFactory
    							>ProxyFactory$Adpative.getInvoker
    								// 直接取缓存的invoker
    								>com.alibaba.dubbo.rpc.proxy.javassist.JavassistProxyFactory#getInvoker
    
    
    					>Protocol$Adaptive
    						>com.alibaba.dubbo.registry.integration.RegistryProtocol#export
    							>com.alibaba.dubbo.rpc.protocol.ProtocolListenerWrapper#export
    								>com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper#export
    									>com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper#buildInvokerChain
    									// dubbo协议export
    									>com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol#export
    										// netty服务
    										>com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol#openServer
    											>com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol#createServer
    												>com.alibaba.dubbo.remoting.exchange.Exchangers#bind(com.alibaba.dubbo.common.URL, com.alibaba.dubbo.remoting.exchange.ExchangeHandler)
    													>com.alibaba.dubbo.remoting.exchange.Exchangers#getExchanger(com.alibaba.dubbo.common.URL)
    													返回HeaderExchanger
    													>com.alibaba.dubbo.remoting.exchange.support.header.HeaderExchanger#bind
    														
    														>com.alibaba.dubbo.remoting.Transporters#bind(com.alibaba.dubbo.common.URL, com.alibaba.dubbo.remoting.ChannelHandler...)
    															>com.alibaba.dubbo.remoting.Transporters#getTransporter
    															>Transporter 有@SPI("netty") 加载spi配置，默认netty
    																>com.alibaba.dubbo.remoting.transport.netty.NettyTransporter#bind
    																	>com.alibaba.dubbo.remoting.transport.netty.NettyServer
    																		>com.alibaba.dubbo.remoting.transport.AbstractServer#AbstractServer
    																			>com.alibaba.dubbo.remoting.transport.netty4.NettyServer#doOpen
    																				>netty4启动服务 bootstrap = new ServerBootstrap();
    																				>com.alibaba.dubbo.remoting.transport.netty4.NettyServerHandler
    															
    															>com.alibaba.dubbo.remoting.exchange.support.header.HeaderExchangeServer
    																// 启动心跳
    																>com.alibaba.dubbo.remoting.exchange.support.header.HeaderExchangeServer#startHeatbeatTimer
    
    
    
    										// url注册
    										>com.alibaba.dubbo.registry.integration.RegistryProtocol#getRegistry
    										>com.alibaba.dubbo.registry.RegistryService#register(URL registedProviderUrl)
    										// 注册监听器
    										>com.alibaba.dubbo.registry.RegistryService#subscribe(overrideSubscribeUrl,OverrideListener overrideSubscribeListener)
    											// 当ur发生变化，触发listener
    											>com.alibaba.dubbo.registry.integration.RegistryProtocol.OverrideListener#notify
    												// url不同时，触发export
    												>com.alibaba.dubbo.registry.integration.RegistryProtocol#doChangeLocalExport

## 设计思路问题 ##

*  1）为什么要费那么大劲都转成Invoker 将自己的Service执行，转换成invoker.doInvoke  
    和其它的Filter组成一个链式调用。
 *  2）Invoker如何生成的？  
    使用动态代理生成，**有什么差别呢？**  
    javaAssistProxy  
    javaProxy  
    stubProxy

## ServiceBean类图 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01lbWVyeV9sYXN0_size_16_color_FFFFFF_t_70]

## nettyServer设计 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01lbWVyeV9sYXN0_size_16_color_FFFFFF_t_70 1]

## Dubbo官网服务暴露的时序图 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01lbWVyeV9sYXN0_size_16_color_FFFFFF_t_70 2]

参考https://juejin.im/post/5bb2ff89f265da0aeb711784

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01lbWVyeV9sYXN0_size_16_color_FFFFFF_t_70]: /images/20220418/f8cb33bd467b40e682c91ecd2f003228.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01lbWVyeV9sYXN0_size_16_color_FFFFFF_t_70 1]: /images/20220418/da388163a83e4da69d7b47d79c7c272e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01lbWVyeV9sYXN0_size_16_color_FFFFFF_t_70 2]: /images/20220418/0cd714092e6641cb87ac157732148507.png