CORBA omniorb C++ 多个仆人

Posted 2023-02-16

【中文标题】CORBA omniorb C++ 多个仆人

【英文标题】：CORBA omniorb C++ multiple servants

【发布时间】：2017-11-16 20:00:30

【问题描述】：

大家好，我是 CORBA C++ 的新手，我阅读了有关如何在 linux 上安装 CORBA 的教程，它的工作原理和代码编译良好，我想执行多个服务器实例，因为我想创建一个对等-同行。例如，当我创建一个服务器实例并且多个客户端实例工作正常时，但是当我尝试执行两个或多个服务器实例以便从客户端接收消息时，只有最后一个服务器实例接收消息，请任何人帮助我吗？

这是我的服务器和客户端代码

server.cpp

#include "MyExampleInterface_impl.h"
#include <iostream>
#include <CORBA.h>
#include <Naming.hh>

/** Server name, clients needs to know this name */
#define SERVER_NAME     "MyServerName"

using namespace std;

int main(int argc, char ** argv)

cerr << "CORBA SERVER RUNNING..." << endl;
try 

    //------------------------------------------------------------------------
    // Initialize CORBA ORB
    //------------------------------------------------------------------------
    CORBA::ORB_ptr orb = CORBA::ORB_init(argc, argv);

    //------------------------------------------------------------------------
    // Initialize POA: Get reference to root POA
    //
    // Servant must register with POA in order to be made available for client
    // Get reference to the RootPOA.
    //-----------------------------------------------------------------------
    CORBA::Object_var poa_obj = orb->resolve_initial_references("RootPOA");
    PortableServer::POA_var poa = PortableServer::POA::_narrow(poa_obj);
    PortableServer::POAManager_var manager = poa->the_POAManager();

    //------------------------------------------------------------------------
    // Create service
    //------------------------------------------------------------------------
    MyExampleInterface_impl * service = new MyExampleInterface_impl;
    cerr << "ya se creo el servicio procediendo a crear instancia" << endl;
    try 
        //------------------------------------------------------------------------
        // Bind object to name service as defined by directive InitRef
        // and identifier "NameService" in config file omniORB.cfg.
        //------------------------------------------------------------------------
        CORBA::Object_var ns_obj = orb->resolve_initial_references("NameService");
        if (!CORBA::is_nil(ns_obj)) 
            //------------------------------------------------------------------------
            // Narrow this to the naming context
            //------------------------------------------------------------------------
            CosNaming::NamingContext_ptr nc = CosNaming::NamingContext::_narrow(ns_obj);

            //------------------------------------------------------------------------
            // Bind to CORBA name service. Same name to be requested by client.
            //------------------------------------------------------------------------
            CosNaming::Name name;
            name.length(1);
            name[0].id = CORBA::string_dup(SERVER_NAME);
            name[0].kind = CORBA::string_dup("");
            nc->rebind(name, service->_this());

            //------------------------------------------------------------------------
            // Intizialization ready, server runs
            //------------------------------------------------------------------------              
            cout << argv[0] << " C++ (omniORB) server '" << SERVER_NAME << "' is running .." << endl;
        
     catch (CosNaming::NamingContext::NotFound &) 
        cerr << "Caught CORBA exception: not found" << endl;
     catch (CosNaming::NamingContext::InvalidName &) 
        cerr << "Caught CORBA exception: invalid name" << endl;
     catch (CosNaming::NamingContext::CannotProceed &) 
        cerr << "Caught CORBA exception: cannot proceed" << endl;
    

    //------------------------------------------------------------------------
    // Activate the POA manager
    //------------------------------------------------------------------------
    manager->activate();
    //------------------------------------------------------------------------
    // Accept requests from clients
    //------------------------------------------------------------------------
cerr << "aceptando peticiones de cliente con run()" << endl;
    orb->run();
cerr << "hecho ahora esperando..." << endl;
    //------------------------------------------------------------------------
    // Clean up
    //------------------------------------------------------------------------
    //delete service;

    //------------------------------------------------------------------------
    // Destroy ORB
    //------------------------------------------------------------------------
    orb->destroy();

 catch (CORBA::UNKNOWN) 
    cerr << "Caught CORBA exception: unknown exception" << endl;
 catch (CORBA::SystemException &) 
    cerr << "Caught CORBA exception: system exception" << endl;

client.cpp

#include "example.hh"
#include <iostream>
#include <CORBA.h>
#include <Naming.hh>

/** Name is defined in the server.cpp */
#define SERVER_NAME     "MyServerName"

using namespace std;

int main(int argc, char ** argv)

    try 
        //------------------------------------------------------------------------
        // Initialize ORB object.
        //------------------------------------------------------------------------
        CORBA::ORB_ptr orb = CORBA::ORB_init(argc, argv);

        //------------------------------------------------------------------------
        // Resolve service
        //------------------------------------------------------------------------
        ExampleInterface_ptr service_server = 0;

        try 

            //------------------------------------------------------------------------
            // Bind ORB object to name service object.
            // (Reference to Name service root context.)
            //------------------------------------------------------------------------
            CORBA::Object_var ns_obj = orb->resolve_initial_references("NameService");

            if (!CORBA::is_nil(ns_obj)) 
                //------------------------------------------------------------------------
                // Bind ORB object to name service object.
                // (Reference to Name service root context.)
                //------------------------------------------------------------------------
                CosNaming::NamingContext_ptr nc = CosNaming::NamingContext::_narrow(ns_obj);

                //------------------------------------------------------------------------
                // The "name text" put forth by CORBA server in name service.
                // This same name ("MyServerName") is used by the CORBA server when
                // binding to the name server (CosNaming::Name).
                //------------------------------------------------------------------------
                CosNaming::Name name;
                name.length(1);
                name[0].id = CORBA::string_dup(SERVER_NAME);
                name[0].kind = CORBA::string_dup("");

                //------------------------------------------------------------------------
                // Resolve "name text" identifier to an object reference.
                //------------------------------------------------------------------------
                CORBA::Object_ptr obj = nc->resolve(name);

                if (!CORBA::is_nil(obj)) 
                    service_server = ExampleInterface::_narrow(obj);
                
            
         catch (CosNaming::NamingContext::NotFound &) 
            cerr << "Caught corba not found" << endl;
         catch (CosNaming::NamingContext::InvalidName &) 
            cerr << "Caught corba invalid name" << endl;
         catch (CosNaming::NamingContext::CannotProceed &) 
            cerr << "Caught corba cannot proceed" << endl;
        

        //------------------------------------------------------------------------
        // Do stuff
        //------------------------------------------------------------------------
        if (!CORBA::is_nil(service_server)) 
            char * server = service_server->send_message("Message from C++ (omniORB) client");
            cout << "response from Server: " << server << endl;
            CORBA::string_free(server);
        

        //------------------------------------------------------------------------
        // Destroy OBR
        //------------------------------------------------------------------------
        orb->destroy();

     catch (CORBA::UNKNOWN) 
        cerr << "Caught CORBA exception: unknown exception" << endl;
    

【问题讨论】：

您使用 CORBA 有什么特别的原因吗？我花了几年的时间开发它以谋生，没有什么能说服我回到它。

是的，这是一个学校的期末项目，所以我别无选择:(老实说，我迷失在 CORBA 中

您需要发布您的作业条款。如您所说，您正在尝试的内容没有意义。

我要做一个P2P网络，所以客户端和服务器最终会混合成一个实体，并且这个实体必须能够与其他实体连接才能建立一个P2P网络，CORBA是让我困惑，我更喜欢使用“套接字”，但老师不允许这样做

这并不能解释为什么要将两台服务器绑定到同名的同一个命名服务。

【参考方案1】：

命名服务就像电话簿，您使用已知名称存储对象引用。目前，您的代码中有“MyServerName”，并且只能注册一台服务器。启动第二台服务器将更新命名服务以仅使用第二台服务器，所有新客户端将从那时起使用该服务器。

您可以在命名服务中为每个服务器注册一个唯一的名称，并让客户端决定使用哪个服务器。

【讨论】：

好的，我知道了，但是一个客户端可以同时连接多个服务器吗？因为这个项目我需要做一个P2P网络，所以客户端和服务器最终会混合成一个实体，这个实体必须能够与其他实体连接。

是的，一个客户端可以连接多个服务器，您需要在命名服务中为每个服务器注册一个唯一的ID，并且客户端必须从命名服务中检索多个。

我可以在不注册命名服务的情况下创建 CORBA 服务器吗？是强制注册 NamingService 吗？

不，不是强制的，其实我更不想用，是单点故障。当您知道服务器在哪里运行以及在服务器端使用 IORTable 在哪个端口上时，客户端可以在代码中构造对象引用并使用它。