用PHP解析一个活的SOAP数据流

我有一个企业应用程序提供了一个相当强大的API来收集数据.目前我正在查询每个用户,我想要每秒钟循环一次更新.然而,新的api文档现在提供了所有用户的所有更改的直播.我想知道如何使用PHP解析这个实时数据.这里有一些细节：

通过SOAP请求请求数据,我正在使用PHP来执行这些请求(返回的唯一ID的会话启动的示例)：

//Get a session ID for this user for the shoretel WEBAPI
$soap_url = 'http://11.11.11.11:8070/ShoreTelWebSDK?wsdl';
$client = new SOAPClient($soap_url,array( 'proxy_host' => '11.11.11.11','proxy_port' => 8070,'trace' => 1 ) );
$client = new SoapClient($soap_url);

$header = new SoapHeader('http://www.ShoreTel.com/ProServices/SDK/Web');
$client->__setSoapHeaders($header);
$registered_string = $client->RegisterClient(array(
                'clientName' => '11.11.11.211'
            )); 
$registered_string = get_object_vars($registered_string);   
$session =  $registered_string['RegisterClientResult'];

新方法允许我指定一个时间段.例如,如果我想获得所有事件1分钟,则呼叫将启动,等待一分钟,然后返回在该分钟内发生的所有事件.

我想做的是抓住每个事件发生,并将其插入数据库.这是我可以用PHP完成的东西,还是需要寻找另一种语言来实现这一点？

好的,目标是用“超时”和/或“间隔”来“流式传输SOAP响应”？

我建议覆盖SoapClient __doRequest()方法,并通过fsockopen()实现一个自定义连接,并使用stream_get_contents()流传输数据.
现在你会收到一个XML数据流,你想要的就是它的中间位置.
您必须提取XML信封或其部分内容,可能使用字符串函数或使用preg_match来获取内部内容.

以下代码提供了一个SoapClientTimeout类,其中超时通过stream_set_timeout()设置.这是用例,当服务器响应缓慢,并且您想要确定何时结束侦听.

我建议玩它,并调整套接字上的超时行为.
因为,你想要的是一段时间后停止收听(间隔获取).
所以,云试图将超时与阻塞结合起来,一段时间后停止从流中读取数据：

$timeout = 60; // seconds
stream_set_blocking($socket,true);
stream_set_timeout($socket,$timeout);

当你有一个流,1分钟后关闭,
您需要一个循环(具有固定的退出条件)来触发下一个请求.

class SoapClientTimeout extends SoapClient
{    
    public function __construct ($wsdl,$options = null)
    {
        if (!$options) $options = [];

        $this->_connectionTimeout = @$options['connection_timeout'] ?: ini_get ('default_socket_timeout');
        $this->_socketTimeout = @$options['socket_timeout'] ?: ini_get ('default_socket_timeout');
        unset ($options['socket_timeout']);

        parent::__construct($wsdl,$options);
    }

    /**
     * Override parent __doRequest and add "timeout" functionality.
     */
    public function __doRequest ($request,$location,$action,$version,$one_way = 0)
    {
        // fetch host,port,and scheme from url.
        $url_parts = parse_url($location);

        $host = $url_parts['host'];
        $port =  @$url_parts['port'] ?: ($url_parts['scheme'] == 'https' ? 443 : 80);
        $length = strlen ($request);

        // create HTTP SOAP request.
        $http_req = "POST $location HTTP/1.0\r\n";
        $http_req .= "Host: $host\r\n";
        $http_req .= "SoapAction: $action\r\n";
        $http_req .= "Content-Type: text/xml; charset=utf-8\r\n";
        $http_req .= "Content-Length: $length\r\n";
        $http_req .= "\r\n";
        $http_req .= $request;

        // switch to SSL,when requested
        if ($url_parts['scheme'] == 'https') $host = 'ssl://'.$host;

        // connect
        $socket = @fsockopen($host,$port,$errno,$errstr,$this->_connectionTimeout);

        if (!$socket) {
            throw new SoapFault('Client',"Failed to connect to SOAP server ($location): $errstr");
        }

        // send request with socket timeout
        stream_set_timeout($socket,$this->_socketTimeout);
        fwrite ($socket,$http_req);

        // start reading the response.
        $http_response = stream_get_contents($socket);

        // close the socket and throw an exception if we timed out.
        $info = stream_get_Meta_data($socket);
        fclose ($socket);
        if ($info['timed_out']) {
            throw new SoapFault ('Client',"HTTP timeout contacting $location");
        }

        // the stream contains XML data
        // lets extract the XML from the HTTP response and return it.
        $response = preg_replace (
            '/
                \A       # Start of string
                .*?      # Match any number of characters (as few as possible)
                ^        # Start of line
                \r       # Carriage Return
                $       # End of line
             /smx','',$http_response
        );
        return $response;
    }

}

原文地址：https://www.jb51.cc/php/139316.html

用PHP解析一个活的SOAP数据流

相关推荐