open/Library/Task/Runner/Remote.php

<?php
/**
 * 远程调度器 Task_Runner_Remote
 * 
 * - 通过远程请求接口实现任务调度
 * 
 * @author dogstar <chanzonghuang@gmail.com> 20150516
 */

class Task_Runner_Remote extends Task_Runner {

	/**
	 * @var Task_Runner_Remote_Connector 远程接口连接器实例
	 */
    protected $contector;

    /**
     * @var int $timeoutMS 接口超时（单位：毫秒）
     */
    protected $timeoutMS;

    /**
     * @var int 默认最大接口超时
     */
    const MAX_TIMEOUT_MS = 3000;

    public function __construct(Task_MQ $mq, $step = 10, Task_Runner_Remote_Connector $contector = NULL) {
        $config = DI()->config->get('app.Task.runner.remote');

        if ($contector === NULL) {
            if (empty($config['host'])) {
                throw new PhalApi_Exception_InternalServerError(T('task miss api host for'));
            }
            $contector = new Task_Runner_Remote_Connector_Http($config);
        }

        $this->contector = $contector;
        $this->timeoutMS = isset($config['timeoutMS']) ? intval($config['timeoutMS']) : self::MAX_TIMEOUT_MS;

        parent::__construct($mq, $step);
    }

    protected function youGo($service, $params) {
        $rs = $this->contector->request($service, $params, $this->timeoutMS);

        if ($this->contector->getRet() == 404) {
            throw PhalApi_Exception_InternalServerError('task request api time out',
                array('url' => $this->contector->getUrl()));
        }

        $isOk = $this->contector->getRet() == 200 ? TRUE : FALSE;

        if (!$isOk) {
            DI()->logger->debug('task remote request not ok', 
                array('url' => $this->contector->getUrl(), 'ret' => $this->contector->getRet(), 'msg' => $this->contector->getMsg()));
        }

        return $isOk;
    }
}