http://www3.ccw.com.cn/club/essence/200305/16517.htm
RMI,遠(yuǎn)程方法調(diào)用(Remote Method Invocation)是Enterprise JavaBeans的支柱,是建立分布式Java應(yīng)用程序的方便途徑。RMI是非常容易使用的,但是它非常的強(qiáng)大。
RMI的基礎(chǔ)是接口,RMI構(gòu)架基于一個(gè)重要的原理:定義接口和定義接口的具體實(shí)現(xiàn)是分開的。下面我們通過具體的例子,建立一個(gè)簡(jiǎn)單的遠(yuǎn)程計(jì)算服務(wù)和使用它的客戶程序
一個(gè)正常工作的RMI系統(tǒng)由下面幾個(gè)部分組成:
● 遠(yuǎn)程服務(wù)的接口定義
● 遠(yuǎn)程服務(wù)接口的具體實(shí)現(xiàn)
● 樁(Stub)和框架(Skeleton)文件
● 一個(gè)運(yùn)行遠(yuǎn)程服務(wù)的服務(wù)器
● 一個(gè)RMI命名服務(wù),它允許客戶端去發(fā)現(xiàn)這個(gè)遠(yuǎn)程服務(wù)
● 類文件的提供者(一個(gè)HTTP或者FTP服務(wù)器)
● 一個(gè)需要這個(gè)遠(yuǎn)程服務(wù)的客戶端程序
下面我們一步一步建立一個(gè)簡(jiǎn)單的RMI系統(tǒng)。首先在你的機(jī)器里建立一個(gè)新的文件夾,以便放置我們創(chuàng)建的文件,為了簡(jiǎn)單起見,我們只使用一個(gè)文件夾存放客戶端和服務(wù)端代碼,并且在同一個(gè)目錄下運(yùn)行服務(wù)端和客戶端。
如果所有的RMI文件都已經(jīng)設(shè)計(jì)好了,那么你需要下面的幾個(gè)步驟去生成你的系統(tǒng):
1、 編寫并且編譯接口的Java代碼
2、 編寫并且編譯接口實(shí)現(xiàn)的Java代碼
3、 從接口實(shí)現(xiàn)類中生成樁(Stub)和框架(Skeleton)類文件
4、 編寫遠(yuǎn)程服務(wù)的主運(yùn)行程序
5、 編寫RMI的客戶端程序
6、 安裝并且運(yùn)行RMI系統(tǒng)
1、 接口
第一步就是建立和編譯服務(wù)接口的Java代碼。這個(gè)接口定義了所有的提供遠(yuǎn)程服務(wù)的功能,下面是源程序:
//Calculator.java
//define the interface
import java.rmi.Remote;
public interface Calculator extends Remote
{
public long add(long a, long b)
throws java.rmi.RemoteException;
public long sub(long a, long b)
throws java.rmi.RemoteException;
public long mul(long a, long b)
throws java.rmi.RemoteException;
public long div(long a, long b)
throws java.rmi.RemoteException;
}
注意,這個(gè)接口繼承自Remote,每一個(gè)定義的方法都必須拋出一個(gè)RemoteException異常對(duì)象。
建立這個(gè)文件,把它存放在剛才的目錄下,并且編譯。
>javac Calculator.java
2、 接口的具體實(shí)現(xiàn)
下一步,我們就要寫遠(yuǎn)程服務(wù)的具體實(shí)現(xiàn),這是一個(gè)CalculatorImpl類文件:
//CalculatorImpl.java
//Implementation
import java.rmi.server.UnicastRemoteObject
public class CalculatorImpl extends UnicastRemoteObject implements Calculator
{
// 這個(gè)實(shí)現(xiàn)必須有一個(gè)顯式的構(gòu)造函數(shù),并且要拋出一個(gè)RemoteException異常
public CalculatorImpl()
throws java.rmi.RemoteException {
super();
}
public long add(long a, long b)
throws java.rmi.RemoteException {
return a + b;
}
public long sub(long a, long b)
throws java.rmi.RemoteException {
return a - b;
}
public long mul(long a, long b)
throws java.rmi.RemoteException {
return a * b;
}
public long div(long a, long b)
throws java.rmi.RemoteException {
return a / b;
}
}
同樣的,把這個(gè)文件保存在你的目錄里然后編譯他。
這個(gè)實(shí)現(xiàn)類使用了UnicastRemoteObject去聯(lián)接RMI系統(tǒng)。在我們的例子中,我們是直接的從UnicastRemoteObject這個(gè)類上繼承的,事實(shí)上并不一定要這樣做,如果一個(gè)類不是從UnicastRmeoteObject上繼承,那必須使用它的exportObject()方法去聯(lián)接到RMI。
如果一個(gè)類繼承自UnicastRemoteObject,那么它必須提供一個(gè)構(gòu)造函數(shù)并且聲明拋出一個(gè)RemoteException對(duì)象。當(dāng)這個(gè)構(gòu)造函數(shù)調(diào)用了super(),它久激活UnicastRemoteObject中的代碼完成RMI的連接和遠(yuǎn)程對(duì)象的初始化。
3、 樁(Stubs)和框架(Skeletons)
下一步就是要使用RMI編譯器rmic來生成樁和框架文件,這個(gè)編譯運(yùn)行在遠(yuǎn)程服務(wù)實(shí)現(xiàn)類文件上。
>rmic CalculatorImpl
在你的目錄下運(yùn)行上面的命令,成功執(zhí)行完上面的命令你可以發(fā)現(xiàn)一個(gè)Calculator_stub.class文件,如果你是使用的Java2SDK,那么你還可以發(fā)現(xiàn)Calculator_Skel.class文件。
4、 主機(jī)服務(wù)器
遠(yuǎn)程RMI服務(wù)必須是在一個(gè)服務(wù)器中運(yùn)行的。CalculatorServer類是一個(gè)非常簡(jiǎn)單的服務(wù)器。
//CalculatorServer.java
import java.rmi.Naming;
public class CalculatorServer {
public CalculatorServer() {
try {
Calculator c = new CalculatorImpl();
Naming.rebind("rmi://localhost:1099/CalculatorService", c);
} catch (Exception e) {
System.out.println("Trouble: " + e);
}
}
public static void main(String args[]) {
new CalculatorServer();
}
}
建立這個(gè)服務(wù)器程序,然后保存到你的目錄下,并且編譯它。
5、 客戶端
客戶端源代碼如下:
//CalculatorClient.java
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.net.MalformedURLException;
import java.rmi.NotBoundException;
public class CalculatorClient {
public static void main(String[] args) {
try {
Calculator c = (Calculator)
Naming.lookup(
"rmi://localhost
/CalculatorService");
System.out.println( c.sub(4, 3) );
System.out.println( c.add(4, 5) );
System.out.println( c.mul(3, 6) );
System.out.println( c.div(9, 3) );
}
catch (MalformedURLException murle) {
System.out.println();
System.out.println(
"MalformedURLException");
System.out.println(murle);
}
catch (RemoteException re) {
System.out.println();
System.out.println(
"RemoteException");
System.out.println(re);
}
catch (NotBoundException nbe) {
System.out.println();
System.out.println(
"NotBoundException");
System.out.println(nbe);
}
catch (
java.lang.ArithmeticException
ae) {
System.out.println();
System.out.println(
"java.lang.ArithmeticException");
System.out.println(ae);
}
}
}
保存這個(gè)客戶端程序到你的目錄下(注意這個(gè)目錄是一開始建立那個(gè),所有的我們的文件都在那個(gè)目錄下),并且編譯他。
6、 運(yùn)行RMI系統(tǒng)
現(xiàn)在我們建立了所有運(yùn)行這個(gè)簡(jiǎn)單RMI系統(tǒng)所需的文件,現(xiàn)在我們終于可以運(yùn)行這個(gè)RMI系統(tǒng)啦!來享受吧。
我們是在命令控制臺(tái)下運(yùn)行這個(gè)系統(tǒng)的,你必須開啟三個(gè)控制臺(tái)窗口,一個(gè)運(yùn)行服務(wù)器,一個(gè)運(yùn)行客戶端,還有一個(gè)運(yùn)行RMIRegistry。
首先運(yùn)行注冊(cè)程序RMIRegistry,你必須在包含你剛寫的類的那么目錄下運(yùn)行這個(gè)注冊(cè)程序。
>rmiregistry
好,這個(gè)命令成功的話,注冊(cè)程序已經(jīng)開始運(yùn)行了,不要管他,現(xiàn)在切換到另外一個(gè)控制臺(tái),在第二個(gè)控制臺(tái)里,我們運(yùn)行服務(wù)器CalculatorService,因?yàn)镽MI的安全機(jī)制將在服務(wù)端發(fā)生作用,所以你必須增加一條安全策略。以下是對(duì)應(yīng)安全策略的例子
grant {
permission java.security.AllPermission "", "";
};
注意:這是一條最簡(jiǎn)單的安全策略,它允許任何人做任何事,對(duì)于你的更加關(guān)鍵性的應(yīng)用,你必須指定更加詳細(xì)安全策略。
現(xiàn)在為了運(yùn)行服務(wù)端,你需要除客戶類(CalculatorClient.class)之外的所有的類文件。確認(rèn)安全策略在policy.txt文件之后,使用如下命令來運(yùn)行服務(wù)器。
> java -Djava.security.policy=policy.txt CalculatorServer
這個(gè)服務(wù)器就開始工作了,把接口的實(shí)現(xiàn)加載到內(nèi)存等待客戶端的聯(lián)接。好現(xiàn)在切換到第三個(gè)控制臺(tái),啟動(dòng)我們的客戶端。
為了在其他的機(jī)器運(yùn)行客戶端程序你需要一個(gè)遠(yuǎn)程接口(Calculator.class) 和一個(gè)stub(CalculatorImpl_Stub.class)。 使用如下命令運(yùn)行客戶端
prompt> java -Djava.security.policy=policy.txt CalculatorClient
如果所有的這些都成功運(yùn)行,你應(yīng)該看到下面的輸出:
1
9
18
3
如果你看到了上面的輸出,恭喜你,你成功了,你已經(jīng)成功的創(chuàng)建了一個(gè)RMI系統(tǒng),并且使他正確工作了。即使你運(yùn)行在同一個(gè)計(jì)算機(jī)上,RMI還是使用了你的網(wǎng)絡(luò)堆棧和TCP/IP去進(jìn)行通訊,并且是運(yùn)行在三個(gè)不同的Java虛擬機(jī)上。這已經(jīng)是一個(gè)完整的RMI系統(tǒng)。
RMI,遠(yuǎn)程方法調(diào)用(Remote Method Invocation)是Enterprise JavaBeans的支柱,是建立分布式Java應(yīng)用程序的方便途徑。RMI是非常容易使用的,但是它非常的強(qiáng)大。
RMI的基礎(chǔ)是接口,RMI構(gòu)架基于一個(gè)重要的原理:定義接口和定義接口的具體實(shí)現(xiàn)是分開的。下面我們通過具體的例子,建立一個(gè)簡(jiǎn)單的遠(yuǎn)程計(jì)算服務(wù)和使用它的客戶程序
一個(gè)正常工作的RMI系統(tǒng)由下面幾個(gè)部分組成:
● 遠(yuǎn)程服務(wù)的接口定義
● 遠(yuǎn)程服務(wù)接口的具體實(shí)現(xiàn)
● 樁(Stub)和框架(Skeleton)文件
● 一個(gè)運(yùn)行遠(yuǎn)程服務(wù)的服務(wù)器
● 一個(gè)RMI命名服務(wù),它允許客戶端去發(fā)現(xiàn)這個(gè)遠(yuǎn)程服務(wù)
● 類文件的提供者(一個(gè)HTTP或者FTP服務(wù)器)
● 一個(gè)需要這個(gè)遠(yuǎn)程服務(wù)的客戶端程序
下面我們一步一步建立一個(gè)簡(jiǎn)單的RMI系統(tǒng)。首先在你的機(jī)器里建立一個(gè)新的文件夾,以便放置我們創(chuàng)建的文件,為了簡(jiǎn)單起見,我們只使用一個(gè)文件夾存放客戶端和服務(wù)端代碼,并且在同一個(gè)目錄下運(yùn)行服務(wù)端和客戶端。
如果所有的RMI文件都已經(jīng)設(shè)計(jì)好了,那么你需要下面的幾個(gè)步驟去生成你的系統(tǒng):
1、 編寫并且編譯接口的Java代碼
2、 編寫并且編譯接口實(shí)現(xiàn)的Java代碼
3、 從接口實(shí)現(xiàn)類中生成樁(Stub)和框架(Skeleton)類文件
4、 編寫遠(yuǎn)程服務(wù)的主運(yùn)行程序
5、 編寫RMI的客戶端程序
6、 安裝并且運(yùn)行RMI系統(tǒng)
1、 接口
第一步就是建立和編譯服務(wù)接口的Java代碼。這個(gè)接口定義了所有的提供遠(yuǎn)程服務(wù)的功能,下面是源程序:
//Calculator.java
//define the interface
import java.rmi.Remote;
public interface Calculator extends Remote
{
public long add(long a, long b)
throws java.rmi.RemoteException;
public long sub(long a, long b)
throws java.rmi.RemoteException;
public long mul(long a, long b)
throws java.rmi.RemoteException;
public long div(long a, long b)
throws java.rmi.RemoteException;
}
注意,這個(gè)接口繼承自Remote,每一個(gè)定義的方法都必須拋出一個(gè)RemoteException異常對(duì)象。
建立這個(gè)文件,把它存放在剛才的目錄下,并且編譯。
>javac Calculator.java
2、 接口的具體實(shí)現(xiàn)
下一步,我們就要寫遠(yuǎn)程服務(wù)的具體實(shí)現(xiàn),這是一個(gè)CalculatorImpl類文件:
//CalculatorImpl.java
//Implementation
import java.rmi.server.UnicastRemoteObject
public class CalculatorImpl extends UnicastRemoteObject implements Calculator
{
// 這個(gè)實(shí)現(xiàn)必須有一個(gè)顯式的構(gòu)造函數(shù),并且要拋出一個(gè)RemoteException異常
public CalculatorImpl()
throws java.rmi.RemoteException {
super();
}
public long add(long a, long b)
throws java.rmi.RemoteException {
return a + b;
}
public long sub(long a, long b)
throws java.rmi.RemoteException {
return a - b;
}
public long mul(long a, long b)
throws java.rmi.RemoteException {
return a * b;
}
public long div(long a, long b)
throws java.rmi.RemoteException {
return a / b;
}
}
同樣的,把這個(gè)文件保存在你的目錄里然后編譯他。
這個(gè)實(shí)現(xiàn)類使用了UnicastRemoteObject去聯(lián)接RMI系統(tǒng)。在我們的例子中,我們是直接的從UnicastRemoteObject這個(gè)類上繼承的,事實(shí)上并不一定要這樣做,如果一個(gè)類不是從UnicastRmeoteObject上繼承,那必須使用它的exportObject()方法去聯(lián)接到RMI。
如果一個(gè)類繼承自UnicastRemoteObject,那么它必須提供一個(gè)構(gòu)造函數(shù)并且聲明拋出一個(gè)RemoteException對(duì)象。當(dāng)這個(gè)構(gòu)造函數(shù)調(diào)用了super(),它久激活UnicastRemoteObject中的代碼完成RMI的連接和遠(yuǎn)程對(duì)象的初始化。
3、 樁(Stubs)和框架(Skeletons)
下一步就是要使用RMI編譯器rmic來生成樁和框架文件,這個(gè)編譯運(yùn)行在遠(yuǎn)程服務(wù)實(shí)現(xiàn)類文件上。
>rmic CalculatorImpl
在你的目錄下運(yùn)行上面的命令,成功執(zhí)行完上面的命令你可以發(fā)現(xiàn)一個(gè)Calculator_stub.class文件,如果你是使用的Java2SDK,那么你還可以發(fā)現(xiàn)Calculator_Skel.class文件。
4、 主機(jī)服務(wù)器
遠(yuǎn)程RMI服務(wù)必須是在一個(gè)服務(wù)器中運(yùn)行的。CalculatorServer類是一個(gè)非常簡(jiǎn)單的服務(wù)器。
//CalculatorServer.java
import java.rmi.Naming;
public class CalculatorServer {
public CalculatorServer() {
try {
Calculator c = new CalculatorImpl();
Naming.rebind("rmi://localhost:1099/CalculatorService", c);
} catch (Exception e) {
System.out.println("Trouble: " + e);
}
}
public static void main(String args[]) {
new CalculatorServer();
}
}
建立這個(gè)服務(wù)器程序,然后保存到你的目錄下,并且編譯它。
5、 客戶端
客戶端源代碼如下:
//CalculatorClient.java
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.net.MalformedURLException;
import java.rmi.NotBoundException;
public class CalculatorClient {
public static void main(String[] args) {
try {
Calculator c = (Calculator)
Naming.lookup(
"rmi://localhost
/CalculatorService");
System.out.println( c.sub(4, 3) );
System.out.println( c.add(4, 5) );
System.out.println( c.mul(3, 6) );
System.out.println( c.div(9, 3) );
}
catch (MalformedURLException murle) {
System.out.println();
System.out.println(
"MalformedURLException");
System.out.println(murle);
}
catch (RemoteException re) {
System.out.println();
System.out.println(
"RemoteException");
System.out.println(re);
}
catch (NotBoundException nbe) {
System.out.println();
System.out.println(
"NotBoundException");
System.out.println(nbe);
}
catch (
java.lang.ArithmeticException
ae) {
System.out.println();
System.out.println(
"java.lang.ArithmeticException");
System.out.println(ae);
}
}
}
保存這個(gè)客戶端程序到你的目錄下(注意這個(gè)目錄是一開始建立那個(gè),所有的我們的文件都在那個(gè)目錄下),并且編譯他。
6、 運(yùn)行RMI系統(tǒng)
現(xiàn)在我們建立了所有運(yùn)行這個(gè)簡(jiǎn)單RMI系統(tǒng)所需的文件,現(xiàn)在我們終于可以運(yùn)行這個(gè)RMI系統(tǒng)啦!來享受吧。
我們是在命令控制臺(tái)下運(yùn)行這個(gè)系統(tǒng)的,你必須開啟三個(gè)控制臺(tái)窗口,一個(gè)運(yùn)行服務(wù)器,一個(gè)運(yùn)行客戶端,還有一個(gè)運(yùn)行RMIRegistry。
首先運(yùn)行注冊(cè)程序RMIRegistry,你必須在包含你剛寫的類的那么目錄下運(yùn)行這個(gè)注冊(cè)程序。
>rmiregistry
好,這個(gè)命令成功的話,注冊(cè)程序已經(jīng)開始運(yùn)行了,不要管他,現(xiàn)在切換到另外一個(gè)控制臺(tái),在第二個(gè)控制臺(tái)里,我們運(yùn)行服務(wù)器CalculatorService,因?yàn)镽MI的安全機(jī)制將在服務(wù)端發(fā)生作用,所以你必須增加一條安全策略。以下是對(duì)應(yīng)安全策略的例子
grant {
permission java.security.AllPermission "", "";
};
注意:這是一條最簡(jiǎn)單的安全策略,它允許任何人做任何事,對(duì)于你的更加關(guān)鍵性的應(yīng)用,你必須指定更加詳細(xì)安全策略。
現(xiàn)在為了運(yùn)行服務(wù)端,你需要除客戶類(CalculatorClient.class)之外的所有的類文件。確認(rèn)安全策略在policy.txt文件之后,使用如下命令來運(yùn)行服務(wù)器。
> java -Djava.security.policy=policy.txt CalculatorServer
這個(gè)服務(wù)器就開始工作了,把接口的實(shí)現(xiàn)加載到內(nèi)存等待客戶端的聯(lián)接。好現(xiàn)在切換到第三個(gè)控制臺(tái),啟動(dòng)我們的客戶端。
為了在其他的機(jī)器運(yùn)行客戶端程序你需要一個(gè)遠(yuǎn)程接口(Calculator.class) 和一個(gè)stub(CalculatorImpl_Stub.class)。 使用如下命令運(yùn)行客戶端
prompt> java -Djava.security.policy=policy.txt CalculatorClient
如果所有的這些都成功運(yùn)行,你應(yīng)該看到下面的輸出:
1
9
18
3
如果你看到了上面的輸出,恭喜你,你成功了,你已經(jīng)成功的創(chuàng)建了一個(gè)RMI系統(tǒng),并且使他正確工作了。即使你運(yùn)行在同一個(gè)計(jì)算機(jī)上,RMI還是使用了你的網(wǎng)絡(luò)堆棧和TCP/IP去進(jìn)行通訊,并且是運(yùn)行在三個(gè)不同的Java虛擬機(jī)上。這已經(jīng)是一個(gè)完整的RMI系統(tǒng)。