前言
服务提供方把自己注册到注册中心后,服务调用方从注册中心获取到服务提供方的信息之后,肯定要发起调用。
dubbo的远程调用主要是用netty nio的方式,利用tcp协议进行网络通信,那么服务提供方在启动的时候,肯定是要启动一个netty服务端的服务的,用来接受调用请求。
1.服务提供方的invoke对象的创建
Invoker是Dubbo中的实体域，也就是真实存在的。其他模型都向它靠拢或转换成它，它也就代表一个可执行体，可向它发起invoke调用。在服务提供方，Invoker用于调用服务提供类。在服务消费方，Invoker用于执行远程调用。
invoke 接口
除了getInterface,只有一个用于执行具体逻辑的invoke方法
服务提供方的invoke对象
提供了对服务提供类实例的
通过proxyFactory对象的getInvoker返回的invoker对象
1.ref对象
其实就是服务暴露类的实例
是ServiceConfig的成员变量,由spring在实例化serviceBean实例的时候,依赖注入而来。
ServiceBean BeanDifinition创建过程
2.proxyFactory对象(JavassistProxyFactory)
ProxyFactory实例,用SPI机制获取的。
ExtensionLoader.getExtensionLoader(ProxyFactory.class).getAdaptiveExtension(
这个dubbo api在spi源码里讲过,如果spi配置文件中配置的该接口的实现类上都没有@Adaptive注解,那么会用javaassist生成一个ProxyFactory的实现类，具体生成的是这样子的
package com.alibaba.dubbo.rpc;
import com.alibaba.dubbo.common.extension.ExtensionLoader;
public class ProxyFactory$Adaptive implements com.alibaba.dubbo.rpc.ProxyFactory {
// 实现的getProxy方法获取的默认的实现类的key是javassist
public java.lang.Object getProxy(com.alibaba.dubbo.rpc.Invoker arg0) throws com.alibaba.dubbo.rpc.RpcException {
if (arg0 == null) throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument == null");
if (arg0.getUrl() == null)
throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument getUrl() == null");
com.alibaba.dubbo.common.URL url = arg0.getUrl();
String extName = url.getParameter("proxy", "javassist");
if (extName == null)
throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.rpc.ProxyFactory) name from url(" + url.toString() + ") use keys([proxy])");
com.alibaba.dubbo.rpc.ProxyFactory extension = (com.alibaba.dubbo.rpc.ProxyFactory) ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.ProxyFactory.class).getExtension(extName);
return extension.getProxy(arg0);
}
public java.lang.Object getProxy(com.alibaba.dubbo.rpc.Invoker arg0, boolean arg1) throws com.alibaba.dubbo.rpc.RpcException {
if (arg0 == null) throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument == null");
if (arg0.getUrl() == null)
throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument getUrl() == null");
com.alibaba.dubbo.common.URL url = arg0.getUrl();
String extName = url.getParameter("proxy", "javassist");
if (extName == null)
throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.rpc.ProxyFactory) name from url(" + url.toString() + ") use keys([proxy])");
com.alibaba.dubbo.rpc.ProxyFactory extension = (com.alibaba.dubbo.rpc.ProxyFactory) ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.ProxyFactory.class).getExtension(extName);
return extension.getProxy(arg0, arg1);
}
public com.alibaba.dubbo.rpc.Invoker getInvoker(java.lang.Object arg0, java.lang.Class arg1, com.alibaba.dubbo.common.URL arg2) throws com.alibaba.dubbo.rpc.RpcException {
if (arg2 == null) throw new IllegalArgumentException("url == null");
com.alibaba.dubbo.common.URL url = arg2;
String extName = url.getParameter("proxy", "javassist");
if (extName == null)
throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.rpc.ProxyFactory) name from url(" + url.toString() + ") use keys([proxy])");
com.alibaba.dubbo.rpc.ProxyFactory extension = (com.alibaba.dubbo.rpc.ProxyFactory) ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.ProxyFactory.class).getExtension(extName);
return extension.getInvoker(arg0, arg1, arg2);
}
}
可以看到这个生成的类中,实现的getProxy方法获取的默认的实现类的key是javassist
所以ProxyFactory就是JavassistProxyFactory的实例
3. JavassistProxyFactory.getInvoker创建invoke对象
先弄一个wrapper对象,然后new出AbstractProxyInvoker(实现Invoker接口)对象,在实现doInvoke用wrapper对象去调用被代理的服务提供类的具体方法
2.又把invoke对象和serviceBean包装下
3.protocol.export(wrapperInvoker)服务发布
3.1 protocol对象
又是一记SPI
不用说肯定是一个生成的类
获取到的Protocol实现类的key是registry,从url获取的
获取到的RegistryProtocol应该是这个类的实例
注意Protocol接口拓展的类有几个包装类,那么RegistryProtocol实例肯定会被这几个类的实例包装
循环中把RegistryProtocol实例传到构造函数中进行层层包装
最终返回的是这个包装后的实例
3.2 protocol.export
QosProtocolWrapper.export,现在url的协议是注册协议
再调到ProtocolFilterWrapper.export
再ProtocolListenerWrapper.export
最后调到RegistryProtocol.export
这里doLocalExport方法就是启动netty服务端的核心方法了
后面的是注册服务到注册中心的逻辑
4.RegistryProtocol.doLocalExport（invoker）启动netty服务
4.1 获取export里的dubbo协议URL
先是获取原Regisry协议里的export参数值
是个dubbo协议,解码后
dubbo://192.168.31.211:20880/com.lb.dubbo_api.service.UserService?anyhost=true
&application=dubbo-p
&bean.name=ServiceBean:com.lb.dubbo_api.service.UserService
&bind.ip=192.168.31.211&bind.port=20880
&dubbo=2.0.2&generic=false&interface=com.lb.dubbo_api.service.UserService
&methods=getUser&pid=58137&side=provider×tamp=1625993018676
创建Url对象,返回
在外面有根据新创建的dubbo协议url和invoker对象创建一个静态代理对象,进行静态代理
4.2 RegistryProtocol.protocol.export()
4.2.1 RegistryProtocol.protocol对象(DubboProtocol)
RegistryProtocol对象里还有个protocol对象
在创建RegistryProtocol的依赖注入的时候,从SPI工厂获取并注入到该属性上的
又是一个动态生成的Protocol实现类
由于方法传入的Invoke静态代理对象的URL是刚刚创建的dubbo协议,所以这里最终调到的会是DubboProtocol实例的export方法
同样会被三个包装类包装
4.2.2 DubboProtocol.export
一样的先走包装类的export方法,
QosProtocolWrapper.export,现在url的协议不是注册协议了，而是dubbo协议
再调到ProtocolFilterWrapper.export
==这里会创建invoker对象的过滤器链。==
根据provider分组和url的key：service.filter从spi工厂中获取Filter的拓展实例
这八个
把Invoker对象接到链表的尾端，并返回的是链表的头结点,以实现在调用invoke对象的方法时,进行层层过滤
再ProtocolListenerWrapper.export
这里会用SPI工厂获取ExporterListener的拓展类实例,用于对服务发布进行时间通知，默认没有,可以自己在本地文件中配置.进行拓展
在ListenerExporterWrapper<T>的构造函数里会调用发布事件监听类的listener方法
最后调到DubboProtocol.export
5.启动netty服务 openServer(url)
这里创建服务 createServer(url)会返回一个ExchangeServer对象,并做了缓存,key为ip加端口号,说明在同一个主机中,配置的tcp端口相同的多个服务发布，都只启动一次netty服务端！
key : 192.168.31.211:20880
value : ExchangeServer
5.1 createServer(url)
Exchangers.bind(url, requestHandler)
requestHandler是一个内部对象
getExchanger(url).bind(url, handler);
new HeaderExchangeServer(Transporters.bind(url, new DecodeHandler(new HeaderExchangeHandler(handler))))
Transporters.bind
getTransporter()又是用SPI获取Transporter的拓展实例
最终获取到的是这个
在构造方法中创建netty服务
AbstractServer的构造方法
获取codec编解码方式,超时时间,绑定的ip,端口
,然后调用子类的doOpen();
接下来就是用netty api开启服务端的代码了
至此,netty服务端已经创建,可以用来接受通信请求了
