技術的雑談-RMIのFastStart

WindowsXP
JDK1.4.2_08

目的

TOP ↑ ↓

とりあえずJava RMI使ってみましょう。

Java RMIとは？

TOP ↑ ↓

Java(JDK)で標準でサポートしている「Remote Method Invocation」のことです。~
CORBAみたいな感じに、別のマシン(同じマシンでもですが)にあるオブジェクトのメソッドを実行できます。

CORBAとの大きな違いは、

Java専用である事(厳密には違うみたいですが…)
JDKのほかにコンポーネントが不要な事(既に実装されている)
リモート公開されるClassのスタブを利用する側に持っていかなくてもいい！！(自動でClassスタブが転送されるみたいです！？)←これ、便利かも。

必要なもの

TOP ↑ ↓

JDK(1.4でも5.0でも可。バージョンをまたいでの通信も出来るようです。）

このなかで、以下のものを特に使います。

rmicコマンド -- RMIで公開するObject Classからスタブを作成します。(JDK1.5同士の通信では不要らしい)
rmidコマンド -- RMIで使われるデーモンです
rmiregistryコマンド -- RMIで使われるデーモンです

デーモンの起動

TOP ↑ ↓

RMIを使うには、RMIのObjectを公開する側のマシンでrmid、rmiregistryデーモンが上がっている必要があります。
ここではService化しないで、とりあえずコマンドプロンプトからバッチで起動しています。

rmid

TOP ↑ ↓

REM Windowsの場合
SET CLASSPATH=
start rmid

rmiregistry

TOP ↑ ↓

REM Windowsの場合
SET CLASSPATH=
start rmiregistry

※セキュリティーが設定されている場合は「-J-Djava.security.policy=＜ポリシーファイル＞」で、権限を追加する必要があるかもしれません。

※CLASSPATHをクリアしているのは、共有classを自動転送する再に邪魔になるらしいのです。転送するclassは-Djava.rmi.server.codebaseで明示的に指定します。

Servantの起動

TOP ↑ ↓

Servantを実装したClassを

-Djava.rmi.server.codebase=file:///＜共有するClassのある場所＞/

付きのjavaで起動します。

classファイルを使う場合は、classesディレクトリへのパスを「最後は\で終わるように」指定します。
.jarになっている場合、それを指定する事も出来ます。

とにかく、「共有するClass(ソースではなく、コンパイルされたCLASS！)のある場所を指定する」と考えてください。(CLASSPATH環境変数と一緒です。)

RMIの場合、JacORBの「lsns」みたいな登録Servant一覧コマンドみたいなのが見当たらないので、以下のようなものを作ってみました。

/!!
 * RMIでRMIRegistryに登録されているObjectを一覧するApplication
 */
package test;

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

/!!
 * RMI Registry List Sample<br>
 * @author Tsubasa
 */
public class RMIListObject {

    /!!
     * main<br>
     * <br>
     * Command line 引数:<br>
     * RMIListObject → LocahostのObject一覧<br>
     * RMIListObject HOST → そのHostのRMIに登録されているObjectの一覧<br>
     * RMIListObject HOST -d URL → そのHOSTのそのURLに登録されているObjectを削除<br>
     * @param args Command line parameters
     */
    public static void main(String[] args) {
        
        String host = "";
        if (args.length == 0) {
            host = "localhost";
        } else {
            host = args[0];
        }
        
        if( host.equalsIgnoreCase("-help")) {
            printUsage();
            System.exit(0);
        }
        
        String url = "";
        if (args.length == 3) {
            if ((!args[1].equals("-d")) && (!args[1].equals("-D"))) {
                printUsage();
                System.exit(1);
            }
            url = args[2];
        } else if ((args.length != 1) && (args.length != 0) ){
            printUsage();
            System.exit(1);
        }
        
        try {
            Registry registry = LocateRegistry.getRegistry(host);
            
            if (url.equals("")) {
                // List一覧
                String[] list = registry.list();
                for(int i = 0; i < list.length; ++i) {
                    System.out.println(list[i]);
                }
                
            } else {
                registry.unbind(url);
            }
            
        } catch (Exception e) {
            System.err.println("Client exception:");
            e.printStackTrace(System.err);
        }

    }
    
    protected static void printUsage() {
        System.err.println("Usage : RMIListObject [HOST [-d URL]]");
    }

}

Clientの起動

TOP ↑ ↓

こっちは普通のJava Applicationのように起動するだけです。

プログラミング

TOP ↑ ↓

Interfaceの定義(Interface)

TOP ↑ ↓

IDLは書かずに普通にJavaのInterfaceを書きます。

java.rmi.Remoteをextendします
メソッドは全てjava.rmi.RemoteExceptionをthrowするようにする

これだけ守ればOKみたいです。~
JDK1.5で多少扱いが変わったようなことが書いてありましたが…。

Servantの実装(Impl)

TOP ↑ ↓

先程作ったInterfaceをimplimentするClassを書けばOK。
簡単。

Serverの作成

TOP ↑ ↓

ServantをRMIRepositryに登録する部分を書きます。

公開するServant実体Object(Servant Impl)をnewします。
Servant Objectを公開できる形にします。「【ServantInterface】 ref = (【ServantInterface】)java.rmi.server.UnicastRemoteObject.exportObject(【servantImpl】, 【portNum】);」
1. 【ServantInterface】 -- ServantのInterface Class
2. 【ServantImpl】 -- 先程newしたServantの実体Object
3. 【portNum】 -- ServantがbindされるネットワークポートNo.(0で自動決定)
RMIRepositryに登録する。「java.rmi.registry.Registry registry = java.rmi.registry.LocateRegistry.getRegistry(host);」でhostのRepositryを取得し、「registry.bind("＜URL＞", ref);」でbindします。＜URL＞は公開するURL(//～/～)です。←別項参照！！
既に公開されているServantを再度上書き登録するには「.rebind」メソッドを使います。(公開されていないものをrebindしてもExceptionになる)

これで、外からこのObjectが参照できます。

Servantの登録を削除するには、java.rmi.registry.Registry#unbind(＜URL＞)で行います。

尚、JDK1.4が絡む環境(ClientがJDK1.4)では、Servantをjavacでコンパイルした後に、Servantの実装Class(【ServantImpl】)に対して「rmic」コマンドを通す必要があります。Servant,Clientが両方ともJDK1.5の環境ではrmicは不要との記述もありますが、確認していません。

Clientの実装

TOP ↑ ↓

java.rmi.registry.LocateRegistry.getRegistry(host)でObjectの登録してあるRegistryを取得します。
【ServantInterface】 obj = (【ServantInterface】)java.rmi.registry.registry.lookup(<URL>); でURLにbindされているObjectを取得します。

あとはそのObjectを使うだけ。

使い終わったら……「obj = null;」すればいいのかなぁ…(ちょっと弱気、でもとりあえず問題なさげ)