Ucenter1.6和DiscuzX2整合通信流程原理详细分析

$ucsynlogin = $this->setting['allowsynlogin'] ? uc_user_synlogin($_G['uid']) : ''; 

function uc_api_post($module, $action, $arg = array()) {
        $s = $sep = '';
        foreach($arg as $k => $v) {
                $k = urlencode($k);
                if(is_array($v)) {
                        $s2 = $sep2 = '';
                        foreach($v as $k2 => $v2) {
                                $k2 = urlencode($k2);
                                $s2 .= "$sep2{$k}[$k2]=".urlencode(uc_stripslashes($v2));
                                $sep2 = '&';
                        }
                        $s .= $sep.$s2;
                } else {
                        $s .= "$sep$k=".urlencode(uc_stripslashes($v));
                }
                $sep = '&';
        }
        $postdata = uc_api_requestdata($module, $action, $s);
        return uc_fopen2(UC_API.'/index.php', 500000, $postdata, '', TRUE, UC_IP, 20);
}

function uc_api_requestdata($module, $action, $arg='', $extra='') {
        $input = uc_api_input($arg);
        $post = "m=$module&a=$action&inajax=2&release=".UC_CLIENT_RELEASE."&input=$input&appid=".UC_APPID.$extra;
        return $post;
}

function uc_fopen($url, $limit = 0, $post = '', $COOKIE = '', $bysocket = FALSE, $ip = '', $timeout = 15, $block = TRUE) {
        $return = '';
        $matches = parse_url($url);
        !isset($matches['host']) && $matches['host'] = '';
        !isset($matches['path']) && $matches['path'] = '';
        !isset($matches['query']) && $matches['query'] = '';
        !isset($matches['port']) && $matches['port'] = '';
        $host = $matches['host'];
        $path = $matches['path'] ? $matches['path'].($matches['query'] ? '?'.$matches['query'] : '') : '/';
        $port = !empty($matches['port']) ? $matches['port'] : 80;
        if($post) {
                $out = "POST $path HTTP/1.0\r\n";
                $out .= "Accept: */*\r\n";
                //$out .= "Referer: $boardurl\r\n";
                $out .= "Accept-Language: zh-cn\r\n";
                $out .= "Content-Type: application/x-www-form-urlencoded\r\n";
                $out .= "User-Agent: $_SERVER[HTTP_USER_AGENT]\r\n";
                $out .= "Host: $host\r\n";
                $out .= 'Content-Length: '.strlen($post)."\r\n";
                $out .= "Connection: Close\r\n";
                $out .= "Cache-Control: no-cache\r\n";
                $out .= "COOKIE: $COOKIE\r\n\r\n";
                $out .= $post;
        } else {
                $out = "GET $path HTTP/1.0\r\n";
                $out .= "Accept: */*\r\n";
                //$out .= "Referer: $boardurl\r\n";
                $out .= "Accept-Language: zh-cn\r\n";
                $out .= "User-Agent: $_SERVER[HTTP_USER_AGENT]\r\n";
                $out .= "Host: $host\r\n";
                $out .= "Connection: Close\r\n";
                $out .= "COOKIE: $COOKIE\r\n\r\n";
        }

        if(function_exists('fsockopen')) {
                $fp = @fsockopen(($ip ? $ip : $host), $port, $errno, $errstr, $timeout);
        } elseif (function_exists('pfsockopen')) {
                $fp = @pfsockopen(($ip ? $ip : $host), $port, $errno, $errstr, $timeout);
        } else {
                $fp = false;
        }

        if(!$fp) {
                return '';
        } else {
                stream_set_blocking($fp, $block);
                stream_set_timeout($fp, $timeout);
                @fwrite($fp, $out);
                $status = stream_get_meta_data($fp);
                if(!$status['timed_out']) {
                        while (!feof($fp)) {
                                if(($header = @fgets($fp)) && ($header == "\r\n" ||  $header == "\n")) {
                                        break;
                                }
                        }

                        $stop = false;
                        while(!feof($fp) && !$stop) {
                                $data = fread($fp, ($limit == 0 || $limit > 8192 ? 8192 : $limit));
                                $return .= $data;
                                if($limit) {
                                        $limit -= strlen($data);
                                        $stop = $limit <= 0;
                                }
                        }
                }
                @fclose($fp);
                return $return;
        }
}

if(in_array($m, array('app', 'frame', 'user', 'pm', 'pm_client', 'tag', 'feed', 'friend', 'domain', 'credit', 'mail', 'version'))) {

        if(file_exists(UC_ROOT.RELEASE_ROOT."control/$m.php")) {
                include UC_ROOT.RELEASE_ROOT."control/$m.php";
        } else {
                include UC_ROOT."control/$m.php";
        }

        $classname = $m.'control';
        $cOntrol= new $classname();
        $method = 'on'.$a;
        if(method_exists($control, $method) && $a{0} != '_') {
                $data = $control->$method();
                echo is_array($data) ? $control->serialize($data, 1) : $data;
                exit;
        } elseif(method_exists($control, '_call')) {
                $data = $control->_call('on'.$a, '');
                echo is_array($data) ? $control->serialize($data, 1) : $data;
                exit;
        } else {
                exit('Action not found!');
        }

} else {

        exit('Module not found!');

}