yunbaolive/web/PhalApi/Library/Task/Runner/Remote/Connector.php

<?php
/**
 * 远程接口连接器 Task_Runner_Remote_Connector
 * 
 * @author dogstar <chanzonghuang@gmail.com> 20150516
 */

abstract class Task_Runner_Remote_Connector {

    protected $host;

    protected $params = array();

    protected $moreParams = array();

    protected $url;
    protected $ret;
    protected $msg;
    protected $data = array();

    public function __construct($config) {
        $this->host = $config['host'];
        $this->moreParams = isset($config['params']) ? $config['params'] : array();
    }

    /**
     * 接口请求，超时时ret为404
     * @param string $service MQ中的接口服务名称，如：Default.Index
     * @param array $params 参数
     * @param int $timeoutMS 接口超时（单位：毫秒）
     * @return array
     */
    public function request($service, $params = array(), $timeoutMs = 3000) {
        $this->url = $this->host . '?service=' . $service;
        $params = array_merge($this->moreParams, $params);

        $apiRs = $this->doRequest($this->url, $params, $timeoutMs);

        if ($apiRs === FALSE) {
            $this->ret = 404;
            $this->msg = T('time out');

            DI()->logger->debug('task request api time out', array('url' => $this->url));

            return $this->getData();
        }

        $rs = json_decode($apiRs, true);

        if (empty($rs) || !isset($rs['ret'])) {
            $this->ret = 500;
            $this->msg = T('nothing return or illegal json: {rs}', array('rs' => $apiRs));
            return $this->getData();
        }

        $this->ret = $rs['ret'];
        $this->data = $rs['data'];
        $this->msg = $rs['msg'];

        return $this->getData();
    }

    public function getRet() {
        return $this->ret;
    }

    public function getData() {
        return $this->data;
    }

    public function getMsg() {
        return $this->msg;
    }

    public function getUrl() {
        return $this->url;
    }

    abstract protected function doRequest($url, $data, $timeoutMs);
}