自学教程：C++ ACE_Acceptor类代码示例

void RARunnable::run(){    if (!sConfig->GetBoolDefault("Ra.Enable", false))        return;    ACE_Acceptor<RASocket, ACE_SOCK_ACCEPTOR> acceptor;    uint16 raport = sConfig->GetIntDefault("Ra.Port", 3443);    std::string stringip = sConfig->GetStringDefault("Ra.IP", "0.0.0.0");    ACE_INET_Addr listen_addr(raport, stringip.c_str());    if (acceptor.open(listen_addr, m_Reactor) == -1)    {        sLog->outError("Trinity RA can not bind to port %d on %s", raport, stringip.c_str());        return;    }    sLog->outString("Starting Trinity RA on port %d on %s", raport, stringip.c_str());    while (!World::IsStopped())    {        // don't be too smart to move this outside the loop        // the run_reactor_event_loop will modify interval        ACE_Time_Value interval(0, 100000);        if (m_Reactor->run_reactor_event_loop(interval) == -1)            break;    }    sLog->outStaticDebug("Trinity RA thread exiting");}

void RARunnable::run(){    if (!sConfigMgr->GetBoolDefault("Ra.Enable", false))        return;    ACE_Acceptor<RASocket, ACE_SOCK_ACCEPTOR> acceptor;    uint16 raPort = uint16(sConfigMgr->GetIntDefault("Ra.Port", 3443));    std::string stringIp = sConfigMgr->GetStringDefault("Ra.IP", "0.0.0.0");    ACE_INET_Addr listenAddress(raPort, stringIp.c_str());    if (acceptor.open(listenAddress, m_Reactor) == -1)    {        TC_LOG_ERROR(LOG_FILTER_WORLDSERVER, "ORIGIN RA can not bind to port %d on %s", raPort, stringIp.c_str());        return;    }    TC_LOG_INFO(LOG_FILTER_WORLDSERVER, "Starting ORIGIN RA on port %d on %s", raPort, stringIp.c_str());    while (!World::IsStopped())    {        ACE_Time_Value interval(0, 100000);        if (m_Reactor->run_reactor_event_loop(interval) == -1)            break;    }    TC_LOG_DEBUG(LOG_FILTER_WORLDSERVER, "ORIGIN RA thread exiting");}

void RARunnable::run(){    if (!sConfigMgr->GetBoolDefault("Ra.Enable", false))        return;    ACE_Acceptor<RASocket, ACE_SOCK_ACCEPTOR> acceptor;    uint16 raPort = uint16(sConfigMgr->GetIntDefault("Ra.Port", 3443));    std::string stringIp = sConfigMgr->GetStringDefault("Ra.IP", "0.0.0.0");    ACE_INET_Addr listenAddress(raPort, stringIp.c_str());    if (acceptor.open(listenAddress, m_Reactor) == -1)    {        sLog->outError("Trinity RA can not bind to port %d on %s", raPort, stringIp.c_str());        return;    }    sLog->outString("Starting Trinity RA on port %d on %s", raPort, stringIp.c_str());    while (!World::IsStopped())    {        ACE_Time_Value interval(0, 100000);        if (m_Reactor->run_reactor_event_loop(interval) == -1)            break;    }    ;//sLog->outStaticDebug("Trinity RA thread exiting");}

void SocketConnectorRunnable::run(){    if (!ConfigMgr::GetBoolDefault("SocketConnector.Enable", false))        return;        ACE_Acceptor<SocketConnector, ACE_SOCK_ACCEPTOR> acceptor;    uint16 SocketConnectorPort = ConfigMgr::GetIntDefault("SocketConnector.Port", 3448);    std::string stringip = ConfigMgr::GetStringDefault("SocketConnector.IP", "0.0.0.0");    ACE_INET_Addr listen_addr(SocketConnectorPort, stringip.c_str());    if (acceptor.open(listen_addr, m_Reactor) == -1)    {        sLog->outError(LOG_FILTER_WORLDSERVER, "Trinity Socket Connector can not bind to port %d on %s", SocketConnectorPort, stringip.c_str());        return;    }    sLog->outInfo(LOG_FILTER_WORLDSERVER, "Starting Trinity Socket Connector on port %d on %s", SocketConnectorPort, stringip.c_str());    while (!World::IsStopped())    {        // don't be too smart to move this outside the loop        // the run_reactor_event_loop will modify interval        ACE_Time_Value interval(0, 100000);        if (m_Reactor->run_reactor_event_loop(interval) == -1)            break;    }    sLog->outDebug(LOG_FILTER_WORLDSERVER, "Trinity Socket Connector thread exiting");}

int main(int argc, char* argv[]){	ACE_Reactor reactor;	ACE_Acceptor<EchoServerHandler, ACE_SOCK_Acceptor> echoServerAcceptor;	if (echoServerAcceptor.open(ACE_INET_Addr(DEFAULT_PORT), &reactor) == -1)		return 1;	reactor.run_reactor_event_loop();	return 0;}

//.........这里部分代码省略.........    // RealmServer PID file creation    std::string pidfile = sConfig.GetStringDefault("PidFile", "");    if (!pidfile.empty())    {        uint32 pid = CreatePIDFile(pidfile);        if (!pid)        {            sLog.outError( "Cannot create PID file %s./n", pidfile.c_str() );            return 1;        }        sLog.outString( "Daemon PID: %u/n", pid );    }    // Initialize the database connection    if (!StartDB())        return 1;    // Get the list of realms for the server    sRealmList->Initialize(sConfig.GetIntDefault("RealmsStateUpdateDelay", 20));    if (sRealmList->size() == 0)    {        sLog.outError("No valid realms specified.");        sleep(5);        return 1;    }    // cleanup query    // delete expired bans    LoginDatabase.Execute("DELETE FROM account_banned WHERE unbandate<=UNIX_TIMESTAMP() AND unbandate<>bandate");    LoginDatabase.Execute("DELETE FROM ip_banned WHERE unbandate<=UNIX_TIMESTAMP() AND unbandate<>bandate");    // Launch the listening network socket    ACE_Acceptor<AuthSocket, ACE_SOCK_Acceptor> acceptor;    uint16 rmport = sConfig.GetIntDefault("AuthServerPort", DEFAULT_AUTHSERVER_PORT);    std::string bind_ip = sConfig.GetStringDefault("BindIP", "0.0.0.0");    ACE_INET_Addr bind_addr(rmport, bind_ip.c_str());    if (acceptor.open(bind_addr, ACE_Reactor::instance(), ACE_NONBLOCK) == -1)    {        sLog.outError("Realm-Server can not bind to %s:%d", bind_ip.c_str(), rmport);        return 1;    }    // Catch termination signals    HookSignals();    sLog.outString("Realm-Server started");    // Handle affinity for multiple processors and process priority on Windows    #ifdef _WIN32    {        HANDLE hProcess = GetCurrentProcess();        uint32 Aff = sConfig.GetIntDefault("UseProcessors", 0);        if (Aff > 0)        {            ULONG_PTR appAff;            ULONG_PTR sysAff;            if (GetProcessAffinityMask(hProcess,&appAff,&sysAff))            {                ULONG_PTR curAff = Aff & appAff;            // remove non accessible processors

intrun_main (int argc, ACE_TCHAR *argv[]){  ACE_START_TEST (ACE_TEXT ("XtMotifReactor_Test"));  XtAppContext app_context;  Widget topLevel, goodbye, PressMe, lbl, digits_rc;  Widget children[5];#if defined (HummingBird_X)  HCLXmInit ();#endif /* HummingBird_X */  topLevel = XtVaAppInitialize (&app_context,                                "XTReactor_Test",                                0,                                0,                                &argc,                                argv,                                0,                                static_cast<void *>(0));  digits_rc = create_box(topLevel, "digits_rc");  //"Stop Test" button.  goodbye = XtCreateWidget ( (char *) "goodbye",                             BUTTON_WIDGET,                             digits_rc,                             0,                             0);  set_label(goodbye, "Stop Test");  //"Press Me" button  PressMe = XtCreateWidget ((char *) "PressMe",                            BUTTON_WIDGET,                            digits_rc,                            0,                            0);  //Display for event counter  lbl = XtCreateWidget ((char *) "label_for_event_one",                        LABEL_WIDGET,                        digits_rc,                        0,                        0);  set_label(lbl, "label_for_all_events");  int ac = 0;  children[ac++] = goodbye;  children[ac++] = PressMe;  children[ac++] = lbl;  XtManageChildren (children, ac);  XtManageChild (digits_rc);  //Register callback for "Stop Test" button  XtAddCallback (goodbye, PRESS_ME_CALLBACK, Quit, 0);  //Register callback for "Press Me" button  XtAddCallback (PressMe,                 PRESS_ME_CALLBACK,                 inc_count,                 (XtPointer) lbl);  // Register callback for X Timer  (void) XtAppAddTimeOut (app_context,                          1000,                          inc_tmo,                          (XtPointer) lbl);  XtRealizeWidget (topLevel);  // It will perform X Main Loop  ACE_XtReactor reactor (app_context);  ACE_Reactor r (&reactor);  //Event Handler for ACE Timer.  EV_handler evh;  ACE_Acceptor <Connection_Handler, ACE_SOCK_ACCEPTOR> acceptor;  if (acceptor.open (ACE_INET_Addr ((u_short) SERV_TCP_PORT),                     &r) == -1)    ACE_ERROR_RETURN ((LM_ERROR,                       "%p/n",                       "open"),                      -1);  if (reactor.schedule_timer (&evh,                              (const void *) lbl,                              ACE_Time_Value (2),                              ACE_Time_Value (2))==-1)    ACE_ERROR_RETURN ((LM_ERROR,                       " (%P|%t) can't register with reactor/n"),                      -1);  ACE_Thread_Manager::instance ()->spawn ((ACE_THR_FUNC) client,                                          0,                                          THR_NEW_LWP | THR_DETACHED);  XtAppMainLoop (XtWidgetToApplicationContext (topLevel));//.........这里部分代码省略.........

//.........这里部分代码省略.........        {            sLog.outError("Can not create PID file %s./n", pidfile.c_str());            Log::WaitBeforeContinueIfNeed();            return 1;        }        sLog.outString("Daemon PID: %u/n", pid);    }    ///- Initialize the database connection    if (!StartDB())    {        Log::WaitBeforeContinueIfNeed();        return 1;    }    ///- Get the list of realms for the server    sRealmList.Initialize(sConfig.GetIntDefault("RealmsStateUpdateDelay", 20));    if (sRealmList.size() == 0)    {        sLog.outError("No valid realms specified.");        Log::WaitBeforeContinueIfNeed();        return 1;    }    // cleanup query    // set expired bans to inactive    LoginDatabase.BeginTransaction();    LoginDatabase.Execute("UPDATE account_banned SET active = 0 WHERE unbandate<=UNIX_TIMESTAMP() AND unbandate<>bandate");    LoginDatabase.Execute("DELETE FROM ip_banned WHERE unbandate<=UNIX_TIMESTAMP() AND unbandate<>bandate");    LoginDatabase.CommitTransaction();    ///- Launch the listening network socket    ACE_Acceptor<AuthSocket, ACE_SOCK_Acceptor> acceptor;    uint16 rmport = sConfig.GetIntDefault("RealmServerPort", DEFAULT_REALMSERVER_PORT);    std::string bind_ip = sConfig.GetStringDefault("BindIP", "0.0.0.0");    ACE_INET_Addr bind_addr(rmport, bind_ip.c_str());    if (acceptor.open(bind_addr, ACE_Reactor::instance(), ACE_NONBLOCK) == -1)    {        sLog.outError("MaNGOS realmd can not bind to %s:%d", bind_ip.c_str(), rmport);        Log::WaitBeforeContinueIfNeed();        return 1;    }    ///- Catch termination signals    HookSignals();    ///- Handle affinity for multiple processors and process priority on Windows#ifdef WIN32    {        HANDLE hProcess = GetCurrentProcess();        uint32 Aff = sConfig.GetIntDefault("UseProcessors", 0);        if (Aff > 0)        {            ULONG_PTR appAff;            ULONG_PTR sysAff;            if (GetProcessAffinityMask(hProcess, &appAff, &sysAff))            {                ULONG_PTR curAff = Aff & appAff;            // remove non accessible processors                if (!curAff)

intrun_main (int, ACE_TCHAR *[]){  ACE_START_TEST (ACE_TEXT ("TkReactor_Test"));  tcl_interp   = Tcl_CreateInterp ();  if (init (tcl_interp) != TCL_OK) {    ACE_OS::exit (1);  }  Tk_Window tk = 0;  tk = Tk_MainWindow(tcl_interp);  if (tk == 0)    {      ACE_ERROR_RETURN ((LM_ERROR, "Tk_Reactor_Test: %s/n", tcl_interp->result),1);    }  char tcl_cmd[] = "source TkReactor_Test.tcl";  if (Tcl_Eval (tcl_interp, tcl_cmd) != TCL_OK) {    ACE_OS::exit (1);  }  // set up callback  char label_var_name[] = "label_var";  char pressme[] = "pressme";  Tcl_CreateCommand (tcl_interp,                     pressme,                     inc_count,                     label_var_name,                     0);  // Register callback for X Timer  (void) Tk_CreateTimerHandler (1000,                                inc_tmo,                                label_var_name);  // It will perform Tk Main Loop  ACE_TkReactor reactor;  ACE_Reactor r (&reactor);  //Event Handler for ACE Timer.  EV_handler evh;  ACE_Acceptor <Connection_Handler, ACE_SOCK_ACCEPTOR> acceptor;  if (acceptor.open (ACE_INET_Addr ((u_short) SERV_TCP_PORT),                     &r) == -1)    ACE_ERROR_RETURN ((LM_ERROR,                       "%p/n",                       "open"),                      -1);  if (reactor.schedule_timer (&evh,                              (const void *) "label_var",                              ACE_Time_Value (2),                              ACE_Time_Value (2))==-1)    ACE_ERROR_RETURN ((LM_ERROR,                       " (%P|%t) can't register with reactor/n"),                      -1);  ACE_Thread_Manager::instance ()->spawn ((ACE_THR_FUNC) client,                                          0,                                          THR_NEW_LWP | THR_DETACHED);  while (!quit)    {      int result = reactor.handle_events ();      switch (result)        {        case 0:          //          ACE_DEBUG ((LM_DEBUG,"handle_events timed out/n"));          break;        case -1:          ACE_DEBUG ((LM_DEBUG,"handle_events returned -1/n"));          quit = 1;          break;        }    }  ACE_END_TEST;  return 0;}

//.........这里部分代码省略.........        {            sLog.outError( "Cannot create PID file %s./n", pidfile.c_str() );            Log::WaitBeforeContinueIfNeed();            return 1;        }        sLog.outString( "Daemon PID: %u/n", pid );    }    ///- Initialize the database connection    if(!StartDB())    {        Log::WaitBeforeContinueIfNeed();        return 1;    }    ///- Get the list of realms for the server    sRealmList.Initialize(sConfig.GetIntDefault("RealmsStateUpdateDelay", 20));    if (sRealmList.size() == 0)    {        sLog.outError("No valid realms specified.");        Log::WaitBeforeContinueIfNeed();        return 1;    }    // cleanup query    // set expired bans to inactive    LoginDatabase.BeginTransaction();    LoginDatabase.Execute("UPDATE account_banned SET active = 0 WHERE unbandate<=UNIX_TIMESTAMP() AND unbandate<>bandate");    LoginDatabase.Execute("DELETE FROM ip_banned WHERE unbandate<=UNIX_TIMESTAMP() AND unbandate<>bandate");    LoginDatabase.CommitTransaction();    ///- Launch the listening network socket    ACE_Acceptor<AuthSocket, ACE_SOCK_Acceptor> acceptor;    uint16 rmport = sConfig.GetIntDefault("RealmServerPort", DEFAULT_REALMSERVER_PORT);    std::string bind_ip = sConfig.GetStringDefault("BindIP", "0.0.0.0");    ACE_INET_Addr bind_addr(rmport, bind_ip.c_str());    if(acceptor.open(bind_addr, ACE_Reactor::instance(), ACE_NONBLOCK) == -1)    {        sLog.outError("MaNGOS realmd can not bind to %s:%d", bind_ip.c_str(), rmport);        Log::WaitBeforeContinueIfNeed();        return 1;    }    // FG: "bad points" system related    uint32 badPointsDropInterval = sConfig.GetIntDefault("BadPoints.DropInterval", HOUR);    uint32 badPointsDropAmount = sConfig.GetIntDefault("BadPoints.DropAmount", 1);    uint32 badPointsDropWaitTime = sConfig.GetIntDefault("BadPoints.WaitTime", WEEK);     IntervalTimer badPointsTimer;    badPointsTimer.SetInterval(badPointsDropInterval * IN_MILLISECONDS);    ///- Catch termination signals    HookSignals();    ///- Handle affinity for multiple processors and process priority on Windows    #ifdef WIN32    {        HANDLE hProcess = GetCurrentProcess();        uint32 Aff = sConfig.GetIntDefault("UseProcessors", 0);        if(Aff > 0)        {            ULONG_PTR appAff;

// Launch the warden serverextern int main(int argc, char **argv){    // Command line parsing to get the configuration file name    char const* cfg_file = _wardenserver_CONFIG;    int c = 1;    while(c < argc)    {        if (strcmp(argv[c], "-c") == 0)        {            if (++c >= argc)            {                sLog->outError("Runtime-Error: -c option requires an input argument");                usage(argv[0]);                return 1;            }            else                cfg_file = argv[c];        }        ++c;    }    if (!sConfig->SetSource(cfg_file))    {        sLog->outError("Invalid or missing configuration file : %s", cfg_file);        sLog->outError("Verify that the file exists and has /'[wardenserver]/' written in the top of the file!");        return 1;    }    sLog->Initialize();    sLog->outString("%s (warden-daemon)", _FULLVERSION);    sLog->outString("<Ctrl-C> to stop./n");    sLog->outString("Using configuration file %s.", cfg_file);	sLog->outDetail("Using ACE: %s", ACE_VERSION);    ACE_Reactor::instance(new ACE_Reactor(new ACE_TP_Reactor(), true), true);    sLog->outBasic("Max allowed open files is %d", ACE::max_handles());    // wardenserver PID file creation    std::string pidfile = sConfig->GetStringDefault("PidFile", "");    if (!pidfile.empty())    {        uint32 pid = CreatePIDFile(pidfile);        if (!pid)        {            sLog->outError("Cannot create PID file %s./n", pidfile.c_str());            return 1;        }        sLog->outString("Daemon PID: %u/n", pid);    }    // Launch the listening network socket    ACE_Acceptor<WardenSocket, ACE_SOCK_Acceptor> acceptor;    uint16 rmport = sConfig->GetIntDefault("WardenServerPort", 4321);    std::string bind_ip = sConfig->GetStringDefault("BindIP", "0.0.0.0");    ACE_INET_Addr bind_addr(rmport, bind_ip.c_str());    if (acceptor.open(bind_addr, ACE_Reactor::instance(), ACE_NONBLOCK) == -1)    {        sLog->outError("wardenserver can not bind to %s:%d", bind_ip.c_str(), rmport);        return 1;    }    // Handle affinity for multiple processors and process priority on Windows#ifdef _WIN32    {        HANDLE hProcess = GetCurrentProcess();        uint32 Aff = sConfig->GetIntDefault("UseProcessors", 0);        if (Aff > 0)        {            ULONG_PTR appAff;            ULONG_PTR sysAff;            if (GetProcessAffinityMask(hProcess, &appAff, &sysAff))            {                ULONG_PTR curAff = Aff & appAff;            // remove non accessible processors                if (!curAff)                    sLog->outError("Processors marked in UseProcessors bitmask (hex) %x not accessible for Warden. Accessible processors bitmask (hex): %x", Aff, appAff);                else if (SetProcessAffinityMask(hProcess, curAff))                    sLog->outString("Using processors (bitmask, hex): %x", curAff);                else                    sLog->outError("Can't set used processors (hex): %x", curAff);            }            sLog->outString();        }        bool Prio = sConfig->GetBoolDefault("ProcessPriority", false);        if (Prio)        {            if (SetPriorityClass(hProcess, HIGH_PRIORITY_CLASS))                sLog->outString("warden process priority class is set to HIGH");            else//.........这里部分代码省略.........