日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關咨詢
選擇下列產(chǎn)品馬上在線溝通
服務時間:8:30-17:00
你可能遇到了下面的問題
關閉右側工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Java 如何實現(xiàn)動態(tài)腳本?

在平臺級的 Java 系統(tǒng)中,動態(tài)腳本技術是不可或缺的一環(huán)。本文分享了一種 Java 動態(tài)腳本實現(xiàn)方案,給出了其中的關鍵技術點,并就類重名問題、生命周期、安全問題等做出進一步討論,歡迎同學們共同交流。

前言

繁星是一個數(shù)據(jù)服務平臺,其核心功能是:用戶配置一段 SQL,繁星產(chǎn)出對應的 HSF/TR/SOA/Http 取數(shù)接口。

繁星引擎流程圖如下:

?

??

??

一次查詢請求經(jīng)過引擎的管道,被各個閥門處理后就得到了相應的結果數(shù)據(jù)。圖中高亮的兩個閥門就是本文討論的重點:前置腳本與后置腳本。

溫馨提示:動態(tài)腳本就意味著代碼發(fā)布跳過了公司內(nèi)部發(fā)布平臺,做不到監(jiān)控、灰度、回滾三板斧,容易引發(fā)線上故障,因此業(yè)務系統(tǒng)中強烈不推薦使用該技術。

當然 Java 動態(tài)腳本技術一般使用場景也比較少,主要在平臺性質(zhì)的系統(tǒng)中可能用到,比如 leetcode 平臺,D2 平臺,繁星數(shù)據(jù)服務平臺等。本文權當技術探索和交流。

功能描述

對 Javascript 熟悉的同學知道,eval() 函數(shù),例如:

eval('console.log(2+3)')

就會在控制臺中打出 5。

這里我們要做的和 eval 類似,就是希望輸入一段 Java 代碼,服務器按照代碼中的邏輯執(zhí)行。在繁星中前置腳本的功能就是可以對用戶的輸入?yún)?shù)進行自定義的處理,后置腳本的功能就是可以對數(shù)據(jù)庫中查詢到的結果做進一步加工。

為什么是 Java 腳本?

Groovy

要實現(xiàn)動態(tài)腳本的需求,首先可能會想到 Groovy,但是使用 Groovy 有幾大缺點:

  • Groovy 雖然也是運行在 JVM,但是語法和 Java 有一些差異,對于只會 Java 的同學來說有一定學習成本。
  • 動態(tài)類型,缺乏約束。有時候太過于靈活自由也是缺點,尤其是對于平臺說來。
  • 需要額外引入 Groovy 的引擎 jar 包,大小 6.2M,屬實不小,對于有代碼強迫癥的我來說這會是一個重要考慮因素。

Java

采用 Java 來實現(xiàn)動態(tài)腳本的功能有以下優(yōu)點:

  • 學習成本低,在阿里最主要的語言就是 Java,會 Java 幾乎是每個工程師必備的技能,因此上手難度幾乎為零。
  • Java 可以規(guī)定接口約束,從而使得用戶寫的前后置腳本整齊劃一,方便管理和治理。
  • 可以實時編譯和錯誤提示,方便用戶及時訂正問題。

實現(xiàn)方式

代碼工程說明

本文的代碼工程:https://kbtdatacenter-read.oss-cn-zhangjiakou.aliyuncs.com/fusu-share/dynamic-script.zip

--dynamic-script 
------advance-discuss //深度討論腳本動態(tài)化技術中的一些細節(jié)
------code-javac //使用代碼執(zhí)行編譯加載運行任務
------command-javac //演示用命令行的方式動態(tài)編譯和加載java類
------facade //提供單獨的接口包,方便整個演示過程流暢進行

實現(xiàn)方案設計

我們首先定義好一個接口,例如 Animal,然后用戶在自己的代碼中實現(xiàn) Animal 接口。相當于用戶提供的是 Animal 的實現(xiàn)類 Cat,這樣系統(tǒng)加載了用戶的 Java 代碼后,可以很方便的利用 Java 多態(tài)特性,訪問到對應的方法。這樣既方便了用戶書寫規(guī)范,同時平臺使用起來也簡單。

使用控制臺命令行

首先回顧如何使用命令行來編譯 Java 類,并且運行。

首先對 facade 模塊打一個 jar 包,方便后續(xù)依賴:

cd 項目根目錄 
mvn install

進入到模塊 command-javac 的 resources 文件夾下(絕對路徑因人而異):

# 進入到Cat.java所在的目錄 
cd /Users/fusu/d/group/fusu-share/dynamic-script/command-javac/src/main/resources
# 使用命令行工具javac編譯,linux/mac 上cp分隔符使用 : windown使用 ;
javac -cp .:/Users/fusu/d/group/fusu-share/dynamic-script/facade/target/facade-1.0.jar Cat.java
# 運行
java -cp .:/Users/fusu/d/group/fusu-share/dynamic-script/facade/target/facade-1.0.jar Cat
# 得到結果
# > I'm Cat Main

使用 Process 調(diào)用 javac 編譯

有了上面的控制臺命令行操作,很容易想到用 Java 的 Process 類調(diào)用命令行工具執(zhí)行 javac 命令,然后使用 URLClassLoader 來加載生成的 class 文件。代碼位于模塊 command-javac 下的 ProcessJavac.java 文件中,核心代碼如下:

//項目所在路徑 
String projectPath = PathUtil.getAppHomePath();

Process process = null;

String cmd = String.format("javac -cp .:%s/facade/target/facade-1.0.jar -d %s/command-javac/src/main/resources %s/command-javac/src/main/resources/Cat.java", projectPath, projectPath, projectPath);

System.out.println(cmd);

process = Runtime.getRuntime().exec(cmd);

// 打印程序輸出
readProcessOutput(process);

int exitVal = process.waitFor();
if (exitVal == 0) {
System.out.println("javac執(zhí)行成功!" + exitVal);
} else {
System.out.println("javac執(zhí)行失敗" + exitVal);
return;
}

String classFilePath = String.format("%s/command-javac/src/main/resources/Cat.class", projectPath);
String urlFilePath = String.format("file:%s", classFilePath);
URL url = new URL(urlFilePath);
URLClassLoader classLoader = new URLClassLoader(new URL[]{url});

Class catClass = classLoader.loadClass("Cat");
Object obj = catClass.newInstance();
if (obj instanceof Animal) {
Animal animal = (Animal) obj;
animal.hello("Kitty");
}
//會得到結果: Hello,Kitty! 我是Cat。

用編程方式編譯和加載

上面兩種方式都有一個明顯的缺點,就是需要依賴于 Cat.java 文件,以及必須產(chǎn)生 Cat.class 文件。在繁星平臺中,自然希望這個過程都在內(nèi)存中完成,盡量減少 IO 操作,因此使用編程方式來編譯 Java 代碼就顯得很有必要了。代碼位于模塊 code-javac 下的 CodeJavac.java 文件中,核心代碼如下:

//類名 
String className = "Cat";
//項目所在路徑
String projectPath = PathUtil.getAppHomePath();
String facadeJarPath = String.format(".:%s/facade/target/facade-1.0.jar", projectPath);

//需要進行編譯的代碼
Iterable compilationUnits = new ArrayList() {{
add(new JavaSourceFromString(className, getJavaCode()));
}};

//編譯的選項,對應于命令行參數(shù)
List options = new ArrayList<>();
options.add("-classpath");
options.add(facadeJarPath);

//使用系統(tǒng)的編譯器
JavaCompiler javaCompiler = ToolProvider.getSystemJavaCompiler();

StandardJavaFileManager standardJavaFileManager = javaCompiler.getStandardFileManager(null, null, null);
ScriptFileManager scriptFileManager = new ScriptFileManager(standardJavaFileManager);

//使用stringWriter來收集錯誤。
StringWriter errorStringWriter = new StringWriter();

//開始進行編譯
boolean ok = javaCompiler.getTask(errorStringWriter, scriptFileManager, diagnostic -> {
if (diagnostic.getKind() == Diagnostic.Kind.ERROR) {

errorStringWriter.append(diagnostic.toString());
}
}, options, null, compilationUnits).call();

if (!ok) {
String errorMessage = errorStringWriter.toString();
//編譯出錯,直接拋錯。
throw new RuntimeException("Compile Error:{}" + errorMessage);
}

//獲取到編譯后的二進制數(shù)據(jù)。
final Map allBuffers = scriptFileManager.getAllBuffers();
final byte[] catBytes = allBuffers.get(className);

//使用自定義的ClassLoader加載類
FsClassLoader fsClassLoader = new FsClassLoader(className, catBytes);
Class catClass = fsClassLoader.findClass(className);
Object obj = catClass.newInstance();
if (obj instanceof Animal) {
Animal animal = (Animal) obj;
animal.hello("Moss");
}

//會得到結果: Hello,Moss! 我是Cat。

代碼中主要使用到了系統(tǒng)編譯器 JavaCompiler,調(diào)用它的 getTask 方法就相當于命令行中執(zhí)行 javac,getTask 方法中使用自定義的 ScriptFileManager 來搜集二進制結果,以及使用 errorStringWriter 來搜集編譯過程中可能出錯的信息。最后借助一個自定義類加載器 FsClassLoader 來從二進制數(shù)據(jù)中加載出類 Cat。

深入討論

上文介紹了動態(tài)腳本的實現(xiàn)關鍵點,但是還有諸多問題需要討論,筆者把主要的幾個問題拋出來,簡單討論一下。

ClassLoader 范圍問題

JVM 的類加載機制采用雙親委派模式,類加載器收到加載請求時,會委派自己的父加載器去執(zhí)行加載任務,因此所有的加載任務都會傳遞到頂層的類加載器,只有當父加載器無法處理時,子加載器才自己去執(zhí)行加載任務。下面這幅圖相信大家已經(jīng)很熟悉了。

?

??

??

JVM 對于一個類的唯一標識是 (Classloader,類全名),因此可能出現(xiàn)這種情況,接口 Animal 已經(jīng)加載了,但是我們用 CustomClassLoader 去加載 Cat 時,提示說 Animal 找不到。這就是因為 Animal 和 Cat 不是被同一個 Classloader 加載的。

由于 defineClass 方法是 protected 的,因此要用 byte[] 來加載 class 就需要自定義一個classloader,如何指定這個 Classloader 的父加載器就比較有講究了。

公司內(nèi)部的 Java 系統(tǒng)都是采用的 pandora,pandora 有自己的類加載器以及線程加載器,因此我們以接口 Animal 的加載器 animalClassLoader 為標準,將線程 ClassLoader 設置為animalClassLoader,同時將自定義的 ClassLoader 的父加載器指定為 animalClassLoader。代碼位于模塊 advance-discuss 下,參考代碼如下:

/*FsClassLoader.java*/ 
public FsClassLoader(ClassLoader parentClassLoader, String name, byte[] data) {
super(parentClassLoader);
this.fullyName = name;
this.data = data;
}


/*AdvanceDiscuss.java*/

//接口的類加載器
ClassLoader animalClassLoader = Animal.class.getClassLoader();
//設置當前的線程類加載器
Thread.currentThread().setContextClassLoader(animalClassLoader);
//...
//使用自定義的ClassLoader加載類
FsClassLoader fsClassLoader = new FsClassLoader(animalClassLoader, className, cat

通過這些保障,就不會出現(xiàn)找不到類的問題了。

類重名問題

當我們只動態(tài)加載一個類時,自然不用擔心類全名重復的問題,但是如果需要加載多個相同類時,就有必要進行特殊處理了,可以利用正則表達式捕獲用戶的類名,然后增加隨機字符串的方式來規(guī)避重名問題。

從上文中,我們知道 JVM 對于一個類的唯一標識是(Classloader,類全名),因此只要能保證我們自定義的 Classloader 是不同的對象,也能夠避免類重名的問題。

Class 生命周期問題

Java 腳本動態(tài)化必須考慮垃圾回收的問題,否則隨著 Class 被加載的越來越多,系統(tǒng)的內(nèi)存很快就不夠用了。我們知道在 JVM 中,對象實例在沒有被引用后會被 GC (Garbage Collection 垃圾回收),Class 作為 JVM 中一個特殊的對象,也會被 GC(清空方法區(qū)中 Class 的信息和堆區(qū)中的 java.lang.Class 對象。這時 Class 的生命周期就結束了)。

Class 要被回收,需要滿足以下三個條件:

  • NoInstance:該類所有的實例都已經(jīng)被 GC。
  • NoClassLoader:加載該類的 ClassLoader 實例已經(jīng)被 GC。
  • NoReference:該類的 java.lang.Class 沒有被引用 (XXX.class,使用了靜態(tài)變量/方法)。

從上面三個條件可以推出,JVM 自帶的類加載器(Bootstrap 類加載器、Extension 類加載器)所加載的類,在 JVM 的生命周期中始終不會被 GC。自定義的類加載器所加載的 Class 是可以被 GC 的,因此在編碼時,自定義的 Classloader 一定做成局部變量,讓其自然被回收。

為了驗證 Class 的 GC 情況,我們寫一個簡單的循環(huán)來觀察,模塊 advance-discuss 下的AdvanceDiscuss.java 文件中:

for (int i = 0; i < 1000000; i++) { 
//編譯加載并且執(zhí)行
compileAndRun(i);

//10000個回收一下
if (i % 10000 == 0) {
System.gc();
}
}

//強制進行回收
System.gc();
System.out.println("休息10s");
Thread.currentThread().sleep(10 * 1000);

打開 Java 自帶的 jvisualvm 程序(位于 JAVA_HOME/bin/jvisualvm),可以可視化的觀看到 JVM 的情況。

?

??

??

在上圖中可以看到加載類的變化圖以及堆大小呈鋸齒狀,說明動態(tài)加載類能夠被有效的被回收。

安全問題

讓用戶寫腳本,并且在服務器上運行,光是想想就知道是一件非常危險的事情,因此如何保證腳本的安全,是必須嚴肅對待的一個問題。

類的白名單及黑名單機制

在用戶寫的 Java 代碼中,我們需要規(guī)定用戶允許使用的類范圍,試想用戶調(diào)用 File 來操作服務器上的文件,這是非常不安全的。javassist 庫可以對 Class 二進制文件進行分析,借助該庫我們可以很容易地得到 Class 所依賴的類。代碼位于模塊 advance-discuss 下的 JavassistUtil.java 文件中,以下是核心代碼:

public static Set getDependencies(InputStream is) throws Exception { 

ClassFile cf = new ClassFile(new DataInputStream(is));
ConstPool constPool = cf.getConstPool();
HashSet set = new HashSet<>();
for (int ix = 1, size = constPool.getSize(); ix < size; ix++) {
int descriptorIndex;
if (constPool.getTag(ix) == ConstPool.CONST_Class) {
set.add(constPool.getClassInfo(ix));
} else if (constPool.getTag(ix) == ConstPool.CONST_NameAndType) {
descriptorIndex = constPool.getNameAndTypeDescriptor(ix);
String desc = constPool.getUtf8Info(descriptorIndex);
for (int p = 0; p < desc.length(); p++) {
if (desc.charAt(p) == 'L') {
set.add(desc.substring(++p, p = desc.indexOf(';', p)).replace('/', '.'));
}
}
}
}
return set;
}

拿到依賴后,就可以首先使用白名單來過濾,以下這些包或類只涉及簡單的數(shù)據(jù)操作和處理,是被允許的:

java.lang, 
java.util,
com.alibaba.fastjson,
java.text,
[Ljava.lang (java.lang下的數(shù)組,例如 `String[]`)
[D (double[])
[F (float[])
[I (int[])
[J (long[])
[C (char[])
[B (byte[])
[Z (boolean[])

但是有個別的包下的類也比較危險,需要過濾掉,這時候就需要用黑名單再做一次篩選,這些包或類是不被允許的:

java.lang.Thread 
java.lang.reflect

線程隔離

有可能用戶的代碼中包含死循環(huán),或者執(zhí)行時間特別長,對于這種有問題的邏輯在編譯時是無法感知的,因此還需要使用單獨的線程來執(zhí)行用戶的代碼,當出現(xiàn)超時或者內(nèi)存占用過大的情況就直接 kill。

緩存問題

上面討論的都是從編譯到執(zhí)行的完整過程,但是有時候用戶的代碼沒有變更,我們?nèi)?zhí)行時就沒有必要再次去編譯了,因此可以設計一個緩存策略,當用戶代碼沒有發(fā)生變更時,就使用懶加載策略,當用戶的代碼發(fā)生了變更就釋放之前加載好的 Class,重新加載新的代碼。

及時加載問題

當系統(tǒng)重啟時,相當于所有的類都被釋放了需要重新加載,對于一些比較重要的腳本,可能短暫的懶加載時間也是難以接受的,對于這種就需要單獨搜集,在系統(tǒng)啟動的時候根據(jù)系統(tǒng)一起加載進內(nèi)存,這樣就可以當健康檢查通過時,保證類已經(jīng)加載好了,從而有效縮短響應時間。

后記

由于篇幅問題,緩存問題、及時加載問題只做了簡單的討論。當然 Java 動態(tài)腳本技術還涉及到很多其他細節(jié),需要在使用過程中不斷總結。也歡迎大家一起交流~


分享標題:Java 如何實現(xiàn)動態(tài)腳本?
文章出自:http://www.dlmjj.cn/article/codjecs.html