|
|
在寫這篇文章前也訪問了中國電信的高級工程師，根據(jù)他的介紹，RMI 有很多實(shí)現(xiàn)方式，而且現(xiàn)在他發(fā)現(xiàn) RMI 在大規(guī)模分布式系統(tǒng)中，效率和性能不是很好。目前他帶領(lǐng)的團(tuán)隊(duì)正在自行開發(fā)分布式應(yīng)用。
隨著 web 2.0 時(shí)代的到來，SOA 開發(fā)思想的普及應(yīng)用。分布式應(yīng)用，將又一次走向高潮。
RMI 開發(fā)步驟大家都很清楚，這里舉個(gè)不用手動(dòng)啟動(dòng) rmiRegistry, 也不要指定 codebase 和web server 的例子.底層 TCP/IP 細(xì)節(jié)我們不用去管他，你就把他看成像 SOAP、JNDI 等一樣的基于注冊服務(wù)的東西就行了 .
1. 遠(yuǎn)程接口
import Java.rmi.Remote;
import Java.rmi.RemoteException;
public interface IRMI extends Remote {
public Object invoke(ITask task) throws RemoteException;
}
2.遠(yuǎn)程接口實(shí)現(xiàn)
/**
* @author Jack.Wang
*
*/
import Java.rmi.RemoteException;
import Java.rmi.server.UnicastRemoteObject;
public class IRMIImpl extends UnicastRemoteObject implements IRMI {
protected IRMIImpl() throws RemoteException {
super();
}
public Object invoke(ITask task) throws RemoteException {
System.out.println("注意：這是一個(gè)遠(yuǎn)程調(diào)用");
Object obj = task.doWork();
System.out.println("調(diào)用ITask.doWork()方法的返回值：" + obj.toString());
// 客戶端調(diào)用，可以在服務(wù)器端播放需要的音樂
ProcessCaller.callMp3();
return obj;
}
}
3. 任務(wù)接口
/**
* @author Jack.Wang
*
*/
import Java.io.Serializable;
public interface ITask extends Serializable {
public Object doWork();
}
4. 任務(wù)實(shí)現(xiàn)類
/**
* @author Jack.Wang
*
*/
public class TaskImpl implements ITask {
public Object doWork() {
System.out.println("當(dāng)前程序處于遠(yuǎn)程調(diào)用中");
return Thread.currentThread().getName() + " "
+ new Date(System.currentTimeMillis());
}
}
5.在Java中調(diào)用windows程序
public class ProcessCaller {
public static void callMp3() {
Runtime ru = Runtime.getRuntime();
try {
// 調(diào)用播放器文件播放指定MP3
Process p1 = ru
.exec("C://Program Files//Windows Media Player//wmplayer D://Jack//Mp3//5.秋天不回來-王強(qiáng).mp3");
} catch (Exception e) {
}
}
}
6. Server 端代碼
/**
* @author Jack.Wang
*
*/
import Java.rmi.Naming;
import Java.rmi.registry.LocateRegistry;
import Java.rmi.registry.Registry;
public class RMIServer {
public static void registRemoteObject() throws Exception {
IRMIImpl impl = new IRMIImpl();
Naming.rebind("rmi://210.43.109.25:1111/mytask", impl);
System.out.println("bound success!");
}
private static Registry createRegistry() {
Registry registry = null;
int port = 1111;
try {
registry = LocateRegistry.getRegistry("210.43.109.25", port);
registry.list();
System.out.println("Register the exist server!");
} catch (final Exception e) {
try {
registry = LocateRegistry.createRegistry(port);
System.out.println("Register the exist server!port=" + port);
} catch (final Exception ee) {
ee.printStackTrace();
}
}
return registry;
}
/**
* 將對象注冊到rmi服務(wù)器上
*/
public static void bind() {
Registry registry = null;
registry = createRegistry();
try {
IRMIImpl impl = new IRMIImpl();
registry.rebind("mytask", impl);
System.out.println("mytask server start!");
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* @param args
*/
public static void main(String[] args) {
try {
bind();
} catch (Exception e) {
e.printStackTrace();
}
}
}
7. Client 端代碼
/**
* @author Jack.Wang
*
*/
public class RMIClient {
public static void getRemoteObject() throws Exception {
IRMI obj = (IRMI) Naming.lookup("rmi://210.43.109.28:1111/mytask"); // 得到遠(yuǎn)程發(fā)布的服務(wù)
TaskImpl task = new TaskImpl();
Object result = obj.invoke(task); // 調(diào)用遠(yuǎn)程服務(wù)的方法
System.out.println(result.toString());
}
public static void main(String[] args) {
try {
getRemoteObject();
} catch (Exception e) {
e.printStackTrace();
}
}
}
小結(jié)：
建議把以上程序打包成 jar 文件，你可以在不同機(jī)子間測試。
RMI 就這么簡單，如果你覺得他不爽，就自己封裝 socket. 到時(shí)候要通知我哦，我也學(xué)習(xí)學(xué)習(xí)。
jsp技術(shù)：RMI使用學(xué)習(xí) 小結(jié)，轉(zhuǎn)載需保留來源！
鄭重聲明：本文版權(quán)歸原作者所有，轉(zhuǎn)載文章僅為傳播更多信息之目的，如作者信息標(biāo)記有誤，請第一時(shí)間聯(lián)系我們修改或刪除，多謝。
