4. 启动流程与进程模型

// 文件：kbe/src/server/baseapp/main.cpp（简化）
#include "baseapp.h"
// ... 大量 DEFINE_IN_INTERFACE 宏注册接口 ...

KBENGINE_MAIN(int argc, char* argv[])
{
    return kbeMainT<Baseapp>(argc, argv, COMPONENT_TYPE, ...);
}

// 文件：kbe/src/lib/server/kbemain.h（宏展开简化）
int main(int argc, char* argv[])
{
    loadConfig();
    g_componentID = genUUID64();
    parseMainCommandArgs(argc, argv);
    return kbeMain(argc, argv);
}

// 文件：programming/bigworld/server/baseapp/main.cpp
int BIGWORLD_MAIN(int argc, char * argv[])
{
    if (isServiceApp(argc, argv))
        return bwMainT<ServiceApp>(argc, argv);
    else
        return bwMainT<BaseApp>(argc, argv);
}

// 文件：programming/bigworld/lib/server/bwservice.hpp（宏展开简化）
int main(int argc, char * argv[])
{
    BWResource::init(argc, (const char**)argv);
    BWConfig::init(argc, argv);
    bwParseCommandLine(argc, argv);
    return bwMain(argc, argv);
}

// 文件：kbe/src/lib/server/kbemain.h（简化）
template<class SERVER_APP>
int kbeMainT(int argc, char* argv[], COMPONENT_TYPE componentType, ...)
{
    checkComponentID(componentType);     // 1. 确定 componentID
    setEvns();                           // 2. 环境变量
    DebugHelper::initialize();           // 3. 调试系统

    EventDispatcher dispatcher;          // 4. 事件分发器
    NetworkInterface ninterface(...);     // 5. 网络接口

    Components::getSingleton().initialize(...);  // 6. 组件管理器

    SERVER_APP app(dispatcher, ninterface, componentType, componentID); // 7. 构造组件
    Components::getSingleton().findLogger();  // 8. 查找日志组件
    START_MSG(SERVER_APP::getComponentName()); // 9. 打印启动信息

    app.initialize();                    // 10. 三阶段初始化
    app.run();                           // 11. 进入主循环
    app.finalise();                      // 12. 清理
    return 0;
}

// 文件：programming/bigworld/lib/server/bwservice.hpp（简化）
template<class SERVER_APP>
int bwMainT(int argc, char* argv[], bool shouldLog = true)
{
    EventDispatcher dispatcher;

    // 通过 bwmachined 查询内部接口 IP
    MachineDaemon::queryForInternalInterface(ServerApp::discoveredInternalIP);

    NetworkInterface interface(&dispatcher, NETWORK_INTERFACE_INTERNAL, ...);

    return doBWMainT<SERVER_APP>(dispatcher, interface, argc, argv);
}

template<class SERVER_APP>
int doBWMainT(EventDispatcher& dispatcher, NetworkInterface& interface, ...)
{
    ServerAppConfig::init(SERVER_APP::Config::postInit);
    SERVER_APP serverApp(dispatcher, interface);
    return serverApp.runApp(argc, argv) ? EXIT_SUCCESS : EXIT_FAILURE;
}

// 文件：kbe/src/lib/server/serverapp.h:44
class ServerApp :
    public SignalHandler,
    public TimerHandler,
    public ShutdownHandler,
    public Network::ChannelTimeOutHandler,
    public Network::ChannelDeregisterHandler,
    public Components::ComponentsNotificationHandler
{
    // ...
};

// 文件：kbe/src/lib/server/serverapp.cpp（简化）
bool ServerApp::initialize()
{
    installSignals();       // 信号处理
    initThreadPool();       // 线程池
    loadConfig();           // 配置加载
    initializeBegin();      // ← 阶段1：派生类覆写
    inInitialize();         // ← 阶段2：派生类覆写
    bool ret = initializeEnd();  // ← 阶段3：派生类覆写
    installSignals();       // 再次确保
    return ret && Network::initialize() && initializeWatcher();
}

// 文件：programming/bigworld/lib/server/server_app.hpp
class ServerApp
{
    bool runApp(int argc, char* argv[]);
protected:
    virtual bool init(int argc, char* argv[]);
    virtual void fini() {}
    virtual bool run();
    // ...
};

// 文件：programming/bigworld/lib/server/server_app.cpp（简化）
bool ServerApp::runApp(int argc, char* argv[])
{
    if (this->init(argc, argv))        // 虚函数，派生类覆写
    {
        result = this->run();          // → processUntilBreak()
    }
    this->fini();
    return result;
}

bool ServerApp::run()
{
    mainDispatcher_.processUntilBreak();
    return true;
}

// 文件：kbe/src/lib/server/entity_app.h（简化）
template<class E>
class EntityApp : public ServerApp
{
    bool initialize() override
    {
        if (!ServerApp::initialize())
            return false;
        // 添加游戏主定时器（1秒/updateHertz 频率）
        gameTimer_ = dispatcher().addTimer(
            1000000 / updateHertz_, this, NULL);
        return true;
    }

    bool inInitialize() override
    {
        installPyScript();     // Python 解释器
        installPyModules();    // KBEngine 模块注册
        installEntityDef();    // 加载 .def 实体定义
        return true;
    }

    void handleGameTick()     // 每帧调用
    {
        ++g_kbetime;
        threadPool_.onMainThreadTick();
        handleTimers();
        networkInterface().processChannels(...);
    }
};

// 文件：programming/bigworld/lib/server/entity_app.cpp
EntityApp::EntityApp(EventDispatcher& mainDispatcher, NetworkInterface& interface) :
    ScriptApp(mainDispatcher, interface),
    timeQueue_(EntityAppConfig::updateHertz(), *this)
{
    ScriptTimers::init(timeQueue_);
}

// 文件：programming/bigworld/server/baseapp/baseapp.cpp（简化）
bool BaseApp::init(int argc, char* argv[])
{
    EntityApp::init(argc, argv);
    // ...
    findOtherProcesses();       // 查找 BaseAppMgr, CellAppMgr
    serveInterfaces();          // 注册接口
    bgTaskManager_.startThreads();  // 启动后台线程
    initScript();               // Python 初始化
    AddToBaseAppMgrHelper(...); // 异步注册到 BaseAppMgr
}

// 文件：programming/bigworld/server/cellapp/cellapp.cpp（简化）
bool CellApp::init(int argc, char* argv[])
{
    EntityApp::init(argc, argv);
    Entity::s_init();
    cellAppMgr_.init();         // 查找 CellAppMgr
    EntityType::init();         // 加载实体类型
    Terrain::Manager::instance(); // 地形管理
    AddToCellAppMgrHelper(...);  // 异步注册到 CellAppMgr
    preloadSpaces();            // 预加载空间
}

// 文件：programming/bigworld/server/dbapp/dbapp.cpp（简化）
bool DBApp::init(int argc, char* argv[])
{
    return this->initNetwork() &&
           this->initBaseAppMgr() &&
           this->initScript(argc, argv) &&
           this->initEntityDefs() &&
           this->initExtensions() &&
           this->initDatabaseCreation() &&
           this->initDBAppMgrAsync();  // 异步注册
    // 后续还有 20+ 个异步初始化步骤...
}

// 文件：kbe/src/server/baseapp/initprogress_handler.cpp（简化）
// Baseapp 的 InitProgressHandler::process() 流程：
// 1. 检查错误状态
// 2. 等待 baseappmgr channel 可用
// 3. 等待 idClient 有可用 ID
// 4. 连接其他 EntityApp (sendRegisterNewApps)
// 5. 第一个 baseapp: 创建 EntityAutoLoader 从 DB 自动加载实体
// 6. 调用入口脚本的 onBaseAppReady(isFirstBaseapp)
// 7. 调用入口脚本的 onReadyForLogin(isFirstBaseapp)
// 8. 进度 >= 100% 时向 baseappmgr 报告完成

// KBEngine: kbe/src/lib/network/event_dispatcher.cpp
void EventDispatcher::processUntilBreak()
{
    breakProcessing_ = EVENT_DISPATCHER_STATUS_RUNNING;
    while (breakProcessing_ != EVENT_DISPATCHER_STATUS_BREAK_PROCESSING)
    {
        this->processOnce(true);
    }
}

int EventDispatcher::processOnce(bool shouldIdle)
{
    this->processTasks();       // 任务队列
    this->processTimers();      // 定时器（含 gameTick）
    this->processStats();       // 统计
    return this->processNetwork(shouldIdle);  // epoll/select 网络 I/O
}

// BigWorld: programming/bigworld/lib/network/event_dispatcher.cpp
int EventDispatcher::processOnce(bool shouldIdle)
{
    this->processFrequentTasks();  // 高频任务
    this->processTimers();         // 定时器
    this->processStats();          // 统计
    return this->processNetwork(shouldIdle);  // 网络 I/O
}