这是广泛使用的通信开源项目,对于大容量,高并发的通讯要求完全能够胜任,他广泛可用于网络游戏医学图像网关的高qos要求.更详细的内容可阅读相应的材料

				// server.cpp,v 1.10 2003/11/01 11:15:11 dhinton Exp
				
				// ============================================================================
				//
				// = LIBRARY
				//    TAO/tests/NestedUpCalls/MT_Client_Test
				//
				// = FILENAME
				//    server.cpp
				//
				// = DESCRIPTION
				//    This class implements a simple server for the
				//    Nested Upcalls - MT_Client test.
				//
				// = AUTHORS
				//    Michael Kircher
				//
				// ============================================================================
				
				#include "server.h"
				#include "tao/debug.h"
				#include "ace/OS_NS_stdio.h"
				
				ACE_RCSID(MT_Client_Test, server, "server.cpp,v 1.10 2003/11/01 11:15:11 dhinton Exp")
				
				MT_Object_Server::MT_Object_Server (void)
				  : ior_output_file_ (0)
				{
				}
				
				int
				MT_Object_Server::parse_args (void)
				{
				  ACE_Get_Opt get_opts (argc_, argv_, "do:m");
				  int c;
				
				  while ((c = get_opts ()) != -1)
				    switch (c)
				      {
				      case 'd':  // debug flag.
				        TAO_debug_level++;
				        break;
				      case 'o': // output the IOR to a file.
				        this->ior_output_file_ = ACE_OS::fopen (get_opts.opt_arg (), "w");
				        if (this->ior_output_file_ == 0)
				          ACE_ERROR_RETURN ((LM_ERROR,
				                             "Unable to open %s for writing: %p\n",
				                             get_opts.opt_arg ()), -1);
				        break;
				      case '?':
				      default:
				        ACE_ERROR_RETURN ((LM_ERROR,
				                           "usage:  %s"
				                           " [-d]"
				                           " [-o] "
				                           "\n",
				                           argv_ [0]),
				                          1);
				      }
				
				  // Indicates successful parsing of command line.
				  return 0;
				}
				
				int
				MT_Object_Server::init (int argc,
				                       char** argv
				                       ACE_ENV_ARG_DECL)
				{
				  // Call the init of TAO_ORB_Manager to create a child POA
				  // under the root POA.
				  this->orb_manager_.init_child_poa (argc,
				                                     argv,
				                                     "child_poa"
				                                     ACE_ENV_ARG_PARAMETER);
				  ACE_CHECK_RETURN (-1);
				
				  this->argc_ = argc;
				  this->argv_ = argv;
				
				  this->parse_args ();
				  // ~~ check for the return value here
				
				  CORBA::String_var str;
				  str = this->orb_manager_.activate_under_child_poa ("MT_Object",
				                                                     &this->mT_Object_i_
				                                                     ACE_ENV_ARG_PARAMETER);
				  ACE_CHECK_RETURN (-1);
				
				#if 0
				  ACE_DEBUG ((LM_DEBUG,
				              "The IOR is: \n",
				              str.in ()));
				#endif /*if 0*/
				
				  if (this->ior_output_file_)
				    {
				      ACE_OS::fprintf (this->ior_output_file_,
				                       "%s",
				                       str.in ());
				      ACE_OS::fclose (this->ior_output_file_);
				    }
				
				
				  return 0;
				}
				
				
				int
				MT_Object_Server::run (ACE_ENV_SINGLE_ARG_DECL)
				{
				  if (this->orb_manager_.run (ACE_ENV_SINGLE_ARG_PARAMETER) == -1)
				    ACE_ERROR_RETURN ((LM_ERROR,
				                       "NestedUpCalls_Server::run"),
				                      -1);
				  return 0;
				}
				
				MT_Object_Server::~MT_Object_Server (void)
				{
				}
				
				int
				main (int argc, char *argv[])
				{
				  MT_Object_Server MT_Object_Server;
				
				  ACE_DEBUG ((LM_DEBUG,
				              "\n \t NestedUpCalls.Triangle_Test: Object A Server \n \n"));
				
				  ACE_DECLARE_NEW_CORBA_ENV;
				  ACE_TRY
				    {
				      int r = MT_Object_Server.init (argc,argv ACE_ENV_ARG_PARAMETER);
				      ACE_TRY_CHECK;
				
				      if (r == -1)
				        return 1;
				      else
				        {
				          MT_Object_Server.run (ACE_ENV_SINGLE_ARG_PARAMETER);
				          ACE_TRY_CHECK;
				        }
				    }
				  ACE_CATCH (CORBA::SystemException, sysex)
				    {
				      ACE_PRINT_EXCEPTION (sysex, "System Exception");
				      return -1;
				    }
				  ACE_CATCH (CORBA::UserException, userex)
				    {
				      ACE_PRINT_EXCEPTION (userex, "User Exception");
				      return -1;
				    }
				  ACE_ENDTRY;
				  return 0;
				}