RMI在企業分布式計算中的應用

2019-11-18 12:41:51

字體：大中小

來源：轉載

供稿：網友

　　作為整個產品供給鏈中的一部分，現代企業的企業信息資源廣泛分布在各種網絡體系中，企業必須能夠處理這些分布的信息資源，這使得分布式企業應用成為構建企業信息環境的必然需求。RMI是使用最廣泛的分布式對象系統之一，本文舉例介紹了分布式企業計算的基本模式及如何應用RMI 來開發分布式的企業應用。
　　
　　一、客戶/服務端模式
　　客戶/服務模式通過使用一個應用程序(客戶)和另一個程序(服務端)交換數據。在客戶/服務模式的應用中，通常使用低層次的Socket來開發，使用Socket來開發客戶/服務端模式意味著我們必須自己設計一種包含客戶端和服務端都統一的命令集的協議，使得客戶端和服務端能夠通過這個協議來通信。
　　
　　二、分布式對象模式
　　分布式對象系統是一個對象集合，通過定義很完善的統一接口來分隔開請求服務(客戶端)和功能服務(服務端)。在分布式對象模式里,客戶端發送一個消息到一個對象，由對象解釋這個消息，然后決定應該由什么服務來完成，這個服務、方法或選擇可能是被一個對象或是被一個Broker來完成的。
　　
　　三、RMI
　　RMI是一個分布式對象模式。由于不需要設計協議使得使用RMI開發分布式程序比使用socket更加輕易。在RMI里，設計者就象在調用一個本地類的方法一樣,而實際上是在調用的時候相應的參數被發送到遠端的對象后被解釋，最后結果返回給調用者，下面本文通過開發一個文件交換程序來介紹RMI的應用。這個應用答應客戶端從服務端交換(或下載)所有類型的文件。第一步是定義一個遠程的接口，這個接口指定的簽名方法將被服務端提供和被客戶端調用。
　　1．定義一個遠程接口
　　FileInterface.java代碼如下:
　　import java.rmi.Remote;
　　import java.rmi.RemoteException;
　　public interface FileInterface extends Remote {
　　　 public byte[] downloadFile(String fileName) throws
　　　 RemoteException;
　　}
　　接口FileInterface提供了一個downloadFile方法，然后返回一個相應的文件數據。
　　2．實現遠程的接口
　　類FileImpl繼續于UnicastRemoteObject類。這顯示出FileImpl類是用來創建一個單獨的、不能復制的、遠程的對象，這個對象使用RMI默認的基于TCP的通信方式。FileImpl.java代碼如下:
　　import java.io.*;
　　import java.rmi.*;
　　import java.rmi.server.UnicastRemoteObject;
　　public class FileImpl extends UnicastRemoteObject
　　　implements FileInterface {
　　　 PRivate String name;
　　　 public FileImpl(String s) throws RemoteException{
　　　　　super();
　　　　　name = s;
　　　 }
　　　 public byte[] downloadFile(String fileName){
　　　　　try {
　　　　　　 File file = new File(fileName);
　　　　　　 byte buffer[] = new byte[(int)file.length()];
　　　　　　 BufferedInputStream input = new
　　　　　BufferedInputStream(new FileInputStream(fileName));
　　　　　　 input.read(buffer,0,buffer.length);
　　　　　　 input.close();
　　　　　　 return(buffer);
　　　　　} catch(Exception e){
　　　　　System.out.println("FileImpl: "+e.getMessage());
　　　　　　 e.printStackTrace();
　　　　　　 return(null);
　　　　　}}}
　　3．編寫服務端
　　（1)創建并安裝一個RMISecurityManager實例。
　?。?)創建一個遠程對象的實例。
　?。?)使用RMI注冊工具來注冊這個對象。
　　FileServer.java 代碼如下：
　　import java.io.*;
　　import java.rmi.*;
　　public class FileServer {
　　　 public static void main(String argv[]) {
　　　　　if(System.getSecurityManager() == null) {
　　System.setSecurityManager(new RMISecurityManager());
　　　　　}
　　　　　try {
　　　　　　 FileInterface fi = new FileImpl("FileServer");
　　　　　　 Naming.rebind("http://127.0.0.1/FileServer", fi);
　　　　　} catch(Exception e) {
　　　　　　 System.out.println("FileServer: "+e.getMessage());
　　　　　　 e.printStackTrace();
　　　　　}}}
　　聲明Naming.rebind("http://127.0.0.1/FileServer", fi) 中假定了RMI注冊工具(RMI registry )使用并啟動了1099端口。假如在其他端口運行了RMI注冊工具，則必須在這個聲明中定義。例如，假如RMI注冊工具在4500端口運行，則聲明應為：
　　Naming.rebind("http://127.0.0.1:4500/FileServer", fi)
　　另外我們已經同時假定了我們的服務端和RMI注冊工具是運行在同一臺機器上的。否則需要修改rebind方法中的地址。
　　4．編寫客戶端
　　客戶端可以遠程調用遠程接口(FileInterface)中的任何一個方法。無論如何實現，客戶端必須先從RMI注冊工具中獲取一個遠程對象的引用。當引用獲得后，方法downloadFile被調用。在執行過程中，客戶端從命令行中獲得兩個參數，第一個是要下載的文件名,第二個是要下載的機器的地址，在對應地址的機器上運行服務端。FileClient.java 代碼如下：
　　import java.io.*;
　　import java.rmi.*;
　　public class FileClient{
　　　 public static void main(String argv[]) {
　　　　　if(argv.length != 2) {
　　　　　　System.out.println("Usage: java FileClient fileName machineName");
　　　　　　System.exit(0);
　　　　　}
　　　　　try {
　　　　　　 String name = "http://" + argv[1] + "/FileServer";
　　　　　　 FileInterface fi = (FileInterface) Naming.lookup(name);
　　　　　　 byte[] filedata = fi.downloadFile(argv[0]);
　　　　　　 File file = new File(argv[0]);
　　　　　　 BufferedOutputStream output = new
　　BufferedOutputStream(new FileOutputStream(file.getName()));
　　　　　　 output.write(filedata,0,filedata.length);
　　　　　　 output.flush();
　　　　　　 output.close();
　　　　　} catch(Exception e) {
　　　　　　 System.err.println("FileServer exception: "+ e.getMessage());
　　　　　　 e.printStackTrace();
　　　　　}}}
　　5．運行程序
　　為了運行程序，我們必須使用rmic來編譯生成stubs和skeletons:prompt>rmic FileImpl。這將會生成FileImpl_Stub.class和FileImpl_Skel.class兩個文件。stub是客戶端的代理，而skeleton是服務端的框架。服務端和客戶端采用javac來編譯（假如服務端和客戶端在兩個不同的機器，則必須復制一個FileInterface接口）。
　　使用rmiregistry或者start rmiregistry 命令來運行RMI注冊工具到window系統默認的端口上：
　　prompt> rmiregistry portNumber
　　RMI注冊工具運行之后，需要運行服務FileServer，因為RMI的安全機制將在服務端發生作用,所以必須增加一條安全策略：
　　grant {
　　permission java.security.AllPermission "", "";
　　};
　　為了運行服務端，需要有除客戶類(FileClient.
　　class)之外所有的類文件。確認安全策略在policy.txt文件之后,使用如下命令來運行服務器。
　　prompt> java -Djava.security.policy=policy.txt FileServer
　　為了在其他的機器運行客戶端程序,需要一個遠程接口(FileInterface.class)和一個stub(FileImpl_Stub.class)。使用如下命令運行客戶端:
　　prompt> java FileClient fileName machineName
　　這里fileName是要下載的文件名,machineName 是要下載的文件所在的機器(也是服務端所在的機器)。假如全部通過的話,當客戶端運行后，則這個文件將被下載到本地。

上一篇：為RMI實現類Jini的發現機制

下一篇：兩種最流行的開源CORBA實現