xyzshop/centra_srv.php

<?php

define('BASE_ROOT_PATH',str_replace('\\','/',dirname(__FILE__)));

require_once (BASE_ROOT_PATH . '/fooder.php');
require_once (BASE_ROOT_PATH . '/helper/event_looper.php');

require_once (BASE_ROOT_PATH . '/helper/search/processor.php');
require_once (BASE_ROOT_PATH . '/helper/search/util.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/goods/commonid_helper.php');
require_once (BASE_ROOT_PATH . '/helper/search/searcher.php');
require_once (BASE_ROOT_PATH . '/helper/special_helper.php');
require_once (BASE_ROOT_PATH . '/helper/search/area_library.php');
require_once (BASE_ROOT_PATH . '/helper/brand_helper.php');
require_once (BASE_ROOT_PATH . '/helper/algorithm.php');
require_once (BASE_ROOT_PATH . '/helper/message/msgutil.php');
require_once (BASE_ROOT_PATH . '/helper/message/subscriber.php');

function all_channels()
{
    return ['searcher'];
}

$gMessageStates = null;
$gMessageLock = null;

function searchwork($sockfd)
{
    global $gMessageStates;
    global $gMessageLock;

    $gMessageStates = new MsgStates();
    $gMessageLock = Mutex::create();

    Base::run_util();

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

    if(StatesHelper::fetch_state('init')) {
        Log::record("StatesHelper::fetch_state first.",Log::DEBUG);
        search\searcher::instance()->init();
        search\area_library::instance();
    }

    process_looper::instance()->init(new search\processor());
    process_looper::instance()->add_listen($sockfd);
    process_looper::instance()->run_loop();
}

global $config;
$host = $config['searcher']['host'];
$port = $config['searcher']['port'];

event\util::fork_listen($host,$port,'searchwork',1);