CORBA again

(2017-05) 現代の環境でコンパイルできるよう, 更新した。10年ぶり、か。

CORBAでのクラス継承を試す。

Java の CORBAモジュール java.corba は、Java SE 11 (2018年9月リリース) で削除された。JEP 320: Remove the Java EE and CORBA Modules

代替としては, JacORB ぐらい。

インタフェイス

Counter / ReverseCounterインタフェイスのオブジェクトに対して, RPCで呼び出す. 

interface Counter {
    readonly attribute short value;
    void incr();
    void decr();
    string name();
};

interface ReverseCounter: Counter {
};

ReverseCounterはincr()で減算し，decr()で加算するようにする.

omniORB (C++)

次の環境;

  • Fedora 25 Linux
  • omniORB 4.2.1
  • gcc 6.3.1

サーバ

まず、オブジェクトを実装する。POA_インタフェイス名 から継承する。

C++
[RAW]
  1. class CounterImpl: public virtual POA_Counter,
  2. public virtual PortableServer::RefCountServantBase
  3. {
  4. protected:
  5. short count_;
  6. public:
  7. CounterImpl(): count_(0) { }
  8. virtual ~CounterImpl() { }
  10. virtual CORBA::Short value(){ return count_; }
  11. virtual void incr() { count_++; }
  12. virtual void decr() { count_--; }
  13. virtual char* name() { return CORBA::string_dup("通常Counter"); }
  14. protected:
  15. CounterImpl(short v): count_(v) { }
  16. };
  19. ////////////////////////////////////////////////////////////////////////
  20. // ReverseCounterImpl
  22. class ReverseCounterImpl: public virtual POA_ReverseCounter,
  23. public virtual PortableServer::RefCountServantBase,
  24. public virtual CounterImpl
  25. {
  26. typedef CounterImpl super;
  27. public:
  28. ReverseCounterImpl(): super(1000) { }
  29. virtual ~ReverseCounterImpl() { }
  31. virtual void incr() { count_--; }
  32. virtual void decr() { count_++; }
  33. virtual char* name() { return CORBA::string_dup("Reverse(逆進)Counter"); }
  34. };

CORBA::Object_var で受けて, _narrow() で目的のクラスにダウンキャストする。

インタフェイス名_var とインタフェイス名_ptr がある. _varはスコープから抜けるときに解放され, _ptr はそうではない。

実装クラスからインタフェイスクラスを得るには, _this()を呼び出す。

サーバ側では, クライアントからオブジェクトを探せるように, 次の二つのいずれかの方法を採る;

  1. name service にオブジェクトを登録する. クライアントでは名前で検索する.
  2. ファイルに, オブジェクトを object_to_string() したものを書き出す. この文字列は, Interoperable Object Reference (IOR) と呼ばれ, サーバのプロセスなどの情報が含まれる。
C++
[RAW]
  1. int main(int argc, char* argv[])
  2. {
  3. // Initialise the ORB.
  4. CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "omniORB4");
  6. CORBA::Object_var obj;
  8. #ifdef USE_NAME_SERVICE
  9. CosNaming::NamingContext_var rootContext;
  11. // Obtain a reference to the root context of the Name service:
  12. obj = orb->resolve_initial_references("NameService");
  13. rootContext = CosNaming::NamingContext::_narrow(obj);
  14. if( CORBA::is_nil(rootContext) ) {
  15. cerr << "Failed to narrow the root naming context." << endl;
  16. return 1;
  17. }
  18. #endif // USE_NAME_SERVICE
  20. try {
  21. // Obtain a reference to the root POA.
  22. obj = orb->resolve_initial_references("RootPOA");
  23. PortableServer::POA_var rootPOA = PortableServer::POA::_narrow(obj);
  25. // We allocate the objects on the heap. Since these are reference
  26. // counted objects, they will be deleted by the POA when they are no
  27. // longer needed.
  28. CounterImpl* myCounter = new CounterImpl();
  29. ReverseCounterImpl* myReverseCounter = new ReverseCounterImpl();
  31. // Activate the objects. This tells the POA that the objects are
  32. // ready to accept requests.
  33. PortableServer::ObjectId_var myCounter_iid
  34. = rootPOA->activate_object(myCounter);
  35. PortableServer::ObjectId_var myReverseCounter_iid
  36. = rootPOA->activate_object(myReverseCounter);
  38. #ifdef USE_NAME_SERVICE
  39. bindObjectToName(orb, rootContext, myCounter->_this(), COUNTER_NAME);
  40. bindObjectToName(orb, rootContext, myReverseCounter->_this(), REVERSE_NAME);
  41. #else
  42. // Obtain a reference to each object and output the stringified
  43. // IOR to ior-file
  44. FILE* fp = fopen(IOR_FILE, "w");
  45. if (!fp) {
  46. perror("ior-file open failed");
  47. return 1;
  48. }
  49. CORBA::String_var sior;
  50. sior = orb->object_to_string(myCounter->_this());
  51. fprintf(fp, "%s\n", (const char*) sior);
  52. sior = orb->object_to_string(myReverseCounter->_this());
  53. fprintf(fp, "%s\n", (const char*) sior);
  54. fclose(fp);
  55. #endif // USE_NAME_SERVICE
  57. // Obtain a POAManager, and tell the POA to start accepting
  58. // requests on its objects.
  59. PortableServer::POAManager_var poaMgr = rootPOA->the_POAManager();
  60. poaMgr->activate();
  62. // main loop
  63. printf("ready.\n");
  64. orb->run();
  66. rootPOA->destroy(true, true);
  67. delete myCounter;
  68. delete myReverseCounter;
  70. #ifndef USE_NAME_SERVICE
  71. remove(IOR_FILE);
  72. #endif // !USE_NAME_SERVICE
  73. }
  74. catch(CORBA::SystemException&) {
  75. cerr << "Caught CORBA::SystemException." << endl;
  76. }
  77. catch(CORBA::Exception&) {
  78. cerr << "Caught CORBA::Exception." << endl;
  79. }
  80. catch(omniORB::fatalException& fe) {
  81. cerr << "Caught omniORB::fatalException:" << endl;
  82. cerr << " file: " << fe.file() << endl;
  83. cerr << " line: " << fe.line() << endl;
  84. cerr << " mesg: " << fe.errmsg() << endl;
  85. }
  86. catch(...) {
  87. cerr << "Caught unknown exception." << endl;
  88. }
  90. orb->destroy();
  92. return 0;
  93. }

クライアント

インタフェイス名_ptr を使って、各メソッドを呼び出す.

C++
[RAW]
  1. // ReverseCounter_ptr を与えることもできる。
  2. void do_test(Counter_ptr counter)
  3. {
  4. CORBA::String_var name = counter->name();
  5. printf("name = %s\n", name.in());
  7. int i;
  8. printf("incr(): ");
  9. for (i = 0; i < 5; i++) {
  10. counter->incr();
  11. printf(" %d", counter->value());
  12. }
  13. printf(".\n");
  15. printf("decr(): ");
  16. for (i = 0; i < 3; i++) {
  17. counter->decr();
  18. printf(" %d", counter->value());
  19. }
  20. printf(".\n");
  21. }

ほんで, main関数. オブジェクトへの参照は CORBA::Object_var

C++
[RAW]
  1. int main(int argc, char* argv[])
  2. {
  3. // omniORBは第3引数を省略できない
  4. CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "omniORB4");
  6. CORBA::Object_var obj;
  8. #ifdef USE_NAME_SERVICE
  9. CosNaming::NamingContext_var rootContext;
  11. // Obtain a reference to the root context of the Name service:
  12. obj = orb->resolve_initial_references("NameService");
  13. rootContext = CosNaming::NamingContext::_narrow(obj);
  14. if( CORBA::is_nil(rootContext) ) {
  15. cerr << "Failed to narrow the root naming context." << endl;
  16. return 1;
  17. }
  18. #endif // USE_NAME_SERVICE
  20. try {
  21. #ifdef USE_NAME_SERVICE
  22. CORBA::Object_var obj_nc = getObjectReference(orb, rootContext,
  23. COUNTER_NAME);
  24. CORBA::Object_var obj_rc = getObjectReference(orb, rootContext,
  25. REVERSE_NAME);
  26. #else
  27. FILE* fp = fopen(IOR_FILE, "r");
  28. if (!fp) {
  29. perror("file open");
  30. return 1;
  31. }
  32. CORBA::Object_var obj_nc = orb->string_to_object(read_line(fp));
  33. CORBA::Object_var obj_rc = orb->string_to_object(read_line(fp));
  34. fclose(fp);
  35. if (!obj_nc || !obj_rc) {
  36. printf("ior error.\n");
  37. return 1;
  38. }
  39. #endif // USE_NAME_SERVICE
  41. Counter_var nc = Counter::_narrow(obj_nc);
  42. ReverseCounter_var rc = ReverseCounter::_narrow(obj_rc);
  43. if (CORBA::is_nil(nc) || CORBA::is_nil(rc)) {
  44. printf("cannot invoke on a nil object\n");
  45. return 1;
  46. }
  48. do_test(nc);
  49. do_test(rc);
  50. }
  51. catch (CORBA::SystemException&) {
  52. cerr << "Caught CORBA::SystemException." << endl;
  53. }
  54. catch (CORBA::Exception& e) {
  55. cerr << "Caught CORBA::Exception." << endl;
  56. }
  57. catch (...) {
  58. printf("unknown exception.\n");
  59. }
  61. orb->destroy();
  63. return 0;
  64. }

実行方法

name serviceを使う場合は, あらかじめ root ユーザで name server を起動しておく。 

# omniNames -always

/var/omninames/ 以下にデータを書き込む。

omniORB は, /etc/omniORB.cfg ファイルの設定を見るので, name service を使う場合でも, プログラムの起動時にポート番号などを与える必要はない。 

$ ./server 
ready.

$ ./client 
name = 通常Counter
incr():  1 2 3 4 5.
decr():  4 3 2.
name = Reverse(逆進)Counter
incr():  999 998 997 996 995.
decr():  996 997 998.

Java

Java SE 8.

サーバ

Javaは多重継承がないので, CounterImpl を継承できない。同じコードでも再度定義する。

Java
[RAW]
  1. class CounterImpl extends CounterPOA
  2. {
  3. protected short count_;
  5. public CounterImpl() { super(); count_ = 0; }
  7. public short value() { return count_; }
  8. public void incr() { count_++; }
  9. public void decr() { count_--; }
  10. public String name() { return "Counter"; }
  11. };
  14. class ReverseCounterImpl extends ReverseCounterPOA
  15. {
  16. protected short count_;
  18. public ReverseCounterImpl() { super(); count_ = 1000; }
  20. public short value() { return count_; }
  21. public void incr() { count_--; }
  22. public void decr() { count_++; }
  23. public String name() { return "ReverseCounter"; }
  24. };

mainメソッド. 流れは C++版と同じ.

Java
[RAW]
  1. // サーバ実装
  2. class Server
  3. {
  4. public static void main(String[] args) {
  5. try {
  6. ORB orb = ORB.init(args, null);
  8. // Get reference to rootpoa & activate the POAManager
  9. POA rootPOA = POAHelper.narrow(orb.resolve_initial_references("RootPOA"));
  10. rootPOA.the_POAManager().activate();
  12. // create servants.
  13. //CounterImpl counterImpl = new CounterImpl();
  14. //ReverseCounterImpl revCounterImpl = new ReverseCounterImpl();
  16. // create a tie, with servant being the delegate.
  17. CounterPOATie ncTie
  18. = new CounterPOATie(new CounterImpl(), rootPOA);
  19. ReverseCounterPOATie rcTie
  20. = new ReverseCounterPOATie(new ReverseCounterImpl(),
  21. rootPOA);
  22. // obtain the objectRef for the tie.
  23. // this step also implicitly activates the object.
  24. Counter ncRef = ncTie._this(orb);
  25. ReverseCounter rcRef = rcTie._this(orb);
  27. if (Config.USE_NAME_SERVICE) {
  28. org.omg.CORBA.Object nameRef
  29. = orb.resolve_initial_references("NameService");
  30. NamingContext naming = NamingContextHelper.narrow(nameRef);
  32. // (id, kind) の組が一致しなければならない.
  33. NameComponent nc = new NameComponent(Config.COUNTER_NAME,
  34. "Object");
  35. NameComponent[] pathNC = { nc };
  36. naming.rebind(pathNC, ncRef);
  38. NameComponent rc = new NameComponent(Config.REV_COUNTER_NAME,
  39. "Object");
  40. NameComponent[] pathRC = { rc };
  41. naming.rebind(pathRC, rcRef);
  42. }
  43. else {
  44. // IORファイルに書き出す
  45. FileWriter out = new FileWriter("../counter.ior");
  47. // 型が abstract String object_to_string(Object obj) なので、
  48. // 型検査がなってない.
  49. String ncIOR = orb.object_to_string(ncRef);
  50. String rcIOR = orb.object_to_string(rcRef);
  51. out.write(ncIOR + "\n");
  52. out.write(rcIOR + "\n");
  53. out.close();
  54. }
  56. // メインループ
  57. orb.run();
  58. //System.out.println("ready.");
  59. //java.lang.Object sync = new java.lang.Object();
  60. //synchronized(sync) {
  61. // sync.wait();
  62. //}
  63. }
  64. catch (Exception e) {
  65. e.printStackTrace(System.err);
  66. }
  67. }
  68. };

クライアント

こちらも, C++と同じ流れ。

Java
[RAW]
  1. // クライアント実装
  2. class Client
  3. {
  4. public static void main(String[] args) {
  5. try {
  6. ORB orb = ORB.init(args, null);
  8. org.omg.CORBA.Object ncRef;
  9. org.omg.CORBA.Object rcRef;
  11. if (Config.USE_NAME_SERVICE) {
  12. org.omg.CORBA.Object nameRef
  13. = orb.resolve_initial_references("NameService");
  14. NamingContext naming = NamingContextHelper.narrow(nameRef);
  16. NameComponent nc = new NameComponent(Config.COUNTER_NAME,
  17. "Object");
  18. NameComponent[] pathNC = { nc };
  19. ncRef = naming.resolve(pathNC);
  21. NameComponent rc = new NameComponent(Config.REV_COUNTER_NAME,
  22. "Object");
  23. NameComponent[] pathRC = { rc };
  24. rcRef = naming.resolve(pathRC);
  25. }
  26. else {
  27. // IORファイルから読み込む
  28. BufferedReader in = new BufferedReader(
  29. new FileReader("../counter.ior"));
  30. String ncIOR = in.readLine();
  31. String rcIOR = in.readLine();
  33. ncRef = orb.string_to_object(ncIOR);
  34. rcRef = orb.string_to_object(rcIOR);
  35. }
  37. Counter[] counter = new Counter[2];
  38. counter[0] = CounterHelper.narrow(ncRef);
  39. counter[1] = ReverseCounterHelper.narrow(rcRef);
  41. for (int k = 0; k < 2; k++) {
  42. System.out.println(counter[k].name());
  44. for (int i = 0; i < 10; i++) {
  45. counter[k].incr();
  46. System.out.print(" " + counter[k].value());
  47. }
  48. System.out.println(".");
  50. for (int i = 0; i < 5; i++) {
  51. counter[k].decr();
  52. System.out.print(" " + counter[k].value());
  53. }
  54. System.out.println(".");
  55. }
  56. }
  57. catch (Exception e) {
  58. e.printStackTrace(System.err);
  59. }
  60. }
  61. };

実行方法

name serviceを使う場合は, name server のホスト名, ポート番号を引数で与える. IORをファイルでやりとりする場合は、オプションを何も与えなくても大丈夫。

次の例は, omniORB の name server を使う場合。 

$ java Server -ORBInitialPort 2809 -ORBInitialHost lolhost

$ java Client -ORBInitialPort 2809 -ORBInitialHost localhost

IORファイルを使う場合, name service を使う場合のいずれでも、omniORB / Java 間で当然, メソッドの呼び出しができる。

gtk3クライアント

次の環境;

  • gtk3 3.22.15
  • glade 3.20.0

ORBit2 はすでに廃れているので, omniORBを使う。

ウィンドウは, glade3 で, GtkBuilder形式で作る。

本体 (C++).

C++
[RAW]
  1. #include "../../config.h"
  3. #include <gtk/gtk.h>
  4. #include "support.h"
  5. #include "gtk2sample.h"
  6. #include "../misc.h"
  8. CounterSet csets[2];
  10. // UI
  11. GtkBuilder* builder;
  13. int main(int argc, char* argv[])
  14. {
  15. GtkWindow* window1;
  17. #ifdef ENABLE_NLS
  18. bindtextdomain (GETTEXT_PACKAGE, PACKAGE_LOCALE_DIR);
  19. bind_textdomain_codeset (GETTEXT_PACKAGE, "UTF-8");
  20. textdomain (GETTEXT_PACKAGE);
  21. #endif
  23. gtk_init(&argc, &argv);
  24. add_pixmap_directory (PACKAGE_DATA_DIR "/" PACKAGE "/pixmaps");
  26. CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "omniORB4");
  28. #ifdef USE_NAME_SERVICE
  29. CORBA::Object_var obj;
  30. obj = orb->resolve_initial_references("NameService");
  31. CosNaming::NamingContext_var rootContext =
  32. CosNaming::NamingContext::_narrow(obj);
  33. if ( !rootContext ) {
  34. printf("resolve NameService failed.\n");
  35. return 1;
  36. }
  38. CosNaming::Name name;
  39. name.length(1);
  40. name[0].id = CORBA::string_dup(COUNTER_NAME);
  41. name[0].kind = "Object"; // string copied
  42. obj = rootContext->resolve(name);
  43. csets[0].counter = Counter::_narrow(obj);
  45. name.length(1);
  46. name[0].id = CORBA::string_dup(REVERSE_NAME);
  47. name[0].kind = "Object"; // string copied
  48. obj = rootContext->resolve(name);
  49. csets[1].counter = ReverseCounter::_narrow(obj);
  50. #else
  51. FILE* fp = fopen(IOR_FILE, "r");
  52. if (!fp) {
  53. perror("file open");
  54. return 1;
  55. }
  56. // Counter_ptr と Counter_var の二つの型がある。前者はポインタ.
  57. // _narrow() は Counter_ptr または ReverseCounter_ptr を返す.
  58. csets[0].counter = Counter::_narrow(orb->string_to_object(read_line(fp)));
  59. csets[1].counter = ReverseCounter::_narrow(orb->string_to_object(read_line(fp)));
  60. fclose(fp);
  61. #endif // USE_NAME_SERVICE
  63. if (CORBA::is_nil(csets[0].counter) || CORBA::is_nil(csets[1].counter)) {
  64. printf("ior error.\n");
  65. return 1;
  66. }
  68. /*
  69. * The following code was added by Glade to create one of each component
  70. * (except popup menus), just so that you see something after building
  71. * the project. Delete any components that you don't want shown initially.
  72. */
  73. builder = gtk_builder_new();
  74. GError* error = nullptr;
  76. gtk_builder_add_from_file(builder, "gtk3-window.ui", &error);
  77. g_assert_no_error(error);
  79. // リンク時に -rdynamic オプションが必要.
  80. gtk_builder_connect_signals(builder, nullptr);
  82. window1 = GTK_WINDOW( gtk_builder_get_object(builder, "window1") );
  83. gtk_widget_show_all( GTK_WIDGET(window1) );
  85. gtk_main ();
  87. // ポインタは解放する.
  88. Counter_Helper::release(csets[0].counter);
  89. Counter_Helper::release(csets[1].counter);
  91. return 0;
  92. }

実行結果

昔の

Linux版はgtk+（GUI）クライアントも実装してみた。

　C++の場合は多重継承を使って実装する。plain Cだと（C++ならコンパイラが自動でやってくれる）vtableを手で書く。Javaは多重継承が使えないので，TIE（委譲）モデルで実装する。

　IORを文字列にして渡すというヘボい方法なら，JDK 1.2をサーバーにしたとき以外はどの組み合わせでも問題なく接続できる。

＼クライアント
サーバー＼		LinuxWindows
omniORB mico ORBacus ORBit omniORB JDK 1.2
omniORB
on Linux 		○ ○ ○ (未) ○ ○
mico
on Linux (注1) 		○ ○ ○ ○ ○ ○
ORBacus
on Linux 		○ ○ ○ (未) ○ ○
ORBit
on Linux 		(未) ○ (未) ○ ○ ○
omniORB
on Windows		○ ○ ○ ○ ○ ○
JDK 1.2
on Windows		× (注2)× (注3)× (注3)× (注3)○ ○
注1: micoをサーバーにするとき，BOAではなくPOAを使う必要あり。BOAではクライアント側がBAD_OPERATION例外を発生する
注2: CORBA/COMM_FAILURE例外
注3: ハングアップ？

　ネームサービスを介してオブジェクトをやり取りするのは，ORBの組み合わせによって上手くいったりいかなかったりして，2000年1月現在では難しい。

2000.11.19
ORBit, mico, omniORB, JavaによるCounter/ReverseCounterリモートオブジェクトの相互接続のテスト
2000.01.03
gtk+クライアント
1999.05.16
ORBit
1999.04.23
mico

ソースコードをまとめたもの: