常用鏈接

          統(tǒng)計(jì)

          最新評(píng)論

          RMI的定義(轉(zhuǎn))http://blog.csdn.net/ocean181/archive/2010/09/02/5857273.aspx

          RMI的定義

          Java 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是專為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是專為Java對(duì)象制定的,因此,RMI對(duì)于用非Java語(yǔ)言開(kāi)發(fā)的應(yīng)用系統(tǒng)的支持不足。不能與用非Java語(yǔ)言書(shū)寫(xiě)的對(duì)象進(jìn)行通信。

          RMI與CORBA的關(guān)系

          RMI 和CORBA常被視為相互競(jìng)爭(zhēng)技術(shù),因?yàn)閮烧叨继峁?duì)遠(yuǎn)程分布式對(duì)象的透明訪問(wèn)。但這兩種技術(shù)實(shí)際上是相互補(bǔ)充的,一者的長(zhǎng)處正好可以彌補(bǔ)另一者的短處。RMI 和 CORBA 的結(jié)合產(chǎn)生了 RMI-IIOP,RMI-IIOP 是企業(yè)服務(wù)器端 Java 開(kāi)發(fā)的基礎(chǔ)

          1997 年,IBM 和 Sun Microsystems啟動(dòng)了一項(xiàng)旨在促進(jìn) Java 作為企業(yè)開(kāi)發(fā)技術(shù)的發(fā)展的合作計(jì)劃。兩家公司特別著力于如何將 Java 用作服務(wù)器端語(yǔ)言,生成可以結(jié)合進(jìn)現(xiàn)有體系結(jié)構(gòu)的企業(yè)級(jí)代碼。所需要的就是一種遠(yuǎn)程傳輸技術(shù),它兼有 Java 的 RMI(Remote Method Invocation,遠(yuǎn)程方法調(diào)用)較少的資源占用量和更成熟的 CORBA(Common Object Request Broker Architecture,公共對(duì)象請(qǐng)求代理體系結(jié)構(gòu))技術(shù)的健壯性。出于這一需要,RMI-IIOP問(wèn)世了,它幫助將 Java 語(yǔ)言推向了目前服務(wù)器端企業(yè)開(kāi)發(fā)的主流語(yǔ)言的領(lǐng)先地位。

          RMI的組成

          一個(gè)正常工作的RMI系統(tǒng)由下面幾個(gè)部分組成:

          1、遠(yuǎn)程服務(wù)的接口定義

          2、遠(yuǎn)程服務(wù)接口的具體實(shí)現(xiàn)

          3、樁(Stub)和框架(Skeleton)文件

          4、一個(gè)運(yùn)行遠(yuǎn)程服務(wù)的服務(wù)器

          5、一個(gè)RMI命名服務(wù),它允許客戶端去發(fā)現(xiàn)這個(gè)遠(yuǎn)程服務(wù)

          6、類文件的提供者(一個(gè)HTTP或者FTP服務(wù)器)

          7、一個(gè)需要這個(gè)遠(yuǎn)程服務(wù)的客戶端程序

          RMI的實(shí)現(xiàn)

          下面我們一步一步建立一個(gè)簡(jiǎn)單的RMI系統(tǒng)。首先在你的機(jī)器里建立一個(gè)新的文件夾,以便放置我們創(chuàng)建的文件,為了簡(jiǎn)單起見(jiàn),我們只使用一個(gè)文件夾存放客戶端和服務(wù)端代碼,并且在同一個(gè)目錄下運(yùn)行服務(wù)端和客戶端。

          如果所有的RMI文件都已經(jīng)設(shè)計(jì)好了,那么你需要下面的幾個(gè)步驟去生成你的系統(tǒng):

          1、   編寫(xiě)并且編譯接口的Java代碼
          2、   編寫(xiě)并且編譯接口實(shí)現(xiàn)的Java代碼
          3、   從接口實(shí)現(xiàn)類中生成 Stub 和 Skeleton 類文件
          4、   編寫(xiě)遠(yuǎn)程服務(wù)的主運(yùn)行程序
          5、   編寫(xiě)RMI的客戶端程序
          6、   安裝并且運(yùn)行RMI系統(tǒng)

          1、接口

          第一步就是建立和編譯服務(wù)接口的Java代碼。這個(gè)接口定義了所有的提供遠(yuǎn)程服務(wù)的功能,下面是源程序:

             1. //Calculator.java
             2. //define the interface
             3. import java.rmi.Remote;
             4.
             5. public interface Calculator extends Remote
             6. {
             7.     public long add(long a, long b)
             8.         throws java.rmi.RemoteException;
             9.
            10.     public long sub(long a, long b)
            11.         throws java.rmi.RemoteException;
            12.
            13.     public long mul(long a, long b)
            14.         throws java.rmi.RemoteException;
            15.
            16.     public long div(long a, long b)
            17.         throws java.rmi.RemoteException;
            18. }


          注意,這個(gè)接口繼承自Remote,每一個(gè)定義的方法都必須拋出一個(gè)RemoteException異常對(duì)象。

          建立這個(gè)文件,把它存放在剛才的目錄下,并且編譯。

          >javac Calculator.java

          2、接口的具體實(shí)現(xiàn)

          下一步,我們就要寫(xiě)遠(yuǎn)程服務(wù)的具體實(shí)現(xiàn),這是一個(gè)CalculatorImpl類文件:

             1. //CalculatorImpl.java
             2. //Implementation
             3. import java.rmi.server.UnicastRemoteObject;
             4.
             5. public class CalculatorImpl extends UnicastRemoteObject implements Calculator
             6. {
             7.
             8.     // 這個(gè)實(shí)現(xiàn)必須有一個(gè)顯式的構(gòu)造函數(shù),并且要拋出一個(gè)RemoteException異常
             9.     public CalculatorImpl()
            10.         throws java.rmi.RemoteException {
            11.         super();
            12.      }
            13.
            14.     public long add(long a, long b)
            15.         throws java.rmi.RemoteException {
            16.         return a + b;
            17.      }
            18.
            19.     public long sub(long a, long b)
            20.         throws java.rmi.RemoteException {
            21.         return a - b;
            22.      }
            23.
            24.     public long mul(long a, long b)
            25.         throws java.rmi.RemoteException {
            26.         return a * b;
            27.      }
            28.
            29.     public long div(long a, long b)
            30.         throws java.rmi.RemoteException {
            31.         return a / b;
            32.      }
            33. }


          同樣的,把這個(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來(lái)生成樁和框架文件,這個(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ù)器。

             1. //CalculatorServer.java
             2. import java.rmi.Naming;
             3.
             4. public class CalculatorServer {
             5.
             6.    public CalculatorServer() {
             7.      try {
             8.         Calculator c = new CalculatorImpl();
             9.        Naming.rebind("rmi://localhost:1099/CalculatorService", c);
            10.       } catch (Exception e) {
            11.        System.out.println("Trouble: " + e);
            12.       }
            13.     }
            14.
            15.    public static void main(String args[]) {
            16.      new CalculatorServer();
            17.     }
            18. }


          建立這個(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è)目錄是一開(kāi)始建立那個(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)啦!來(lái)享受吧。

          我們是在命令控制臺(tái)下運(yùn)行這個(gè)系統(tǒng)的,你必須開(kāi)啟三個(gè)控制臺(tái)窗口,一個(gè)運(yùn)行服務(wù)器,一個(gè)運(yùn)行客戶端,還有一個(gè)運(yùn)行RMIRegistry。

          首先運(yùn)行注冊(cè)程序RMIRegistry,你必須在包含你剛寫(xiě)的類的那么目錄下運(yùn)行這個(gè)注冊(cè)程序。

          >rmiregistry

          好,這個(gè)命令成功的話,注冊(cè)程序已經(jīng)開(kāi)始運(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文件之后,使用如下命令來(lái)運(yùn)行服務(wù)器。

          > java -Djava.security.policy=policy.txt CalculatorServer

          這個(gè)服務(wù)器就開(kāi)始工作了,把接口的實(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)行客戶端

          > 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)。

          posted on 2011-02-13 18:46 九寶 閱讀(265) 評(píng)論(0)  編輯  收藏


          只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。


          網(wǎng)站導(dǎo)航:
           
          主站蜘蛛池模板: 三台县| 开化县| 潢川县| 五峰| 和顺县| 宜宾市| 巴彦县| 岑溪市| 图木舒克市| 左云县| 西平县| 来宾市| 铜梁县| 凯里市| 潼南县| 连州市| 清远市| 漳平市| 苏尼特左旗| 虎林市| 南城县| 社会| 兴安县| 胶州市| 大城县| 墨脱县| 咸宁市| 塘沽区| 醴陵市| 镇坪县| 望城县| 通道| 舒兰市| 临沭县| 灵武市| 高碑店市| 桐城市| 开封市| 湘乡市| 德格县| 昭觉县|