dubbo服務引用創(chuàng)建Invoker代理對象
創(chuàng)建Invoker代理
ReferenceConfig#createProxy方法的結尾處,將FailoverClusterInvoker創(chuàng)建DemoService接口的動態(tài)代理。
proxyFactory.getProxy(invoker);
proxyFactory也是一個帶有Adaptive注解方法的SPI類。
默認實現(xiàn)JavassistProxyFactory
@SPI("javassist")
public interface ProxyFactory {
/**
* create proxy.
*
* @param invoker
* @return proxy
*/
@Adaptive({Constants.PROXY_KEY})
<T> T getProxy(Invoker<T> invoker) throws RpcException;
/**
* create invoker.
*
* @param <T>
* @param proxy
* @param type
* @param url
* @return invoker
*/
@Adaptive({Constants.PROXY_KEY})
<T> Invoker<T> getInvoker(T proxy, Class<T> type, URL url) throws RpcException;
}在JavassistProxyFactory#getProxy中
這個地方生成代理的方法非常類似Java的原生的動態(tài)代理java.lang.reflect.Proxy,大家感興趣的可以自己去看一下,這個地方暫不繼續(xù)寫下去了。
InvokerInvocationHandler
我們主要看一下InvokerInvocationHandler。
這樣在執(zhí)行接口的方法時,將方法名與入?yún)嬙斐梢粋€RpcInvocation作為入?yún)ⅲ瑐鬟f到Invoker的invoke函數(shù)中去。
public class InvokerInvocationHandler implements InvocationHandler {
private final Invoker<?> invoker;
public InvokerInvocationHandler(Invoker<?> handler) {
this.invoker = handler;
}
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
String methodName = method.getName();
Class<?>[] parameterTypes = method.getParameterTypes();
if (method.getDeclaringClass() == Object.class) {
return method.invoke(invoker, args);
}
if ("toString".equals(methodName) && parameterTypes.length == 0) {
return invoker.toString();
}
if ("hashCode".equals(methodName) && parameterTypes.length == 0) {
return invoker.hashCode();
}
if ("equals".equals(methodName) && parameterTypes.length == 1) {
return invoker.equals(args[0]);
}
return invoker.invoke(new RpcInvocation(method, args)).recreate();
}
}總結
我們都說,使用RPC框架時,調(diào)用外部服務就像調(diào)用本地服務一樣方便,那么如何實現(xiàn)服務接口的注入的呢?本文真是從這個角度出發(fā),講解了dubbo服務引用時,是怎么注入接口的,并講解了dubbo是通過Invoker調(diào)用外部服務的,更多關于dubbo創(chuàng)建Invoker代理對象的資料請關注腳本之家其它相關文章!
相關文章
Docker部署ElasticSearch和ElasticSearch-Head的實現(xiàn)
這篇文章主要介紹了Docker部署ElasticSearch和ElasticSearch-Head的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2019-12-12
ubuntu vps安裝docker報錯:Cannot connect to t
這篇文章主要介紹了解決ubuntu vps安裝docker時報錯:Cannot connect to the Docker daemon at unix:///var/run/docker.sock.問題的相關資料,文中介紹非常詳細,需要的朋友可以參考借鑒,下面來一起看看吧。2017-04-04
docker搭建redis哨兵集群并且整合springboot的實現(xiàn)
本文主要介紹了docker搭建redis哨兵集群并且整合springboot的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2022-07-07
在Docker中安裝Elasticsearch7.6.2的教程
這篇文章主要介紹了在Docker中安裝Elasticsearch7.6.2的教程,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-11-11

