5、任務(wù)接口實(shí)現(xiàn)
該實(shí)現(xiàn)定義了遠(yuǎn)程方法需要傳遞的參數(shù)
package com.liuxiang.rmi.download;
/**
* 任務(wù)實(shí)現(xiàn)類(lèi)
* @author liuxiang
* 2007-8-31 上午09:08:57
*
*/
public class TaskImpl implements ITask{
public Object doWork() {
System.out.println("當(dāng)前程序處于遠(yuǎn)程調(diào)用中");
return "動(dòng)態(tài)上載對(duì)象的返回值";
}
}
6、編寫(xiě)服務(wù)器程序 、注冊(cè)遠(yuǎn)程對(duì)象、啟動(dòng)遠(yuǎn)程對(duì)象
代碼：遠(yuǎn)程對(duì)象的注冊(cè)類(lèi) 該類(lèi)應(yīng)該在服務(wù)器端執(zhí)行 執(zhí)行之后， 該機(jī)器將變?yōu)镽MI服務(wù)器 客戶(hù)端可以通過(guò)正確的url來(lái)訪問(wèn)；服務(wù)器上的遠(yuǎn)程對(duì)象；執(zhí)行對(duì)外報(bào)露的方法
/**
*
*/
package com.liuxiang.rmi.download;
import java.rmi.Naming;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
/**
* 遠(yuǎn)程對(duì)象的注冊(cè)類(lèi) 該類(lèi)應(yīng)該在服務(wù)器端執(zhí)行 執(zhí)行之后，
* 該機(jī)器將變?yōu)镽MI服務(wù)器 客戶(hù)端可以通過(guò)正確的url來(lái)訪問(wèn)
* 服務(wù)器上的遠(yuǎn)程對(duì)象；執(zhí)行對(duì)外報(bào)露的方法
*
* @author liuxiang 2007-8-30 下午09:44:54
*
*/
public class RMIServer {
/**
* 如果沒(méi)有創(chuàng)建一個(gè)Registry，Naming是不會(huì)幫助你創(chuàng)建的。 還是自己手工創(chuàng)建的比較的好
*
* 盡量用下面的自己封裝的bind方法來(lái)注冊(cè)遠(yuǎn)程對(duì)象
*
* @throws Exception
*/
public static void registRemoteObject() throws Exception {
IRMIImpl impl = new IRMIImpl();
Naming.rebind("rmi://219.233.8.97:1111/mytask", impl);
System.out.println("bound success!");
}
/**
* 創(chuàng)建一個(gè)Registry對(duì)象
*
* @return 返回一個(gè)Registry對(duì)象
*/
private static Registry createRegistry() {
Registry registry = null;
int port = 1111;
try {
registry = LocateRegistry.getRegistry(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;
}
/**
* 將對(duì)象注冊(cè)到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();
}
}
}
運(yùn)行該服務(wù)端代碼后，將會(huì)注冊(cè)一個(gè)遠(yuǎn)程服務(wù)對(duì)象，通過(guò)恰當(dāng)?shù)腢RL可以訪問(wèn)遠(yuǎn)程對(duì)象中的方法；運(yùn)行后的結(jié)果如下：
Register the exist server!port=1111
mytask server start!
7、編寫(xiě)客戶(hù)程序
代碼首先獲取一個(gè)遠(yuǎn)程對(duì)象，然后如同本地調(diào)用一樣，調(diào)用遠(yuǎn)程對(duì)象中的方法。
/**
*
*/
package com.liuxiang.rmi.download;
import java.rmi.Naming;
/**
* @author liuxiang
* 2007-8-30 下午09:47:41
*
*/
public class RMIClient {
/**
* 調(diào)用遠(yuǎn)程對(duì)象中的方法
* @throws Exception
*/
public static void getRemoteObject() throws Exception{
IRMI obj = (IRMI)Naming.lookup("rmi://localhost: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());
}
/**
* @param args
*/
public static void main(String[] args) {
try {
getRemoteObject();
} catch (Exception e) {
e.printStackTrace();
}
}
}
最后，運(yùn)行客戶(hù)端代碼，可以看到控制臺(tái)分別輸出了如下的內(nèi)容：
Server端輸出了更多的內(nèi)容，如下：
Register the exist server!port=1111
mytask server start!
注意：這是一個(gè)遠(yuǎn)程調(diào)用
當(dāng)前程序處于遠(yuǎn)程調(diào)用中
調(diào)用ITask.doWork()方法的返回值：動(dòng)態(tài)上載對(duì)象的返回值
同時(shí)可以看到，會(huì)調(diào)用了Windows的Mediaplay播放本地磁盤(pán)的Mp3歌曲；
Client端輸入了如下內(nèi)容：
動(dòng)態(tài)上載對(duì)象的返回值
四、RMI介紹
RMI（Remote Method Invocation，遠(yuǎn)程方法調(diào)用）是用Java在JDK1.1中實(shí)現(xiàn)的，它大大增強(qiáng)了Java開(kāi)發(fā)分布式應(yīng)用的能力。Java作為一種風(fēng)靡一時(shí)的網(wǎng)絡(luò)開(kāi)發(fā)語(yǔ)言，其巨大的威力就體現(xiàn)在它強(qiáng)大的開(kāi)發(fā)分布式網(wǎng)絡(luò)應(yīng)用的能力上，而RMI就是開(kāi)發(fā)百分之百純Java的網(wǎng)絡(luò)分布式應(yīng)用系統(tǒng)的核心解決方案之一。其實(shí)它可以被看作是RPC的Java版本。但是傳統(tǒng)RPC并不能很好地應(yīng)用于分布式對(duì)象系統(tǒng)。而Java RMI 則支持存儲(chǔ)于不同地址空間的程序級(jí)對(duì)象之間彼此進(jìn)行通信，實(shí)現(xiàn)遠(yuǎn)程對(duì)象之間的無(wú)縫遠(yuǎn)程調(diào)用。
RMI目前使用Java遠(yuǎn)程消息交換協(xié)議JRMP（Java Remote Messaging Protocol）進(jìn)行通信。JRMP是專(zhuān)為Java的遠(yuǎn)程對(duì)象制定的協(xié)議。因此，Java RMI具有Java的"Write Once,Run Anywhere"的優(yōu)點(diǎn)，是分布式應(yīng)用系統(tǒng)的百分之百純Java解決方案。用Java RMI開(kāi)發(fā)的應(yīng)用系統(tǒng)可以部署在任何支持JRE（Java Run Environment Java，運(yùn)行環(huán)境）的平臺(tái)上。但由于JRMP是專(zhuān)為Java對(duì)象制定的，因此，RMI對(duì)于用非Java語(yǔ)言開(kāi)發(fā)的應(yīng)用系統(tǒng)的支持不足。不能與用非Java語(yǔ)言書(shū)寫(xiě)的對(duì)象進(jìn)行通信。
RMI為采用Java對(duì)象的分布式計(jì)算提供了簡(jiǎn)單而直接的途徑。這些對(duì)象可以是新的Java對(duì)象，也可以是圍繞現(xiàn)有API的簡(jiǎn)單的Java包裝程序。Java體現(xiàn)了“編寫(xiě)一次就能在任何地方運(yùn)行的模式。而RMI可將Java模式進(jìn)行擴(kuò)展，使之可在任何地方運(yùn)行”。
因?yàn)镽MI是以Java為核心的，所以，它將Java的安全性和可移植性等強(qiáng)大功能帶給了分布式計(jì)算。您可將代理和梢?務(wù)邏輯等屬性移動(dòng)到網(wǎng)絡(luò)中最合適的地方。如果您要擴(kuò)展Java在系統(tǒng)中的使用，RMI將使您充分利用其強(qiáng)大功能。
RMI可利用標(biāo)準(zhǔn)Java本機(jī)方法接口JNI與現(xiàn)有的和原有的系統(tǒng)相連接。RMI還可利用標(biāo)準(zhǔn)JDBC包與現(xiàn)有的關(guān)系數(shù)據(jù)庫(kù)連接。RMI/JNI和RMI/JDBC相結(jié)合，可幫助您利用RMI與目前使用非Java語(yǔ)言的現(xiàn)有服務(wù)器進(jìn)行通信，而且在您需要時(shí)可擴(kuò)展Java在這些服務(wù)器上的使用。RMI可幫助您在擴(kuò)展使用時(shí)充分利用Java的強(qiáng)大功能。