RMI學習筆記

一個//ip:port/name能夠惟必定位一個RMI服務器上的發佈了的對象html

其中 host 是註冊表所在的主機(遠程或本地),port 是註冊表接受調用的端口號,name 是未經註冊表解釋的簡單字符串。host 和 port 二者都是可選項。若是省略了 host,則主機默認爲本地主機。若是省略了 port,則端口默認爲 1099,該端口是 RMI 的註冊表 rmiregistry 使用的「著名」端口。java

 

簡單說下工做的原理:服務器

這裏假設RMI有3個部分構成,第一個是RMIService即JDK提供的一個能夠獨立運行的程序(bin目錄下的rmiregistry),第二個是RMIServer即咱們本身編寫的一個java項目,這個項目對外提供服務。第三個是RMIClient即咱們本身編寫的另一個java項目,這個項目遠程使用RMIServer提供的服務。函數

首先,RMIService必須先啓動並開始監聽對應的端口。測試

其次,RMIServer將本身提供的服務的實現類註冊到RMIService上,並指定一個訪問的路徑(或者說名稱)供RMIClient使用。url

最後,RMIClient使用事先知道(或和RMIServer約定好)的路徑(或名稱)到RMIService上去尋找這個服務,並使用這個服務在本地的接口調用服務的具體方法。spa

通俗的講完了再稍微技術的講下:server

首先,在一個JVM中啓動rmiregistry服務,啓動時能夠指定服務監聽的端口,也可使用默認的端口。xml

其次,RMIServer在本地先實例化一個提供服務的實現類,而後經過RMI提供的Naming,Context,Registry等類的bind或rebind方法將剛纔實例化好的實現類註冊到RMIService上並對外暴露一個名稱。htm

最後,RMIClient經過本地的接口和一個已知的名稱(即RMIServer暴露出的名稱)再使用RMI提供的Naming,Context,Registry等類的lookup方法從RMIService那拿到實現類。這樣雖然本地沒有這個類的實現類,但全部的方法都在接口裏了,想怎麼調就怎麼調吧。

值得注意的是理論上講RMIService,RMIServer,RMIClient能夠部署到3個不一樣的JVM中,這個時候的執行的順序是RMIService---RMIServer—RMIClient。另外也能夠由RMIServer來啓動RMIService這時候執行的順序是RMIServer—RMIService—RMIClient。

除了這些外再說幾點理論上的廢話:

一、使用RMI的時候RMIClient須要知道RMIServer註冊時暴露出來的路徑或名稱。

二、RMIClient要有實現類的接口。

三、接口必定要繼承Remote。

四、實現類除了實現接口外還要實現Serializable接口,有須要的話還要繼承UnicastRemoteObject

 

 

RMI的基礎是接口,RMI構架基於一個重要的原理:定義接口和定義接口的具體實現是分開的。 

一個簡單的RMI系統,通常能夠分紅4個文件,下面來介紹各個文件的建立和做用 

第一步:建立一個遠程對象接口 

import java.rmi.Remote; 
import java.rmi.RemoteException; 

/* 
* 這個接口繼承自Remote,每個定義的方法都必須拋出一個RemoteException異常對象 
* 咱們可供遠程調用的方法就是經過這裏開公開 
*/ 
public interface IRMI extends Remote{ 
    public String invoke() throws RemoteException; 


第二步:建立接口的具體實現類 

import java.rmi.RemoteException; 
import java.rmi.server.UnicastRemoteObject; 

/* 
* 遠程對象的實現 
* 公開方法的具體實現就是這裏定義的 
*/ 
public class IRMIImpl extends UnicastRemoteObject implements IRMI { 
    
    protected IRMIImpl() throws RemoteException { 
        super(); // 這個實現必須有一個顯式的構造函數,而且要拋出一個RemoteException異常 
    } 
    
    private static final long serialVersionUID = 6131922116577454476L; 
    
    public String invoke() throws RemoteException {  //該方法公開 
        return "hello,world!"; 
    } 
    
    public String tryInvoke() throws RemoteException{ //該方法未公開,若要公開請在接口中定義 
       return "try to remote me"; 
    } 


第三步:建立RMI服務器 

import java.rmi.Naming; 
import java.rmi.registry.LocateRegistry; 
import java.rmi.registry.Registry; 

/* 
* 遠程對象的註冊類 該類應該在服務器端執行,執行以後 
* 該機器將變爲RMI服務器 客戶端能夠經過正確的url來訪問 
* 服務器上的遠程對象,執行對外報露的方法 
*/ 

public class RMIServer { 
    static int port = 8888; 
   
    /* 
     * 建立一個Registry對象. 
     * LocateRegistry用於獲取名字服務或建立名字服務. 
     * 調用LocateRegistry.createRegistry(int port)方法能夠在某一特定端口建立名字服務,從而用戶無需再手工啓動rmiregistry 
     * @return 返回一個Registry對象 
     */ 
    private static Registry createRegistry() { 
        Registry registry = null; 
        try { 
            registry = LocateRegistry.getRegistry(port); //若是該端口未被註冊,則拋異常 
            registry.list(); //拿到該端口註冊的rmi對象 
        } catch (final Exception e) { 
            try { 
                registry = LocateRegistry.createRegistry(port);//捕獲異常,端口註冊 
            } catch (final Exception ee) { 
                ee.printStackTrace(); 
            } 
        } 
        return registry; 
    } 

    /** 
     * 將對象註冊到rmi服務器上 
     */ 
    public static void bind() { 
        Registry registry =  createRegistry(); 
        try { 
            IRMIImpl impl = new IRMIImpl(); 
            registry.rebind("mytask", impl); //這就是綁定,client裏lookup必須和"mytast"同樣才能遠程調用impl 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    } 

   public static void main(String[] args) { 
        try { 
            bind(); 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    } 


上面是一種比較好的寫法,若是隻是要測試,能夠直接在main()方法中寫: 

    ImplementClass ic = new ImplementClass(); //具體實現類 
    Registry r = LocateRegistry.createRegistry(8888); 
    r.bind("mytask", ic); 
    //Naming.rebind("rmi://localhost:8888/mytask", ic); 可替換上句 

1.註冊一個端口  2.在註冊端口綁定taskName和implementClass  3.客戶端就能夠經過url和taskName來找到implementClass。 

第四步:建立RMI客戶端 

import java.rmi.Naming; 

public class RMIClient { 
    /** 
     * 調用遠程對象中的方法 
     * @throws Exception 
     */ 
    public static void getRemoteObject() throws Exception{ 
    
    /*獲得遠程發佈的服務 
    返回與指定 name 關聯的遠程對象的引用(一個stub)*/ 
        IRMI obj = (IRMI)Naming.lookup("rmi://localhost:"+RMIServer.port+"/mytask");  //注:經過接口拿 

        System.out.println(obj.invoke()); //調用遠程服務的方法 
    } 

    public static void main(String[] args) { 
        try { 
            getRemoteObject(); 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    } 


實際使用過程當中遇到奇怪狀況

registry.rebind("bpserver", ic);綁定服務就一直不動

換成Naming.rebind("rmi://localhost:2005/bpserver", ic); 就能夠,其中原理待研究?

 

參考

http://skanion.iteye.com/blog/1168747

http://blog.sina.com.cn/s/blog_4918a7d90100oftg.html

相關文章
相關標籤/搜索