http://www.youzitool.com/blog/15.html
工作中,遇到部分業(yè)務(wù)經(jīng)常動(dòng)態(tài)變化麸俘,或者在不發(fā)布系統(tǒng)的前提下,對(duì)業(yè)務(wù)規(guī)則進(jìn)行調(diào)整拜效。那么可以將這部分業(yè)務(wù)邏輯改寫成Groovy腳本來執(zhí)行嘲碧,那么就可以在業(yè)務(wù)運(yùn)行過程中動(dòng)態(tài)更改業(yè)務(wù)規(guī)則望抽,達(dá)到快速響應(yīng)。
Case1: Groovy動(dòng)態(tài)編譯執(zhí)行
閑話少說辑奈,直接上代碼:
static Compilable engine; //獲取groovy編譯類
static {
ScriptEngineManager manager = new ScriptEngineManager();
engine = (Compilable) manager.getEngineByName("groovy");
}
public static Object execute(String scriptText, Map<?, ?> context) {
CompiledScript script = engine.compile(scriptText); // 這個(gè)地方需要使用緩存稍计,達(dá)到編譯一次,多次執(zhí)行。
if (script != null) {
ScriptContext scriptContext = new SimpleScriptContext();
Set<?> its = context.entrySet(); //上下文參數(shù)
for(Object o:its){
@SuppressWarnings("rawtypes")
Entry entry = (Entry)o;
scriptContext.setAttribute(
LangUtil.getString(entry.getKey()),
entry.getValue(), ScriptContext.ENGINE_SCOPE); //copy到groovy執(zhí)行環(huán)境上下文
}
return script.eval(scriptContext); //執(zhí)行g(shù)roovy腳本
}
那么腳本里面就可以使用很靈活的規(guī)則,如果需要使用bean,需要在上文下參數(shù)將bean工作傳遞進(jìn)去揪垄。
以上是使用java的ScriptEngineManager來動(dòng)態(tài)編譯、執(zhí)行Groovy。
如果你覺得這種執(zhí)行方式效率比較低,那么還可以使用groovy的ClassLoade將其編譯成對(duì)象來執(zhí)行士败。
ClassLoader parent = getClass().getClassLoader();
GroovyClassLoader loader = new GroovyClassLoader(parent);
Class groovyClass = loader.parseClass(new File("src/test/groovy/script/HelloWorld.groovy")); //也可以直接使用String(腳本內(nèi)容)
GroovyObject groovyObject = (GroovyObject) groovyClass.newInstance();
Object[] args = {};
groovyObject.invokeMethod("run", args);
如果你希望這個(gè)groovy腳本是嵌入在自己的抽象類中執(zhí)行的,那么也可以使用如下方法:
GroovyClassLoader gcl = new GroovyClassLoader();
Class clazz = gcl.parseClass(myStringwithGroovyClassSource, "SomeName.groovy");
Object aScript = clazz.newInstance();
MyInterface myObject = (MyInterface) aScript;
myObject.interfaceMethod();
參考鏈接:http://docs.codehaus.org/display/GROOVY/Embedding+Groovy
當(dāng)然對(duì)底層服務(wù)的封裝就根據(jù)不同業(yè)務(wù)系統(tǒng)有所不同,只要底層服務(wù)封裝的好隅熙,那么在groovy腳本里就可以只使用一套封裝之后的API來完成各種業(yè)務(wù)實(shí)現(xiàn),避免了各種直接調(diào)用bean的情況出現(xiàn)。
Case2: Java動(dòng)態(tài)編譯執(zhí)行
以上執(zhí)行方式已經(jīng)在生產(chǎn)環(huán)境得到驗(yàn)證,但最近壓測(cè)發(fā)現(xiàn),不管使用Case1中的哪種方法執(zhí)行的QPS都沒有直接使用Java代碼的執(zhí)行效率高。那么是否可以將Java代碼動(dòng)態(tài)編譯删窒。結(jié)果當(dāng)然是suer,在JDK6及以上中已經(jīng)支持了java代碼動(dòng)態(tài)編譯(JavaCompiler)
Java的動(dòng)態(tài)編譯對(duì)源提供了多個(gè)渠道。可以是字符串,可以是文本文件库快,也可以是編譯過的字節(jié)碼文件(.class文件),甚至可以是存放在數(shù)據(jù)庫中的明文代碼或是字節(jié)碼。匯總成一句話财喳,只要是符合Java規(guī)范的就都可以在運(yùn)行期動(dòng)態(tài)加載,其實(shí)現(xiàn)方式就是實(shí)現(xiàn)JavaFileObject接口,重寫getCharContent、openInputStream、openOutputStream,或者實(shí)現(xiàn)JDK已經(jīng)提供的兩個(gè)SimpleJavaFileObject、ForwardingJavaFileObject
public void compileClass(String name, String code) {
private final JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();
private final FileManager manager = new FileManager(this.compiler); //自定義FileManager
List<Source> list = new ArrayList<Source>();
list.add(new Source(name, JavaFileObject.Kind.SOURCE, code)); //輸入
StringWriter stringWriter = new StringWriter();
this.compiler.getTask(stringWriter, this.manager, null, null, null, list).call();
Output mc = this.manager.getOutput(name); //輸出
if (mc != null) {
byte[] array = mc.toByteArray(); //轉(zhuǎn)換成byte[]
return defineClass(name, array, 0, array.length); //需要繼承ClassLoader
}
}
public class FileManager extends ForwardingJavaFileManager<StandardJavaFileManager> {
protected final Map<String, Output> map = new HashMap<String, Output>();
public FileManager(JavaCompiler compiler) {
super(compiler.getStandardFileManager(null, null, null)); } //取得文件管理器
@Override
public Output getJavaFileForOutput
(Location location, String name, JavaFileObject.Kind kind, FileObject source) {
Output mc = new Output(name, kind); //與文件連接
this.map.put(name, mc);
return mc;
}
public Output getOutput(String name) {
return map.get(name);
}
}
public class Output extends SimpleJavaFileObject {
private final ByteArrayOutputStream baos = new ByteArrayOutputStream();
public Output(String name, Kind kind) {
super(URI.create("dynamic:///" + name.replace('.', '/') + kind.extension), kind); } //URI
byte[] toByteArray() { //外部調(diào)用,生成Class
return this.baos.toByteArray();
}
@Override
public ByteArrayOutputStream openOutputStream() {
return this.baos;
}
}
public class Source extends SimpleJavaFileObject {
private final String content;
public Source(String name, Kind kind, String content) {
super(URI.create("dynamic:///" + name.replace('.', '/') + kind.extension), kind);
this.content = content;
}
@Override
public CharSequence getCharContent(boolean ignore) {
return this.content;
}
}