RMI-IIOP

RMI-IIOP（RMI オーバー IIOP）とは、CORBAシステム上のJava RMIインタフェースを指す。

概要

この標準は、CORBA の利点を保ちつつ、CORBA アプリケーションの開発を単純化するべく作成された。RMI-IIOP は、CORBA 構造体、共用体、シーケンス、配列、文字列などを置換するコンテナとして働く Object by Value の概念に基づいている（CORBAの項目を参照）。IDLは使われていない。代わりに自動的にデータ構造定義を推定し、リフレクション機構で必要なデータを集める。CORBA では転送すべきデータ構造ごとに補助的なクラスを生成する必要があるが、RMI-IIOP ではリモートオブジェクト向けに生成されたコードを使うだけでよい。生成すべきコード量が少ないため、メモリ使用量も減らせる。

CORBA と RMI-IIOP はどちらも通信規格の GIOP を使用している。RMI-IIOP のデータ構造について、必要ならばIDLを生成することも可能で、それを使って、RMI-IIOP と純粋な CORBA アプリケーションの相互運用を行うことも可能である。

RMI-IIOP の最近のバージョンでは標準のサーバントクラスからサーバントを生成できる。これを使うと CORBA の ORB に手動で接続でき、Portable Object Adapter、Portable Interceptor、CORBA のネーミングサービスなどの各種 CORBA 機能に接続可能である。

Hello world の例

Java RMI-IIOP を実装したパッケージの標準的な名称は javax.rmi.CORBA である。

インタフェース

public interface MyServer extends Remote
{
  // クライアントは self を第一引数に渡す。サーバはクライアント側
  // にあるリモートメソッドを呼び出せる。これは要求処理に時間がかかる場合に
  // 便利である。
  void receiveRequest(MyClient client, String message) throws RemoteException;
}

public interface MyClient extends Remote
{
  // このリモートメソッドはサーバから呼び出される
  void receiveReply(String message) throws RemoteException;
}

クライアントとサーバの機能実装

public class MyServerImpl implements MyServer
{
   void receiveRequest(MyClient client, String message) throws RemoteException
   {
     System.out.println("The client says: "+message);
     client.receiveReply("Yes, "+message+", "+message+", "+message+"...");
   }
}

public class MyClientImpl implements MyClient
{
   MyServer server;
   public MyClientImpl(String Server_IOR, ORB orb)
     throws Exception
   {
     server = (MyServer) PortableRemoteObject.narrow(
                 orb.string_to_object(Server_IOR), MyServer.class);
   }
   // これはリモートメソッド
   void receiveReply(String message) throws RemoteException
   {
     System.out.println("And the answer is: "+message);
   }
   // これはリモートメソッドではなく、ローカルメソッド
   public void talk(String conversation)
   {
      server.receiveRequest(this, conversation);
   }
}

RMI-IIOP 開発ツール（rmic）は上記2つのクラスを使い、リモート側で使われる2つのスタブとサービス側で使われる2つの Tie を生成する。つまり、スタブと Tie のペアがそれぞれクライアント側とサーバ側に置かれる。

サーバ機能開始に必要なコード

       new Thread()
       {
         public void run()
         {
           try
             {
               // CORBA ORB の生成
               MyServerImpl.orb = ORB.init(args, properties);
               // ルート Portable Object Adapter を取得:
               POA rootPOA = POAHelper.narrow
                 (MyServerImpl.orb.resolve_initial_references("RootPOA"));              
               // MyServerImpl にはサーバがサポートしなければならない
               // メソッドの実装が含まれる。
               MyServerImpl impl = new MyServerImpl();
               PortableRemoteObject.exportObject(impl);
               // Tie の構築。Tie はサーバントでもある。
               // _MyServerImpl_Tie クラスは MyServerImpl から自動的に生成される。
               Tie tie = new _MyServerImpl_Tie();
               // この Tie の呼び出しターゲットを設定
               tie.setTarget(impl);
               // 対応する CORBA オブジェクトへの参照を取得:
               org.omg.CORBA.Object object = rootPOA.servant_to_reference((Servant) tie);
               // ルート POA の活性化
               rootPOA.the_POAManager().activate();
               // クライアントに渡す IOR URL を取得
               String Server_IOR = MyServerImpl.orb.object_to_string(object);
               MyServerImpl.orb.run();
               // 文字列変数 Server_IOR の内容をどうにかしてクライアントに
               // 転送しなければならない
             }
           catch (Exception exc)
             {
               exc.printStackTrace();
             }
         }
       }.start();

クライアント機能開始に必要なコード

      MyClient the_client;
      
       new Thread()
       {
         public void run()
         {
           try
             {
               ORB orb = ORB.init(args, parameters);
               the_client = new MyClientImpl(Server_IOR, orb);
               POA rootPOA = POAHelper.narrow(desk.orb.resolve_initial_references("RootPOA"));
               rootPOA.the_POAManager().activate();
               // Tie 構築
               Tie tie = new _MyClientImpl_Tie();
               // 実装クラス（呼び出しターゲット）の設定
               tie.setTarget(the_client);
               // Tie を POA サーバントとして接続
               org.omg.CORBA.Object object = rootPOA.servant_to_reference((Servant) tie);
               // IOR 文字列を使ってWeb上でこのオブジェクトを探すことが可能
               String IOR = desk.orb.object_to_string(object);
               orb.run();
             }
           catch (Exception exc)
             {
               exc.printStackTrace();
             }
         }
       }.start();

ORB スレッドが開始した後で、以下のコードを実行する:

the_client.talk("it is raining");

実行

最初にサーバ、次にクライアントがそれぞれ別のマシン上で開始される（同一マシンの別プロセスでもよい）。サーバは The client says: it is raining と表示する。クライアントは And the answer is: Yes, it is raining, it is raining, it is raining.. と表示する。

ここに示したコードはサン・マイクロシステムズの Java 1.5 と GNU Classpath 0.95 で動作する。

略語利用の法的問題

IIOP という略称はOMGの商標であり、利用には注意が必要である。このプロトコルは GIOP 上にあるため、GIOPを利用しているとした方がよい場合もある。これは間違いではないが、やや正確さを欠く（GIOP の実装は他にも様々存在する）。詳しくはGIOPを参照されたい。