UDP数据转发

void WtDtRunner::initialize(const char* cfgFile, const char* logCfg, const char* modDir /* = "" */)
{
	// 1. 初始化日志文件
	WTSLogger::init(logCfg);
	// 2. 设置工作目录 "Debug/WtDtPorter/"
	WtHelper::set_module_dir(modDir);

	// 3. 加载配置文件
	WTSVariant* config = WTSCfgLoader::load_from_file(cfgFile, true);
	if(config == NULL)
	{
		WTSLogger::error_f("Loading config file {} failed", cfgFile);
		return;
	}

	// 4. 加载基础环境配置文件
	WTSVariant* cfgBF = config->get("basefiles");
	// ...(省略代码)

	// 5. 初始化UDP广播组件
	_udp_caster.init(config->get("broadcaster"), &_bd_mgr, &_data_mgr);

	//By Wesley @ 2021.12.27
	//全天候模式，不需要再使用状态机
	bool bAlldayMode = config->getBoolean("allday");
	if (!bAlldayMode)
	{
		// 6. 初始化状态机
		_state_mon.initialize(config->getCString("statemonitor"), &_bd_mgr, &_data_mgr);
	}
	else
	{
		WTSLogger::info("QuoteFactory will run in allday mode");
	}
	// 7. 初始化数据落地组件
	initDataMgr(config->get("writer"), bAlldayMode);
	// 8. 初始化行情接口
	if (config->has("parsers"))
		initParsers(config->getCString("parsers"));
	else
		WTSLogger::log_raw(LL_WARN, "No parsers config, skipped loading parsers");

	config->release();
}

void WtDtRunner::start(bool bAsync /* = false */, bool bAlldayMode /* = false */)
{
	// 1. 启动行情接口
	_parsers.run();

    if(!bAsync)
    {
		_async_io.post([this]() {
			std::this_thread::sleep_for(std::chrono::milliseconds(5));
			// 2. 启动状态机
			_state_mon.run();
		});

        boost::asio::io_service::work work(_async_io);
        _async_io.run();
    }
	else
	{
		std::this_thread::sleep_for(std::chrono::milliseconds(5));
		_state_mon.run();
	}
}