Java IDL は、一時オブジェクトだけをサポートしています。したがって、オブジェクトのサーバプロセスが停止するか再起動されると、オブジェクト参照は無効になります。このプログラム例 2 では、一時オブジェクトの状態を保存し、サーバが再起動されるたびにその状態から一時オブジェクトを初期化し直す方法を説明します。
プログラム例 2 のサーバは、文字列をファイルに保存する Hello オブジェクトを提供します。文字列は、コマンド行引数としてクライアントプログラムに渡します。サーバの Hello オブジェクトはこの文字列を「記憶」し、クライアントが次に実行されたとき、サーバが停止または再起動していても、この文字列をクライアントに返します。
プログラム例 2 は、持続性を持たせるための拡張が行われていることを除いて、プログラム例 1 と同じです。このページでは、拡張部分のコードについてだけ説明します。
このページでは、次の内容について説明します。
このプログラム例のコンパイル方法と実行方法については、「Hello World の構築方法と実行方法」を参照してください。
インタフェース定義 (
Hello.idl
)
module HelloApp { interface Hello { exception cantWriteFile{}; exception cantReadFile{}; string sayHello(in string message) raises (cantWriteFile); string lastMessage() raises (cantReadFile); }; };Hello オブジェクトではファイルを読み書きするため、Java 言語の例外をスローする必要があります (次の「サーバの実装」を参照)。Hello インタフェースでは、適切なスケルトン定義が生成されるように、例外を定義し発生させる必要があります。
sayHello
メソッドは、文字列引数をとるように変更されています。この文字列は、実行時にファイルに保存されます。また、ファイルに保存した文字列をクライアントに返すため、lastMessage
メソッドが追加されています。HelloApp/HelloPackage
ディレクトリを生成します。
HelloServer.java
)// Copyright and License import HelloApp.*; import org.omg.CosNaming.*; import org.omg.CosNaming.NamingContextPackage.*; import org.omg.CORBA.*; class HelloServant extends _HelloImplBase { public String sayHello(String msg) throws HelloApp.HelloPackage.cantWriteFile { try { synchronized(this) { File helloFile = new File("helloStorage.txt"); FileOutputStream fos = new FileOutputStream(helloFile); byte[] buf = new byte[msg.length()]; msg.getBytes(0, msg.length(), buf, 0); fos.write(buf); fos.close(); } } catch(Exception e) { throw new HelloApp.HelloPackage.cantWriteFile(); } return "¥nHello world !!¥n"; } public String lastMessage() throws HelloApp.HelloPackage.cantReadFile { try { synchronized(this) { File helloFile = new File("helloStorage.txt"); FileInputStream fis = new FileInputStream(helloFile); byte[] buf = new byte[1000]; int n = fis.read(buf); String lastmsg = new String(buf); fis.close(); return lastmsg; } } catch(Exception e) { throw new HelloApp.HelloPackage.cantReadFile(); } } } public class HelloServer { public static void main(String args[]) { try{ // create and initialize the ORB ORB orb = ORB.init(args, null); // create servant and register it with the ORB HelloServant helloRef = new HelloServant(); orb.connect(helloRef); // get the root naming context org.omg.CORBA.Object objRef = orb.resolve_initial_references("NameService"); NamingContext ncRef = NamingContextHelper.narrow(objRef); // bind the Object Reference in Naming NameComponent nc = new NameComponent("Hello", ""); NameComponent path[] = {nc}; ncRef.rebind(path, helloRef); // wait for invocations from clients java.lang.Object sync = new java.lang.Object(); synchronized (sync) { sync.wait(); } } catch (Exception e) { System.err.println("ERROR: " + e); e.printStackTrace(System.out); } } }
sayHello
メソッドと lastMessage
メソッドでは、IDL ファイルで定義されている例外をスローしています。これらのメソッドでは、ファイル入出力例外をスローしなければなりません。ファイル入出力例外をスローしない場合、Java 言語コンパイラは警告とエラーを発します。HelloServant
オブジェクトは非同期にメソッド要求を受け取り、場合によっては同時に複数のメソッド要求を受け取ることがあります。このため、ファイル入出力コード全体を synchronized
節で囲むようにします。HelloServer.main
は何も変更する必要はありません。
HelloClient.java
)// Copyright and License import HelloApp.*; import org.omg.CosNaming.*; import org.omg.CORBA.*; public class HelloClient { public static void main(String args[]) { try{ // create and initialize the ORB ORB orb = ORB.init(args, null); // get the root naming context org.omg.CORBA.Object objRef = orb.resolve_initial_references("NameService"); NamingContext ncRef = NamingContextHelper.narrow(objRef); // resolve the Object Reference in Naming NameComponent nc = new NameComponent("Hello", ""); NameComponent path[] = {nc}; Hello helloRef = HelloHelper.narrow(ncRef.resolve(path)); // call the Hello server object and print results String oldhello = helloRef.lastMessage(); System.out.println(oldhello); String hello = helloRef.sayHello(args[0]); System.out.println(hello); } catch (Exception e) { System.out.println("ERROR : " + e) ; e.printStackTrace(System.out); } } }このクライアントは、保存されたメッセージを
lastMessage
により取り出し、新しいメッセージを sayHello
への引数を使って保存します。
以下の説明では、Java IDL ネームサーバ用にポート 1050 を使用できることを前提としています。必要であれば、別のポートに変更してください。なお、1024 以下のポートを使用する場合は、UNIX マシンであればスーパーユーザの権限が、Windows95 および NT であれば管理者の権限が必要です。また、以下の説明ではパス名でスラッシュ (/) を使用していますが、Windows95 および NT ではバックスラッシュ (¥) に置き換える必要があります。
idltojava Hello.idl
javac *.java HelloApp/*.java
tnameserv -ORBInitialPort 1050&
java HelloServer -ORBInitialPort 1050
java HelloClient "remember this message" -ORBInitialPort 1050
ホーム |
Copyright © 1995-98 Sun Microsystems, Inc. All Rights Reserved.