Создание CORBA приложения на Java начинается с написания интерфейса для удаленного объекта, используя язык описания интерфейсов (Interface Definition Language, IDL).

Создадим файл test.idl

module testApp {
    interface test
    {
       long count(in string msg);
    };
};

Данный интерфейс описывает лишь один метод count. Причем, нам не важно, что делает этот метод, главное мы определяем, что он есть, определяем какие у него входные и выходные параметры.

Воспользуемся компилятором idltojava.

        idltojava Hello.idl

        idltojava –fno-cpp Hello.idl

Результат работы данной программы можно представить в виде схемы.

В текущей директории появилась новая папка testApp, в которой содержатся пять java-файлов. Каждый из них имеет свое назначение.

_testImplBase.java — абстрактный класс, который представляет собой не что иное, как скелет сервера (skeleton) и обеспечивает функциональность сервера;

_testStub.java — класс, реализующий заглушку (stub) клиента. Обеспечивает функциональность клиента;

test.java — класс, содержащий описание интерфейса test на языке Java;

testHelper.java и testHolder.java — классы, предоставляющие вспомогательные функции для CORBA объектов.

Теперь наша задача — написать класс, реализующий интерфейс test. Такие классы должны называться так, чтобы в их имени было слово “Servant”, в нашем случае это будет testServant.

class testServant extends _testImplBase
{
    public int count(String msg)
    {
        return msg.length();
    }
}

Обратите внимание, что этот класс унаследован от _testImplBase. Как видно, здесь реализован метод count, который в данном примере считает количество букв в принятом сообщении.

Теперь перейдем непосредственно к написанию серверной части приложения.

Первое что мы делаем, создаем ORB. Затем создаем экземпляр класса удаленного объекта (testServant) и регистрируем его в ORB. Дальше вызываем специальную службу имен (NameService) и регистрируем в ней имя удаленного объекта, чтобы клиент смог его найти (есть и другой способ нахождения удаленного объекта, но о нем чуть позже).

Рассмотрим подробнее эти этапы.

1. Создание и инициализация ORB. Производится вызовом статического метода init класса ORB

   ORB orb = ORB.init();
   

2. Создание экземпляра класса удаленного объекта и регистрация его в ORB

   testServant testRef = new testServant();
   
   orb.connect(testRef);
   

3. Получение контекста имен (NamingContext)

   org.omg.CORBA.Object objRef =
   
   orb.resolve_initial_references("NameService");
   
   NamingContext ncRef = NamingContextHelper.narrow(objRef);
   

   в первой строчке мы получаем объектую ссылку на службу имен (NameService). Но фактически это обыкновенный CORBA-объект и для того, чтобы использовать его как контекст имен (NamingContext), необходимо вызвать метод narrow класса NamingContextHelper, который как бы конкретизирует данный CORBA-объект.
4. Регистрация имени удаленного объекта (testServant)
   Как было сказано раньше регистрация имени производится для того чтобы клиент смог найти удаленный объект. Этой цели служит функция rebind(NameComponent[] nc, Object obj) интерфейса NamingContext.

       NameComponent nc = new NameComponent("test", "");
        //первый параметр
        //указывает имя объекта,
        //второй нам использовать не обязательно
       NameComponent path[] = {nc};
       ncRef.rebind(path, testRef);
   

5. Ожидание запросов от клиента.

   java.lang.Object sync = new java.lang.Object();
              synchronized (sync) {
                   sync.wait();
              }
   

   После того как сервер обработает запрос от клиента и выполнит метод count он снова перейдет в состояние ожидания.

Теперь сервер готов к работе

Листинг 1. testServer.java

import testApp.*;
import org.omg.CosNaming.*;
import org.omg.CosNaming.NamingContextPackage.*;
import org.omg.CORBA.*;
import java.lang.*;

class testServant extends _testImplBase
{
    public int count(String msg)
    {
return msg.length();
    }
}

public class testServer {

    public static void main(String args[])
    {
        try
        {
        ORB orb = ORB.init(args, null);

        testServant testRef = new testServant();
        orb.connect(testRef);

        org.omg.CORBA.Object objRef =
         orb.resolve_initial_references("NameService");
        NamingContext ncRef =
         NamingContextHelper.narrow(objRef);

        NameComponent nc =
            new NameComponent("test", "");
        NameComponent path[] = {nc};
        ncRef.rebind(path, testRef);

        java.lang.Object sync = new java.lang.Object();
        synchronized (sync) {
        sync.wait()
        }

        }
        catch (Exception e) {
        System.err.println("ERROR: " + e);
        e.printStackTrace(System.out);
        }
    }
}

Обратите внимание на то, что все операции выполняемые над CORBA-объектами заключены в try-catch блок.

Перейдем к написанию кода для клиента.

Основные шаги написания клиентского приложения

1. Создание и инициализация ORB
2. Получение контекста службы имен (NamingContext)
3. Нахождение удаленного объекта
4. Вызов метода count.

Как видно, первые два пункта совпадают с этапами создания серверного приложения, поэтому рассматривать их не будем.

Третий пункт реализуется тоже достаточно просто. Создается объект NameComponent. Вызывается метод resolve(NameComponent[] path), который отыскивает по имени удаленный объект (стандартный CORBA-объект). При помощи метода narrow(org.omg.CORBA.Object obj) класса testHelper (сгенерированного idltojava компилятором) получаем объектную ссылку на интерфейс test.

        NameComponent nc = new NameComponent("test", "");
        NameComponent path[] = {nc};
        org.omg.CORBA.Object obj= ncRef.resolve(path);
        test testRef = testHelper.narrow(obj);

Теперь можно вызывать метод count

        String msg = "try to count";
        int count = testRef.count(msg);

Листинг 2. testClient.java

import testApp.*;
import org.omg.CosNaming.*;
import org.omg.CORBA.*;
import java.lang.*;

public class testClient
{
    public static void main(String args[])
    {
        try
        {
          ORB orb = ORB.init(args, null);
          org.omg.CORBA.Object objRef =
           orb.resolve_initial_references("NameService");

          NamingContext ncRef =
               NamingContextHelper.narrow(objRef);
          NameComponent nc = new NameComponent("test", "");
          NameComponent path[] = {nc};
          test testRef =
               testHelper.narrow(ncRef.resolve(path));

          String msg = "try to count";
          int count = testRef.count(msg);
          System.out.println
              (“number of chars in message is:” + count);

        }
        catch (Exception e)
        {
          System.out.println("ERROR : " + e) ;
          e.printStackTrace(System.out);
        }
        }
}