2. 程式人生 > >Dubbo系列之SPI實現機制(五)

Dubbo系列之SPI實現機制(五)

阿新 • • 發佈：2019-02-14
private String createAdaptiveExtensionClassCode() { StringBuilder codeBuidler = new StringBuilder(); Method[] methods = type.getMethods(); boolean hasAdaptiveAnnotation = false; for (Method m : methods) { if (m.isAnnotationPresent(Adaptive.class)) { hasAdaptiveAnnotation = true;
break; } } // no need to generate adaptive class since there's no adaptive method found. if (!hasAdaptiveAnnotation) throw new IllegalStateException("No adaptive method on extension " + type.getName() + ", refuse to create the adaptive class!"); codeBuidler.append("package "
+ type.getPackage().getName() + ";"); codeBuidler.append("\nimport " + ExtensionLoader.class.getName() + ";"); codeBuidler.append("\npublic class " + type.getSimpleName() + "$Adaptive" + " implements " + type.getCanonicalName() + " {"); for (Method method : methods) { Class<?> rt = method.getReturnType();
Class<?>[] pts = method.getParameterTypes(); Class<?>[] ets = method.getExceptionTypes(); Adaptive adaptiveAnnotation = method.getAnnotation(Adaptive.class); StringBuilder code = new StringBuilder(512); if (adaptiveAnnotation == null) { code.append("throw new UnsupportedOperationException(\"method ") .append(method.toString()).append(" of interface ") .append(type.getName()).append(" is not adaptive method!\");"); } else { int urlTypeIndex = -1; for (int i = 0; i < pts.length; ++i) { if (pts[i].equals(URL.class)) { urlTypeIndex = i; break; } } // found parameter in URL type if (urlTypeIndex != -1) { // Null Point check String s = String.format("\nif (arg%d == null) throw new IllegalArgumentException(\"url == null\");", urlTypeIndex); code.append(s); s = String.format("\n%s url = arg%d;", URL.class.getName(), urlTypeIndex); code.append(s); } // did not find parameter in URL type else { String attribMethod = null; // find URL getter method LBL_PTS: for (int i = 0; i < pts.length; ++i) { Method[] ms = pts[i].getMethods(); for (Method m : ms) { String name = m.getName(); if ((name.startsWith("get") || name.length() > 3) && Modifier.isPublic(m.getModifiers()) && !Modifier.isStatic(m.getModifiers()) && m.getParameterTypes().length == 0 && m.getReturnType() == URL.class) { urlTypeIndex = i; attribMethod = name; break LBL_PTS; } } } if (attribMethod == null) { throw new IllegalStateException("fail to create adaptive class for interface " + type.getName() + ": not found url parameter or url attribute in parameters of method " + method.getName()); } // Null point check String s = String.format("\nif (arg%d == null) throw new IllegalArgumentException(\"%s argument == null\");", urlTypeIndex, pts[urlTypeIndex].getName()); code.append(s); s = String.format("\nif (arg%d.%s() == null) throw new IllegalArgumentException(\"%s argument %s() == null\");", urlTypeIndex, attribMethod, pts[urlTypeIndex].getName(), attribMethod); code.append(s); s = String.format("%s url = arg%d.%s();", URL.class.getName(), urlTypeIndex, attribMethod); code.append(s); } String[] value = adaptiveAnnotation.value(); // value is not set, use the value generated from class name as the key if (value.length == 0) { char[] charArray = type.getSimpleName().toCharArray(); StringBuilder sb = new StringBuilder(128); for (int i = 0; i < charArray.length; i++) { if (Character.isUpperCase(charArray[i])) { if (i != 0) { sb.append("."); } sb.append(Character.toLowerCase(charArray[i])); } else { sb.append(charArray[i]); } } value = new String[]{sb.toString()}; } boolean hasInvocation = false; for (int i = 0; i < pts.length; ++i) { if (pts[i].getName().equals("com.alibaba.dubbo.rpc.Invocation")) { // Null Point check String s = String.format("\nif (arg%d == null) throw new IllegalArgumentException(\"invocation == null\");", i); code.append(s); s = String.format("\nString methodName = arg%d.getMethodName();", i); code.append(s); hasInvocation = true; break; } } String defaultExtName = cachedDefaultName; String getNameCode = null; for (int i = value.length - 1; i >= 0; --i) { if (i == value.length - 1) { if (null != defaultExtName) { if (!"protocol".equals(value[i])) if (hasInvocation) getNameCode = String.format("url.getMethodParameter(methodName, \"%s\", \"%s\")", value[i], defaultExtName); else getNameCode = String.format("url.getParameter(\"%s\", \"%s\")", value[i], defaultExtName); else getNameCode = String.format("( url.getProtocol() == null ? \"%s\" : url.getProtocol() )", defaultExtName); } else { if (!"protocol".equals(value[i])) if (hasInvocation) getNameCode = String.format("url.getMethodParameter(methodName, \"%s\", \"%s\")", value[i], defaultExtName); else getNameCode = String.format("url.getParameter(\"%s\")", value[i]); else getNameCode = "url.getProtocol()"; } } else { if (!"protocol".equals(value[i])) if (hasInvocation) getNameCode = String.format("url.getMethodParameter(methodName, \"%s\", \"%s\")", value[i], defaultExtName); else getNameCode = String.format("url.getParameter(\"%s\", %s)", value[i], getNameCode); else getNameCode = String.format("url.getProtocol() == null ? (%s) : url.getProtocol()", getNameCode); } } code.append("\nString extName = ").append(getNameCode).append(";"); // check extName == null? String s = String.format("\nif(extName == null) " + "throw new IllegalStateException(\"Fail to get extension(%s) name from url(\" + url.toString() + \") use keys(%s)\");", type.getName(), Arrays.toString(value)); code.append(s); s = String.format("\n%s extension = (%<s)%s.getExtensionLoader(%s.class).getExtension(extName);", type.getName(), ExtensionLoader.class.getSimpleName(), type.getName()); code.append(s); // return statement if (!rt.equals(void.class)) { code.append("\nreturn "); } s = String.format("extension.%s(", method.getName()); code.append(s); for (int i = 0; i < pts.length; i++) { if (i != 0) code.append(", "); code.append("arg").append(i); } code.append(");"); } codeBuidler.append("\npublic " + rt.getCanonicalName() + " " + method.getName() + "("); for (int i = 0; i < pts.length; i++) { if (i > 0) { codeBuidler.append(", "); } codeBuidler.append(pts[i].getCanonicalName()); codeBuidler.append(" "); codeBuidler.append("arg" + i); } codeBuidler.append(")"); if (ets.length > 0) { codeBuidler.append(" throws "); for (int i = 0; i < ets.length; i++) { if (i > 0) { codeBuidler.append(", "); } codeBuidler.append(ets[i].getCanonicalName()); } } codeBuidler.append(" {"); codeBuidler.append(code.toString()); codeBuidler.append("\n}"); } codeBuidler.append("\n}"); if (logger.isDebugEnabled()) { logger.debug(codeBuidler.toString()); } return codeBuidler.toString(); }

相關推薦

Dubbo系列之SPI實現機制(五)

private String createAdaptiveExtensionClassCode() { StringBuilder codeBuidler = new StringBuilder(); Method[] methods = type.getMethods(); boolean

spark源碼系列之累加器實現機制及自定義累加器

大數據 spark一，基本概念 累加器是Spark的一種變量，顧名思義該變量只能增加。有以下特點： 1，累加器只能在Driver端構建及並只能是Driver讀取結果，Task只能累加。 2，累加器不會改變Spark Lazy計算的特點。只會在Job觸發的時候進行相關累加操作。 3，現有累加器的類型。相信有很

Dubbo系列之 （五）服務訂閱（2）

# 輔助連結 ## [Dubbo系列之 （一）SPI擴充套件 ](https://www.cnblogs.com/liferecord/p/13445631.html) ## [Dubbo系列之 （二）Registry註冊中心-註冊（1）](https://www.cnblogs.com/liferecord

Spring系列之AOP實現的兩種方式

部分 靜態常量 cep value conf tar import enc ble AOP常用的實現方式有兩種，一種是采用聲明的方式來實現（基於XML），一種是采用註解的方式來實現（基於AspectJ）。 首先復習下AOP中一些比較重要的概念： Joinpoint（連接點）

Appium python自動化測試系列之Capability介紹（五）

語言 路徑 pla apk 過程 5.1 基礎 針對 driver ?5.1 Capability介紹 5.1.1 什麽是Capability 在講capability之前大家是否還記得在講log時給大家看過的啟動時的日誌？在我們的整個啟動日誌中會出現一些配置信息，其實那些

dubbo系列之spring boot核心配置讀取（三）

版本說明 springboot starter : 0.1.1 dubbo版本: 2.6.2 自動配置類 @Configuration @ConditionalOnProperty(prefix = DUBBO_PREFIX, name = "enabled",

dubbo系列之ServiceBean介紹（六）

前言 前面幾篇文章中，我們瞭解了spring是如何解析@Service，@Reference註解的，今天主要講的是服務暴露者的一個非常重要的類，ServiceBean , 每個暴露出去的服務都會生成一個ServiceBean. ServiceBean 該類的繼

Android進階篇之引導頁系列之ViewPager實現Animation動畫引導頁

小夥伴們，時隔很久，我又開始來BB了，勿噴，，今天繼續上次所說的引導頁之旅。 其實想實現一個靜態的引導頁還是很容易的，就是一個ViewPager，但是想對每一頁實現動畫效果，比如第一頁有一幾朵雲在飄啊飄！，想實現這種效果對只要瞭解過Animation動畫的人來說也不難實現。

arcgis for js 開發系列之地圖實現右鍵點選事件

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01//EN" "http://www.w3.org/TR/html4/strict.dtd"> <html> <head> <meta http-equiv

[手把手系列之二]實現多層神經網路

完整程式碼：>>點我 歡迎star,fork,一起學習 網路用途 或者說應用場景：使用單層神經網路來識別一張圖片是否是貓咪的圖片。 數學表示 給定一張圖片XX 送到網路中，判斷這張圖片是否是貓咪的照片？ 網路架構 多層

dubbo系列之@Service註解解析原理（四）

前言 前面幾篇文章，講的是除錯環境搭建，配置解析讀取，本文講的是dubbo如何解析@service註解的，瞭解這些東西對於真正使用dubbo來說，沒有直接的東西，但是這個是我後面要寫的dubbo核心功能原始碼解析的前提，前後連貫，這樣才能瞭解的更加清晰一點。 解

Dubbo原始碼學習--SPI實現@SPI和@Adaptive

上一篇部落格 Dubbo入門學習--Dubbo服務提供介面SPI機制我們已經簡單介紹了Dubbo的SPI機制，這篇部落格我們來剖析一下Dubbo是如何使用SPI機制的，在介面中使用@SPI("值")使用預設的實現類，如果我們不想使用預設的實現類是如何處理的。1、獲取指定實現類

內容解刨——dubbo自己的SPI實現

dubbo的核心：SPI、AOP、IOC、compiler(動態編譯) 這篇文章主要明SPI 1、什麼是SPI SPI英文為Service Provider Interface。 面向物件的設計裡，模組與模組之間是基於介面程式設計，模組之間

dubbo系列之springboot 除錯環境搭建（一）

前言 本文是dubbo系列的第一篇，在正式講解dubbo的原始碼之前，需要搭建一套dubbo的樣例，用於我們閱讀原始碼以及理解dubbo的核心功能，本文是以springboot為基礎的，其他的通過xml配置的太麻煩了。 版本說明 springboot start

PHP函式原始碼之SESSION實現機制

Session是以擴充套件的形式嵌入到PHP核心的，所以我們可以把Session當成擴充套件來看待。 一般擴充套件被載入到PHP會經過下面幾個過程 #define PHP_MINIT_FUNCTION      ZEND_MODULE_STARTU

ES學習筆記之-Translog實現機制的理解

就是 文件 實時 應用場景 Lucene 索引操作 解決 模擬 結果 ES作為一個NoSQL，典型的應用場景就是存儲數據。即用戶可以通過api添加數據到es中。由於Lucene內部的實現， 每次添加的數據並不是實時落盤的。而是在內存中維護著索引信息，直到緩沖區滿了或者顯式的

Dubbo系列之 （二）Registry註冊中心-註冊（1）

# 引導 dubbo的服務的註冊與發現，需要通過第三方註冊中心來協助完成，目前dubbo支援的註冊中心包括 zookeeper,consul,etcd3,eureka,nacas,redis,sofa。這些註冊中心的不同支援在之後的篇章進行分享。 # 基礎鋪墊 在鋪墊一些基礎內容之前，根據如果下幾個問題來進行

Dubbo系列之 （二）Registry註冊中心-註冊（2）

# 引導 本章主要介紹下AbstractRegistry、FailbackRegistry的作用和原始碼。 # AbstractRegistry 首先，直接引出這個類的作用，該類主要把服務提供者資訊快取本地檔案上，檔案目錄是：當前使用者目錄下的/.dubbo/dubbo-registry-${applicat

Dubbo系列之 （四）服務訂閱（1）

# 輔助連結 ## [Dubbo系列之 （一）SPI擴充套件 ](https://www.cnblogs.com/liferecord/p/13445631.html) ## [Dubbo系列之 （二）Registry註冊中心-註冊（1）](https://www.cnblogs.com/liferecord

asyncio系列之Lock實現

1 import types 2 import select 3 import time 4 import socket 5 import functools 6 import collections 7 8 9 class Future: 10 def _