xyzshop/searcher.php

<?php
declare(strict_types=1);

define('APP_ID','search');
define('BASE_ROOT_PATH',str_replace('\\','/',dirname(__FILE__)));
define('BASE_PATH', BASE_ROOT_PATH . '/helper');

require_once(BASE_ROOT_PATH . '/global.php');
require_once(BASE_ROOT_PATH . '/fooder.php');
require_once(BASE_HELPER_PATH . '/event_looper.php');
require_once(BASE_HELPER_PATH . '/search/processor.php');
require_once(BASE_HELPER_PATH . '/search/util.php');
require_once(BASE_HELPER_PATH . '/category_helper.php');
require_once(BASE_HELPER_PATH . '/brand_helper.php');
require_once(BASE_HELPER_PATH . '/goods/commonid_helper.php');
require_once(BASE_HELPER_PATH . '/search/searcher.php');
require_once(BASE_HELPER_PATH . '/special_helper.php');
require_once(BASE_HELPER_PATH . '/search/area_library.php');
require_once(BASE_HELPER_PATH . '/brand_helper.php');
require_once(BASE_HELPER_PATH . '/algorithm.php');
require_once(BASE_HELPER_PATH . '/message/msgstates.php');
require_once(BASE_HELPER_PATH . '/message/msgutil.php');
require_once(BASE_HELPER_PATH . '/message/subscriber.php');

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

$gMessageStates = null;
function searchwork($sockfd)
{
    global $gMessageStates;
    $gMessageStates = new MsgStates();

    Base::run_util();

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

    search\area_library::instance();

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

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

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

Log::record("Search server is starting....",Log::DEBUG);
event\util::fork_listen($host,$port,'searchwork',1);