完美世界辰东,好看的小说,梦入神机

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案

使用RelProxy提高Java開(kāi)發(fā)效率

RelProxy 旨在通過(guò)下列兩種方式提高開(kāi)發(fā)效率：

可以在生產(chǎn)環(huán)境下修改用戶(hù)代碼，而不需要重新加載整個(gè)應(yīng)用。

提高開(kāi)發(fā)效率，避免花費(fèi)過(guò)多的時(shí)間加載應(yīng)用且對(duì)性能不會(huì)有影響。

兩個(gè)目標(biāo)都要求在你的應(yīng)用中增加一些 RelProxy 代碼，注冊(cè)成一種典型的監(jiān)聽(tīng)、回調(diào)模式。這是一種“侵入”的方式。

如果你是一名Java 框架或獨(dú)立 Java 通用服務(wù)模塊的開(kāi)發(fā)者，可以將 RelProxy Java 嵌入到你的框架中，這樣能透明地為框架的終端用戶(hù)提供代碼自動(dòng)加載功能，只需要進(jìn)行一些必要的配置，而無(wú)需調(diào)用 RelProxy API。

對(duì)使用 Java 版的 RelProxy，有兩種 API 可供調(diào)用：

JProxy 及其相關(guān)類(lèi)：主要是靜態(tài)方法

Java 腳本 API：基于接口

第二種方式更適合將 RelProxy 嵌入到你的 Java 框架中，這種方式是基于接口的，在你的 API 中無(wú)需暴露公共 RelProxy 類(lèi)，因?yàn)樵诳蚣苤袝?huì)執(zhí)行啟動(dòng)程序。我將使用比較簡(jiǎn)單的 API：JProxyScriptEngineFactory.create()。

JProxyScriptEngine 的功能與 Jproxy 相同，也就是說(shuō)具有相同的方法。只是這種情況下，只需要使用接口。

一個(gè)簡(jiǎn)單的例子是演示如何嵌入 RelProxy 的***方式。這個(gè)例子是 RelProxy 的示例倉(cāng)庫(kù)中包含的 RelProxyBuiltin（relproxy_builtin_ex 項(xiàng)目中）。它定義了兩個(gè)監(jiān)聽(tīng)器來(lái)實(shí)現(xiàn)注冊(cè)用戶(hù)端的代碼，一個(gè)監(jiān)聽(tīng)器顯示選項(xiàng)（option），另一個(gè)執(zhí)行選擇的行為。

這個(gè)迷你框架和示例使用 NetBeans 和 Maven 開(kāi)發(fā)完成。

有兩個(gè)包：

com.innowhere.relproxy_builtin_ex ：迷你框架。子包 com.innowhere.relproxy_builtin_ex.impl 只包含一個(gè)非公共的類(lèi)。

com.innowhere.relproxy_builtin_ex_main ：一個(gè)簡(jiǎn)單的使用示例。

迷你框架（公共類(lèi)和接口）：

RelProxyBuiltinRoot.java

package com.innowhere.relproxy_builtin_ex;

import com.innowhere.relproxy_builtin_ex.impl.RelProxyBuiltinImpl;

public class RelProxyBuiltinRoot

{

private final static RelProxyBuiltinImpl SINGLETON = new RelProxyBuiltinImpl();

public static RelProxyBuiltin get()

{

return SINGLETON;

}

RelProxyBuiltin.java

package com.innowhere.relproxy_builtin_ex;

import com.innowhere.relproxy.jproxy.JProxyScriptEngine;

import java.io.InputStream;

import java.io.PrintStream;

public interface RelProxyBuiltin

{

public JProxyScriptEngine getJProxyScriptEngine();

public void addOutputListener(OutputListener listener);

public void removeOutputListener(OutputListener listener);

public int getOutputListenerCount();

public void addCommandListener(CommandListener listener);

public void removeCommandListener(CommandListener listener);

public int getCommandListenerCount();

public void runLoop(InputStream in,PrintStream out);

}

OutputListener.java

package com.innowhere.relproxy_builtin_ex;

import java.io.PrintStream;

public interface OutputListener

{

public void write(PrintStream out);

}

CommandListener.java

package com.innowhere.relproxy_builtin_ex;

import java.io.PrintStream;

public interface CommandListener

{

public void execute(String command,String input,PrintStream out);

}

現(xiàn)在看一下實(shí)現(xiàn)細(xì)節(jié)，該類(lèi)演示了怎樣簡(jiǎn)單地內(nèi)嵌 RelProxy：

RelProxyBuiltinImpl.java

package com.innowhere.relproxy_builtin_ex.impl;

import com.innowhere.relproxy.jproxy.JProxyScriptEngine;

import com.innowhere.relproxy.jproxy.JProxyScriptEngineFactory;

import com.innowhere.relproxy_builtin_ex.CommandListener;

import com.innowhere.relproxy_builtin_ex.OutputListener;

import com.innowhere.relproxy_builtin_ex.RelProxyBuiltin;

import java.io.InputStream;

import java.io.PrintStream;

import java.util.LinkedHashSet;

import java.util.Scanner;

public class RelProxyBuiltinImpl implements RelProxyBuiltin

{

protected JProxyScriptEngine jProxyEngine = null;

protected LinkedHashSet outListeners = new LinkedHashSet();

protected LinkedHashSet commandListeners = new LinkedHashSet();

@Override

public JProxyScriptEngine getJProxyScriptEngine()

{

if (jProxyEngine == null) jProxyEngine = (JProxyScriptEngine)JProxyScriptEngineFactory.create().getScriptEngine();

return jProxyEngine;

}

public JProxyScriptEngine getJProxyScriptEngineIfConfigured()

{

if (jProxyEngine == null || !jProxyEngine.isEnabled())

return null;

return jProxyEngine;

}

@Override

public void addOutputListener(OutputListener listener)

{

JProxyScriptEngine jProxy = getJProxyScriptEngineIfConfigured();

if (jProxy != null)

{

listener = jProxy.create(listener,OutputListener.class);

}

outListeners.add(listener);

}

@Override

public void removeOutputListener(OutputListener listener)

{

JProxyScriptEngine jProxy = getJProxyScriptEngineIfConfigured();

if (jProxy != null)

{

listener = jProxy.create(listener,OutputListener.class);

}

outListeners.remove(listener);

}

@Override

public int getOutputListenerCount()

{

return outListeners.size();

}

@Override

public void addCommandListener(CommandListener listener)

{

JProxyScriptEngine jProxy = getJProxyScriptEngineIfConfigured();

if (jProxy != null)

{

listener = jProxy.create(listener,CommandListener.class);

}

commandListeners.add(listener);

}

@Override

public void removeCommandListener(CommandListener listener)

{

JProxyScriptEngine jProxy = getJProxyScriptEngineIfConfigured();

if (jProxy != null)

{

listener = jProxy.create(listener,CommandListener.class);

}

commandListeners.remove(listener);

}

@Override

public int getCommandListenerCount()

{

return commandListeners.size();

}

@Override

public void runLoop(InputStream in,PrintStream out)

{

Scanner scanner = new Scanner(in);

while(true)

{

out.print("Enter phrase:");

String input = scanner.nextLine();

out.println("Command list:");

for(OutputListener listener : outListeners)

listener.write(out);

out.print("Enter command (or quit):");

String command = scanner.nextLine();

if ("quit".equals(command))

break;

for(CommandListener listener : commandListeners)

listener.execute(command,input,out);

}

這三個(gè)方法足以解釋怎樣啟動(dòng) RelProxy Java 引擎，怎樣簡(jiǎn)單地使用指令監(jiān)聽(tīng)器來(lái)注冊(cè)熱加載。

RelProxyBuiltinImpl.java (部分)

@Override

public JProxyScriptEngine getJProxyScriptEngine()

{

if (jProxyEngine == null) jProxyEngine = (JProxyScriptEngine)JProxyScriptEngineFactory.create().getScriptEngine();

return jProxyEngine;

}

public JProxyScriptEngine getJProxyScriptEngineIfConfigured()

{

if (jProxyEngine == null || !jProxyEngine.isEnabled())

return null;

return jProxyEngine;

}

@Override

public void addOutputListener(OutputListener listener)

{

JProxyScriptEngine jProxy = getJProxyScriptEngineIfConfigured();

if (jProxy != null)

{

listener = jProxy.create(listener,OutputListener.class);

}

outListeners.add(listener);

}

公共方法 RelProxyBuiltin.getJProxyScriptEngine() 必須在啟動(dòng)時(shí)執(zhí)行，用于配置 RelProxy。如果沒(méi)有配置，RelProxy 就不起作用。

請(qǐng)記住，通過(guò) create(…) 創(chuàng)建的代理對(duì)象需要能正確的執(zhí)行 hashCode() 方法和 equals(Object) 方法，監(jiān)聽(tīng)器集合、監(jiān)聽(tīng)記錄依賴(lài)這兩個(gè)方法來(lái)區(qū)別監(jiān)聽(tīng)器對(duì)象。

這是基于控制臺(tái)的示例代碼（名稱(chēng)與 JUnit 類(lèi)似，但確實(shí)不是 JUnit 的測(cè)試示例）：

Main.java

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

package com.innowhere.relproxy_builtin_ex_main;

import com.innowhere.relproxy.RelProxyOnReloadListener;

import com.innowhere.relproxy.jproxy.JProxy;

import com.innowhere.relproxy.jproxy.JProxyCompilerListener;

import com.innowhere.relproxy.jproxy.JProxyConfig;

import com.innowhere.relproxy.jproxy.JProxyDiagnosticsListener;

import com.innowhere.relproxy.jproxy.JProxyInputSourceFileExcludedListener;

import com.innowhere.relproxy.jproxy.JProxyScriptEngine;

import com.innowhere.relproxy_builtin_ex.CommandListener;

import com.innowhere.relproxy_builtin_ex.RelProxyBuiltin;

import com.innowhere.relproxy_builtin_ex.RelProxyBuiltinRoot;

import java.io.File;

import java.lang.reflect.Method;

import java.net.URL;

import java.util.Arrays;

import java.util.List;

import javax.tools.Diagnostic;

import javax.tools.DiagnosticCollector;

import javax.tools.JavaFileObject;

public class Main

{

public static void main(String[] args) throws Exception

{

new Main();

}

public Main()

{

// Note: NetBeans Console window works bad (no input) with Maven Test tasks http://stackoverflow.com/questions/3035351/broken-console-in-maven-project-using-netbeans

// this is why is not a really JUnit test.

setUp();

try

{

mainTest();

}

finally

{

tearDown();

}

System.exit(0);

}

public void setUp()

{

URL res = this.getClass().getResource("/"); // .../target/classes/

// Use example of RelProxy in development time:

String inputPath = res.getFile() + "/../../src/main/java/";

if (new File(inputPath).exists())

{

System.out.println("RelProxy to be enabled, development mode detected");

}

else

{

System.out.println("RelProxy disabled, production mode detected");

return;

}

JProxyInputSourceFileExcludedListener excludedListener = new JProxyInputSourceFileExcludedListener()

{

@Override

public boolean isExcluded(File file, File rootFolderOfSources)

{

String absPath = file.getAbsolutePath();

if (file.isDirectory())

{

return absPath.endsWith(File.separatorChar + "relproxy_builtin_ex");

}

else

{

return absPath.endsWith(File.separatorChar + Main.class.getSimpleName() + ".java");

}

};

String classFolder = null; // Optional

Iterable compilationOptions = Arrays.asList(new String[]{"-source","1.6","-target","1.6"});

long scanPeriod = 1000;

RelProxyOnReloadListener proxyListener = new RelProxyOnReloadListener() {

@Override

public void onReload(Object objOld, Object objNew, Object proxy, Method method, Object[] args) {

System.out.println("Reloaded " + objNew + " Calling method: " + method);

}

};

JProxyCompilerListener compilerListener = new JProxyCompilerListener(){

@Override

public void beforeCompile(File file)

{

System.out.println("Before compile: " + file);

}

@Override

public void afterCompile(File file)

{

System.out.println("After compile: " + file);

}

};

JProxyDiagnosticsListener diagnosticsListener = new JProxyDiagnosticsListener()

{

@Override

public void onDiagnostics(DiagnosticCollector diagnostics)

{

Listextends JavaFileObject>> diagList = diagnostics.getDiagnostics();

int i = 1;

for (Diagnostic diagnostic : diagList)

{

System.err.println("Diagnostic " + i);

System.err.println(" code: " + diagnostic.getCode());

System.err.println(" kind: " + diagnostic.getKind());

System.err.println(" line number: " + diagnostic.getLineNumber());

System.err.println(" column number: " + diagnostic.getColumnNumber());

System.err.println(" start position: " + diagnostic.getStartPosition());

System.err.println(" position: " + diagnostic.getPosition());

System.err.println(" end position: " + diagnostic.getEndPosition());

System.err.println(" source: " + diagnostic.getSource());

System.err.println(" message: " + diagnostic.getMessage(null));

i++;

}

};

RelProxyBuiltin rpbRoot = RelProxyBuiltinRoot.get();

JProxyScriptEngine engine = rpbRoot.getJProxyScriptEngine();

JProxyConfig jpConfig = JProxy.createJProxyConfig();

jpConfig.setEnabled(true)

.setRelProxyOnReloadListener(proxyListener)

.setInputPath(inputPath)

.setJProxyInputSourceFileExcludedListener(excludedListener)

.setScanPeriod(scanPeriod)

.setClassFolder(classFolder)

.setCompilationOptions(compilationOptions)

.setJProxyCompilerListener(compilerListener)

.setJProxyDiagnosticsListener(diagnosticsListener);

engine.init(jpConfig);

System.out.println("RelProxy running");

}

public void tearDown()

{

RelProxyBuiltin rpbRoot = RelProxyBuiltinRoot.get();

JProxyScriptEngine engine = rpbRoot.getJProxyScriptEngine();

engine.stop();

System.out.println("RelProxy stopped");

}

public void mainTest()

{

RelProxyBuiltin rpbRoot = RelProxyBuiltinRoot.get();

TestListener listener = new TestListener();

rpbRoot.addOutputListener(listener);

assertTrue(rpbRoot.getOutputListenerCount() == 1);

rpbRoot.removeOutputListener(listener);

assertTrue(rpbRoot.getOutputListenerCount() == 0);

rpbRoot.addOutputListener(listener);

CommandListener commandListener = listener.getCommandListener();

rpbRoot.addCommandListener(commandListener);

assertTrue(rpbRoot.getCommandListenerCount() == 1);

rpbRoot.removeCommandListener(commandListener);

assertTrue(rpbRoot.getCommandListenerCount() == 0);

rpbRoot.addCommandListener(commandListener);

rpbRoot.runLoop(System.in,System.out);

}

private static void assertTrue(boolean res)

{

if (!res) throw new RuntimeException("Unexpected Error");

}

看一下這段代碼：

Main.java （部分）

URL res = this.getClass().getResource("/"); // .../target/classes/

// Use example of RelProxy in development time:

String inputPath = res.getFile() + "/../../src/main/java/";

if (new File(inputPath).exists())

{

System.out.println("RelProxy to be enabled, development mode detected");

}

else

{

System.out.println("RelProxy disabled, production mode detected");

return;

}

JProxyInputSourceFileExcludedListener excludedListener = new JProxyInputSourceFileExcludedListener()

{

@Override

public boolean isExcluded(File file, File rootFolderOfSources)

{

String absPath = file.getAbsolutePath();

if (file.isDirectory())

{

return absPath.endsWith(File.separatorChar + "relproxy_builtin_ex");

}

else

{

return absPath.endsWith(File.separatorChar + Main.class.getSimpleName() + ".java");

}

};

我們獲取并注冊(cè)應(yīng)用源代碼的根目錄，該代碼“可能”會(huì)被重新加載。

我們需要排除框架代碼，因?yàn)檫@顯然不是用戶(hù)的代碼（不需要重新加載）。此外，還需要排除 Main.java 文件，該文件包含了測(cè)試代碼，也不需要重新加載，只有 TestListener.java 類(lèi)（與 Main.java 在同一文件夾下）需要（必需）重新加載。

*** TestListener.java 類(lèi)包含兩個(gè)監(jiān)聽(tīng)器，CommandListener 的實(shí)現(xiàn)采用匿名內(nèi)部類(lèi)的方式，主要目的是為了演示。

TestListener.java

package com.innowhere.relproxy_builtin_ex_main;

import com.innowhere.relproxy_builtin_ex.CommandListener;

import com.innowhere.relproxy_builtin_ex.OutputListener;

import java.io.PrintStream;

public class TestListener implements OutputListener

{

@Override

public void write(PrintStream out)

{

out.println("uppercase");

out.println("lowercase");

}

public CommandListener getCommandListener()

{

return new CommandListener()

{

@Override

public void execute(String command,String text,PrintStream out)

{

if ("uppercase".equals(command))

out.println(text.toUpperCase());

else if ("lowercase".equals(command))

out.println(text.toLowerCase());

else

out.println("Unknown command:" + command);

}

};

}

先預(yù)定義可選項(xiàng)，然后執(zhí)行 Main 類(lèi)。為了校驗(yàn) RelProxy 是否起作用，可以在不停止程序的運(yùn)行的基礎(chǔ)上增加一個(gè)新的可選項(xiàng)“same”。

@Override

public void write(PrintStream out)

{

out.println("uppercase");

out.println("lowercase");

out.println("same"); // NEW

}

public CommandListener getCommandListener()

{

return new CommandListener()

{

@Override

public void execute(String command,String text,PrintStream out)

{

if ("uppercase".equals(command))

out.println(text.toUpperCase());

else if ("lowercase".equals(command))

out.println(text.toLowerCase());

else if ("same".equals(command)) // NEW

out.println(text); // NEW

else

out.println("Unknown command:" + command);

}

};

}

下一篇文章中將處理包含當(dāng)前“same”的行為，不需要停止控制臺(tái)應(yīng)用。

ItsNat web 框架可能是***個(gè)使用 RelProxy 技術(shù)的應(yīng)用（版本 v1.4）。

注意：使用 RelProxy 0.8.7 或更高的版本，這個(gè)版本在嵌入方式上做了改進(jìn)。

名稱(chēng)欄目：使用RelProxy提高Java開(kāi)發(fā)效率
文章URL：http://m.fisionsoft.com.cn/article/dhhshec.html

新聞中心

其他資訊