xyzshop/mchsrv/mchsrv_run.php

<?php

define('APP_ID', 'mchsrv');
define('MOBILE_SERVER',true);
define('SUPPORT_PTHREAD',true);

define('BASE_ROOT_PATH', str_replace('/mchsrv', '', dirname(__FILE__)));
define('BASE_PATH', BASE_ROOT_PATH . '/mchsrv');

require_once(BASE_ROOT_PATH . '/global.php');
require_once(BASE_ROOT_PATH . '/fooder.php');
require_once(BASE_PATH . '/index.php');

Log::record(__FILE__,Log::DEBUG);

require_once(BASE_ROOT_PATH . '/helper/session.php');
require_once(BASE_ROOT_PATH . '/helper/img_helper.php');
require_once(BASE_ROOT_PATH . '/helper/message/msgstates.php');
require_once(BASE_ROOT_PATH . '/helper/message/msgutil.php');
require_once(BASE_ROOT_PATH . '/helper/message/subscriber.php');
require_once(BASE_ROOT_PATH . '/helper/index_tab.php');
require_once(BASE_ROOT_PATH . '/helper/bonus_helper.php');
require_once(BASE_ROOT_PATH . '/helper/session_helper.php');
require_once(BASE_ROOT_PATH . '/helper/sms_helper.php');
require_once(BASE_ROOT_PATH . '/helper/model_helper.php');
require_once(BASE_ROOT_PATH . '/helper/category_helper.php');
require_once(BASE_ROOT_PATH . '/helper/brand_helper.php');
require_once(BASE_ROOT_PATH . '/helper/search/tcp_client.php');
require_once(BASE_ROOT_PATH . '/helper/search/util.php');
require_once(BASE_ROOT_PATH . '/helper/search_param.php');
require_once(BASE_ROOT_PATH . '/helper/goods_helper.php');
require_once(BASE_ROOT_PATH . '/helper/session_helper.php');
require_once(BASE_ROOT_PATH . '/helper/login_helper.php');
require_once(BASE_ROOT_PATH . '/helper/third_author/wxauthor.php');
require_once(BASE_ROOT_PATH . '/helper/fcode/present_manager.php');
require_once(BASE_ROOT_PATH . '/helper/url_helper.php');
require_once(BASE_ROOT_PATH . '/helper/activity_helper.php');
require_once(BASE_HELPER_PATH . '/fcgisrv/MerchantServer.php');
require_once(BASE_HELPER_PATH . '/refill/util.php');


function all_channels() {
    return ['ch_index','activity','goods','refill'];
}

Base::mobile_init();
$trdid = Thread::getCurrentThreadId();
Log::record("thread id = {$trdid}",Log::INFO);

$gMessageStates = new MsgStates();
StatesHelper::init();
$listener = new message\subscriber($gMessageStates);
$listener->start();

//function sig_handler($signo)
//{
//    Log::record("queue quit at sig_handler.",Log::DEBUG);
//    switch($signo) {
//        case SIGINT:
//        case SIGHUP:
//        case SIGQUIT:
//        case SIGTERM:
//        default:
//            break;
//    }
//}
//
//pcntl_signal(SIGINT,  'sig_handler');
//pcntl_signal(SIGHUP,  'sig_handler');
//pcntl_signal(SIGQUIT, 'sig_handler');
//pcntl_signal(SIGTERM, 'sig_handler');

fcgisrv\MerchantServer::instance()->run_looper();