Spec-Zone .ru
спецификации, руководства, описания, API
Содержание документации

IDL Java: Пример с Объектом Обратного вызова

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

Пример в этом документе иллюстрирует, как клиентская программа может передать объект обратного вызова к серверу, и сервер может тогда обратный вызов, чтобы уведомить изменения клиенту. В это время мы обеспечили код для расширения простого приложения. Примечания об упрощении приложения содержатся в пределах кода.

Этот документ обеспечивает код для:

Инструкции для компиляции и выполнения примера также обеспечиваются.

Пример обратного вызова: Промежуточный Уровень

Запись файла IDL

Для приложения в качестве примера файл callback.idl похож на это:

interface Listener {
        void message(in string msg);
};

interface MessageServer {
        void register(in Listener lt);
};

Запись Серверного кода

Для приложения в качестве примера файл Server.java похож следующим образом.

import org.omg.CORBA.ORB;
import org.omg.PortableServer.POA;
import org.omg.PortableServer.POAHelper;
import org.omg.CosNaming.NameComponent;
import org.omg.CosNaming.NamingContext;
import org.omg.CosNaming.NamingContextHelper;

public class Server {

    public static void main(String[] args) {
        try {
            //create and initialize the ORB
            Properties props = System.getProperties();
            props.put("org.omg.CORBA.ORBInitialPort", "1050");
            //Replace MyHost with the name of the host on which you are running the server
            props.put("org.omg.CORBA.ORBInitialHost", "<MyHost>");
            ORB orb = ORB.init(args, props);
            System.out.println("Initialized ORB");

            //Instantiate Servant and create reference
            POA rootPOA = POAHelper.narrow(
                orb.resolve_initial_references("RootPOA"));
            MessageServerImpl msImpl = new MessageServerImpl();
            rootPOA.activate_object(msImpl);
            MessageServer msRef = MessageServerHelper.narrow(
                rootPOA.servant_to_reference(msImpl));

            //Bind reference with NameService
            NamingContext namingContext = NamingContextHelper.narrow(
                orb.resolve_initial_references("NameService"));
            System.out.println("Resolved NameService");
            NameComponent[] nc = { new NameComponent("MessageServer", "") };
            namingContext.rebind(nc, msRef);

            //Activate rootpoa
            rootPOA.the_POAManager().activate();

            //Start readthread and wait for incoming requests
            System.out.println("Server ready and running ....");
            
            //REMOVE THE NEXT LINE FOR THE SIMPLER EXAMPLE
            msImpl.startReadThread();
            
            orb.run();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

Запись Реализации MessageServer

Файл регистрирует новые клиенты, принимает сообщения, тогда передает сообщения зарегистрированным клиентам. Для приложения в качестве примера файл MessageServerImpl.java похож на следующий пример.

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Vector;
import java.util.Iterator;

public class MessageServerImpl extends MessageServerPOA {

    private Vector clients = new Vector();
    private ReadThread rt = null;

    public MessageServerImpl() {
        rt = new ReadThread(this);
    }

    public void register(Listener lt) {
        clients.add(lt);
    }

    public void startReadThread() {
        rt.start();
    }

    public void message(String msg) {
        Iterator it = clients.iterator();
        while (it.hasNext()) {
            Listener lt = (Listener) it.next();
            lt.message(msg);
            //FOR THE SIMPLER EXAMPLE, ADD A SIMPLE
            //MESSAGE TO BE CALLED BACK, FOR EXAMPLE,
            //SLEEP FOR 30 SECONDS, THEN SEND THE TIME
        }
    }
}

//EXCLUDE THIS CLASS FOR THE SIMPLER EXAMPLE
class ReadThread extends Thread {

    MessageServerImpl msImpl = null;

    public ReadThread(MessageServerImpl msImpl) {
        this.msImpl = msImpl;
    }

    public void run() {
        BufferedReader br = new BufferedReader(
            new InputStreamReader(System.in));

        try {
            for (;;) {
                System.out.print("message > ");
                String msg = br.readLine();
                msImpl.message(msg);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

Запись Клиентского Кода

Для приложения в качестве примера файл файл Client.java похож на следующий пример.

import java.util.Properties;
import org.omg.CORBA.ORB;
import org.omg.PortableServer.POA;
import org.omg.PortableServer.POAHelper;
import org.omg.CosNaming.NameComponent;
import org.omg.CosNaming.NamingContext;
import org.omg.CosNaming.NamingContextHelper;

public class Client {

    public static void main(String[] args) {
        try {
        
            //initialize orb
            Properties props = System.getProperties();
            props.put("org.omg.CORBA.ORBInitialPort", "1050");
            //Replace MyHost with the name of the host on which you are running the server
            props.put("org.omg.CORBA.ORBInitialHost", "<MyHost>");
            ORB orb = ORB.init(args, props);
            System.out.println("Initialized ORB");

            //Instantiate Servant and create reference
            POA rootPOA = POAHelper.narrow(
                orb.resolve_initial_references("RootPOA"));
            ListenerImpl listener  = new ListenerImpl();
            rootPOA.activate_object(listener);
            Listener ref = ListenerHelper.narrow(
                rootPOA.servant_to_reference(listener));

            //Resolve MessageServer
            MessageServer msgServer = MessageServerHelper.narrow(
                orb.string_to_object("corbaname:iiop:1.2@localhost:1050#MessageServer"));

            //Register listener reference (callback object) with MessageServer
            msgServer.register(ref);
            System.out.println("Listener registered with MessageServer");

            //Activate rootpoa
            rootPOA.the_POAManager().activate();

            //Wait for messages
            System.out.println("Wait for incoming messages");
            orb.run();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

Запись Реализации Слушателя

Когда Слушатель идентифицирует это, сообщение было получено от сервера, оно выводит на экран сообщение на клиенте. Для приложения в качестве примера файл ListenerImpl.java похож на следующий пример.

public class ListenerImpl extends ListenerPOA {

    public void message(String msg) {
        System.out.println("Message from server : " + msg);
    }
}

Инструкции для компиляции и выполнения примера

Чтобы запустить приложение в качестве примера, Вы следовали бы этим инструкциям на машине СЕРВЕРА:
  1. Если Вы выполнили пример ранее, удалите любые существующие сгенерированные файлы. В операционной среде Unix эта команда была бы следующие:
    rm -rf ./classes ./orb.db
    
  2. Генерируйте тупики и скелеты. Во-первых, Вы должны создать каталог, где тупики и скелеты будут находиться, затем выполнять компилятор idlj, чтобы генерировать тупики и скелеты. Эта команда была бы похожа на это:
    mkdir -p ./classes
    <path_to_java>/bin/idlj -fall -td ./classes callback.idl
    
  3. Скомпилируйте файлы .java, следующим образом:
    <path_to_java>/bin/javac -classpath ./classes -d ./classes *.java
    
  4. Запустите службу именования orbd, следующим образом:
    <path_to_java>/bin/orbd -ORBInitialPort 1050 -ORBInitialHost <host_name> &
    
  5. Выполните сервер, следующим образом:
    <path_to_java>/bin/java -classpath ./classes Server -ORBInitialPort 1050
    

После того, как Вы запустили сервер, Вы будете видеть, выводит, такие как следующее в окне терминала:

Initialized ORB
Resolved NameService
Server ready and running ....
message > 

При этой подсказке Вы отправите сообщения клиенту, но сначала Вы должны запустить клиентское приложение. От КЛИЕНТСКОГО терминала следуйте за этими шагами, чтобы выполнить клиент. Удостоверьтесь, что Вы использовали имя хоста, на котором сервер работает в разделе свойств клиентского кода.

<path_to_java>/bin/java -classpath ./classes Client -ORBInitialPort 1050 

Вывод от клиента выведет на экран в формате, подобном этому:

Initialized ORB
Listener registered with MessageServer
Wait for incoming messages

Чтобы вывести на экран функциональность использования обратного вызова, Вы ввели бы данные в терминал сервера при подсказке, и это выведет на экран на всех клиентских терминалах. Это могло быть чем-либо, где клиенты интересуются некоторыми уведомлениями.

Одним примером является футбольный игровой счет, где клиенты уведомляются всякий раз, когда счет изменяется.

message > Niners TD. Niners 7 - Giants 0
message > Giants TD. Niners 7 - Giants 7
message > Niners TD. Niners 14 - Giants 7

Когда сообщения, такие как показанные выше отправляются, клиентский дисплей выглядит подобным следующему:

Wait for incoming messages
Message from server : Niners TD. Niners 7 - Giants 0
Message from server : Giants TD. Niners 7 - Giants 7
Message from server : Niners TD. Niners 14 - Giants 7

Oracle и/или его филиалы Авторское право © 1993, 2012, Oracle и/или его филиалы. Все права защищены.
Свяжитесь с Нами