<div class="codetitle"><a style="CURSOR: pointer" data="30576" class="copybut" id="copybut30576" onclick="doCopy('code30576')"> 代码如下:<div class="codebody" id="code30576"> <?php / 从网上找来的XML-RPC库,对于开发小型的外部通讯接口很有用 / function & XML_serialize($data,$level = 0,$prior_key = NULL){ #assumes a hash,keys are the variable names $xml_serialized_string = ""; while(list($key,$value) = each($data)){ $inline = false; $numeric_array = false; $attributes = ""; #echo "My current key is '$key',called with prior key '$prior_key' "; if(!strstr($key," attr")){ #if it's not an attribute if(array_key_exists("$key attr",$data)){ while(list($attr_name,$attr_value) = each($data["$key attr"])){ #echo "Found attribute $attribute_name with value $attribute_value "; $attr_value = &htmlspecialchars($attr_value,ENT_QUOTES); $attributes .= " $attr_name="$attr_value""; } } if(is_numeric($key)){ #echo "My current key ($key) is numeric. My parent key is '$prior_key' "; $key = $prior_key; }else{ #you can't have numeric keys at two levels in a row,so this is ok #echo "Checking to see if a numeric key exists in data."; if(is_array($value) and array_key_exists(0,$value)){ # echo " It does! Calling myself as a result of a numeric array. "; $numeric_array = true; $xml_serialized_string .= XML_serialize($value,$level,$key); } #echo " "; } if(!$numeric_array){ $xml_serialized_string .= str_repeat("t",$level) . "<$key$attributes>"; if(is_array($value)){ $xml_serialized_string .= "rn" . XML_serialize($value,$level+1); }else{ $inline = true; $xml_serialized_string .= htmlspecialchars($value); } $xml_serialized_string .= (!$inline ? str_repeat("t",$level) : "") . "</$key>rn"; } }else{ #echo "Skipping attribute record for key $key "; } } if($level == 0){ $xml_serialized_string = "<?xml version="1.0" ?>rn" . $xml_serialized_string; return $xml_serialized_string; }else{ return $xml_serialized_string; } } class XML { var $parser; #a reference to the XML parser var $document; #the entire XML structure built up so far var $current; #a pointer to the current item - what is this var $parent; #a pointer to the current parent - the parent will be an array var $parents; #an array of the most recent parent at each level var $last_opened_tag; function XML($data=null){ $this->parser = xml_parser_create(); xml_parser_set_option ($this->parser,XML_OPTION_CASE_FOLDING,0); xml_set_object($this->parser,$this); xml_set_element_handler($this->parser,"open","close"); xml_set_character_data_handler($this->parser,"data"); # register_shutdown_function(array($this,'destruct')); } function destruct(){ xml_parser_free($this->parser); } function parse($data){ $this->document = array(); $this->parent = $this->document; $this->parents = array(); $this->last_opened_tag = NULL; xml_parse($this->parser,$data); return $this->document; } function open($parser,$tag,$attributes){ #echo "Opening tag $tag n"; $this->data = ""; $this->last_opened_tag = $tag; #tag is a string if(array_key_exists($tag,$this->parent)){ #echo "There's already an instance of '$tag' at the current level ($level) n"; if(is_array($this->parent[$tag]) and array_key_exists(0,$this->parent[$tag])){ #if the keys are numeric #need to make sure they're numeric (account for attributes) $key = count_numeric_items($this->parent[$tag]); #echo "There are $key instances: the keys are numeric. n"; }else{ #echo "There is only one instance. Shifting everything around n"; $temp = $this->parent[$tag]; unset($this->parent[$tag]); $this->parent[$tag][0] = $temp; if(array_key_exists("$tag attr",$this->parent)){ #shift the attributes around too if they exist $temp = $this->parent["$tag attr"]; unset($this->parent["$tag attr"]); $this->parent[$tag]["0 attr"] = $temp; } $key = 1; } $this->parent = $this->parent[$tag]; }else{ $key = $tag; } if($attributes){ $this->parent["$key attr"] = $attributes; } $this->parent[$key] = array(); $this->parent = $this->parent[$key]; array_unshift($this->parents,$this->parent); } function data($parser,$data){ #echo "Data is '",htmlspecialchars($data),"' n"; if($this->last_opened_tag != NULL){ $this->data .= $data; } } function close($parser,$tag){ #echo "Close tag $tag n"; if($this->last_opened_tag == $tag){ $this->parent = $this->data; $this->last_opened_tag = NULL; } array_shift($this->parents); $this->parent = $this->parents[0]; } } function & XML_unserialize($xml){ $xml_parser = new XML(); $data = $xml_parser->parse($xml); $xml_parser->destruct(); return $data; } function & XMLRPC_parse($request){ if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_parse',"Received the following raw request: " . XMLRPC_show($request,'print_r',true)); } $data = &XML_unserialize($request); if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_parse',"Returning the following parsed request: " . XMLRPC_show($data,true)); } return $data; } function & XMLRPC_prepare($data,$type = NULL){ if(is_array($data)){ $num_elements = count($data); if((array_key_exists(0,$data) or !$num_elements) and $type != 'struct'){ #it's an array if(!$num_elements){ #if the array is emptyempty $returnvalue = array('array' => array('data' => NULL)); }else{ $returnvalue['array']['data']['value'] = array(); $temp = $returnvalue['array']['data']['value']; $count = count_numeric_items($data); for($n=0; $n<$count; $n++){ $type = NULL; if(array_key_exists("$n type",$data)){ $type = $data["$n type"]; } $temp[$n] = XMLRPC_prepare($data[$n],$type); } } }else{ #it's a struct if(!$num_elements){ #if the struct is emptyempty $returnvalue = array('struct' => NULL); }else{ $returnvalue['struct']['member'] = array(); $temp = $returnvalue['struct']['member']; while(list($key,$value) = each($data)){ if(substr($key,-5) != ' type'){ #if it's not a type specifier $type = NULL; if(array_key_exists("$key type",$data)){ $type = $data["$key type"]; } $temp[] = array('name' => $key,'value' => XMLRPC_prepare($value,$type)); } } } } }else{ #it's a scalar if(!$type){ if(is_int($data)){ $returnvalue['int'] = $data; return $returnvalue; }elseif(is_float($data)){ $returnvalue['double'] = $data; return $returnvalue; }elseif(is_bool($data)){ $returnvalue['boolean'] = ($data ? 1 : 0); return $returnvalue; }elseif(preg_match('/^d{8}Td{2}:d{2}:d{2}$/',$data,$matches)){ #it's a date $returnvalue['dateTime.iso8601'] = $data; return $returnvalue; }elseif(is_string($data)){ $returnvalue['string'] = htmlspecialchars($data); return $returnvalue; } }else{ $returnvalue[$type] = htmlspecialchars($data); } } return $returnvalue; } function & XMLRPC_adjustValue($current_node){ if(is_array($current_node)){ if(isset($current_node['array'])){ if(!is_array($current_node['array']['data'])){ #If there are no elements,return an emptyempty array return array(); }else{ #echo "Getting rid of array -> data -> value n"; $temp = $current_node['array']['data']['value']; if(is_array($temp) and array_key_exists(0,$temp)){ $count = count($temp); for($n=0;$n<$count;$n++){ $temp2[$n] = &XMLRPC_adjustValue($temp[$n]); } $temp = $temp2; }else{ $temp2 = &XMLRPC_adjustValue($temp); $temp = array($temp2); #I do the temp assignment because it avoids copying, # since I can put a reference in the array #PHP's reference model is a bit silly,and I can't just say: # $temp = array(&XMLRPC_adjustValue($temp)); } } }elseif(isset($current_node['struct'])){ if(!is_array($current_node['struct'])){ #If there are no members,return an emptyempty array return array(); }else{ #echo "Getting rid of struct -> member n"; $temp = $current_node['struct']['member']; if(is_array($temp) and array_key_exists(0,$temp)){ $count = count($temp); for($n=0;$n<$count;$n++){ #echo "Passing name {$temp[$n][name]}. Value is: " . show($temp[$n][value],var_dump,true) . " n"; $temp2[$temp[$n]['name']] = &XMLRPC_adjustValue($temp[$n]['value']); #echo "adjustValue(): After assigning,the value is " . show($temp2[$temp[$n]['name']],true) . " n"; } }else{ #echo "Passing name $temp[name] n"; $temp2[$temp['name']] = &XMLRPC_adjustValue($temp['value']); } $temp = $temp2; } }else{ $types = array('string','int','i4','double','dateTime.iso8601','base64','boolean'); $fell_through = true; foreach($types as $type){ if(array_key_exists($type,$current_node)){ #echo "Getting rid of '$type' n"; $temp = $current_node[$type]; #echo "adjustValue(): The current node is set with a type of $type n"; $fell_through = false; break; } } if($fell_through){ $type = 'string'; #echo "Fell through! Type is $type n"; } switch ($type){ case 'int': case 'i4': $temp = (int)$temp; break; case 'string': $temp = (string)$temp; break; case 'double': $temp = (double)$temp; break; case 'boolean': $temp = (bool)$temp; break; } } }else{ $temp = (string)$current_node; } return $temp; } function XMLRPC_getParams($request){ if(!is_array($request['methodCall']['params'])){ #If there are no parameters,return an emptyempty array return array(); }else{ #echo "Getting rid of methodCall -> params -> param n"; $temp = $request['methodCall']['params']['param']; if(is_array($temp) and array_key_exists(0,$temp)){ $count = count($temp); for($n = 0; $n < $count; $n++){ #echo "Serializing parameter $n "; $temp2[$n] = &XMLRPC_adjustValue($temp[$n]['value']); } }else{ $temp2[0] = &XMLRPC_adjustValue($temp['value']); } $temp = $temp2; return $temp; } } function XMLRPC_getMethodName($methodCall){ #returns the method name return $methodCall['methodCall']['methodName']; } function XMLRPC_request($site,$location,$methodName,$params = NULL,$user_agent = NULL){ $site = explode(':',$site); if(isset($site[1]) and is_numeric($site[1])){ $port = $site[1]; }else{ $port = 80; } $site = $site[0]; $data["methodCall"]["methodName"] = $methodName; $param_count = count($params); if(!$param_count){ $data["methodCall"]["params"] = NULL; }else{ for($n = 0; $n<$param_count; $n++){ $data["methodCall"]["params"]["param"][$n]["value"] = $params[$n]; } } $data = XML_serialize($data); if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_request',"Received the following parameter list to send: " . XMLRPC_show($params,true)); } $conn = fsockopen ($site,$port); #open the connection if(!$conn){ #if the connection was not opened successfully if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_request',"Connection failed: Couldn't make the connection to $site. "); } return array(false,array('faultCode'=>10532,'faultString'=>"Connection failed: Couldn't make the connection to $site.")); }else{ $headers = "POST $location HTTP/1.0rn" . "Host: $sitern" . "Connection: closern" . ($user_agent ? "User-Agent: $user_agentrn" : '') . "Content-Type: text/xmlrn" . "Content-Length: " . strlen($data) . "rnrn"; fputs($conn,"$headers"); fputs($conn,$data); if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_request',"Sent the following request: nn" . XMLRPC_show($headers . $data,true)); } #socket_set_blocking ($conn,false); $response = ""; while(!feof($conn)){ $response .= fgets($conn,1024); } fclose($conn); #strip headers off of response $data = XML_unserialize(substr($response,strpos($response,"rnrn")+4)); if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_request',"Received the following response: nn" . XMLRPC_show($response,true) . "Which was serialized into the following data: nn" . XMLRPC_show($data,true)); } if(isset($data['methodResponse']['fault'])){ $return = array(false,XMLRPC_adjustValue($data['methodResponse']['fault']['value'])); if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_request',"Returning: nn" . XMLRPC_show($return,'var_dump',true)); } return $return; }else{ $return = array(true,XMLRPC_adjustValue($data['methodResponse']['params']['param']['value'])); if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_request',true)); } return $return; } } } function XMLRPC_response($return_value,$server = NULL){ $data["methodResponse"]["params"]["param"]["value"] = $return_value; $return = XML_serialize($data); if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_response',"Received the following data to return: nn" . XMLRPC_show($return_value,true)); } header("Connection: close"); header("Content-Length: " . strlen($return)); header("Content-Type: text/xml"); header("Date: " . date("r")); if($server){ header("Server: $server"); } if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_response',"Sent the following response: nn" . XMLRPC_show($return,true)); } echo $return; } function XMLRPC_error($faultCode,$faultString,$server = NULL){ $array["methodResponse"]["fault"]["value"]["struct"]["member"] = array(); $temp = $array["methodResponse"]["fault"]["value"]["struct"]["member"]; $temp[0]["name"] = "faultCode"; $temp[0]["value"]["int"] = $faultCode; $temp[1]["name"] = "faultString"; $temp[1]["value"]["string"] = $faultString; $return = XML_serialize($array); header("Connection: close"); header("Content-Length: " . strlen($return)); header("Content-Type: text/xml"); header("Date: " . date("r")); if($server){ header("Server: $server"); } if(defined('XMLRPC_DEBUG') and XMLRPC_DEBUG){ XMLRPC_debug('XMLRPC_error',"Sent the following error response: nn" . XMLRPC_show($return,true)); } echo $return; } function XMLRPC_convert_timestamp_to_iso8601($timestamp){ #takes a unix timestamp and converts it to iso8601 required by XMLRPC #an example iso8601 datetime is "20010822T03:14:33" return date("YmdTH:i:s",$timestamp); } function XMLRPC_convert_iso8601_to_timestamp($iso8601){ return strtotime($iso8601); } function count_numeric_items($array){ return is_array($array) ? count(array_filter(array_keys($array),'is_numeric')) : 0; } function XMLRPC_debug($function_name,$debug_message){ $GLOBALS['XMLRPC_DEBUG_INFO'][] = array($function_name,$debug_message); } function XMLRPC_debug_print(){ if($GLOBALS['XMLRPC_DEBUG_INFO']){ echo "<table border="1" width="100%">n"; foreach($GLOBALS['XMLRPC_DEBUG_INFO'] as $debug){ echo "<tr><th style="vertical-align: top">$debug[0]<td>$debug[1]</td></tr>n"; } echo "</table>n"; unset($GLOBALS['XMLRPC_DEBUG_INFO']); }else{ echo "No debugging information available yet. "; } } function XMLRPC_show($data,$func = "print_r",$return_str = false){ ob_start(); $func($data); $output = ob_get_contents(); ob_end_clean(); if($return_str){ return "" . htmlspecialchars($output) . " n"; }else{ echo "",htmlspecialchars($output)," n"; } } ?>
服务端程序例子,server.php <div class="codetitle"><a style="CURSOR: pointer" data="22290" class="copybut" id="copybut22290" onclick="doCopy('code22290')"> 代码如下:<div class="codebody" id="code22290"> <? include 'xml-rpc.inc.php'; //定义可被远程调用的方法 $xmlrpc_methods=array(); $xmlrpc_methods['insertRecords']='insertRecords'; //获得用户传入的方法名和参数 $xmlrpc_request = XMLRPC_parse($HTTP_RAW_POST_DATA); $methodName = XMLRPC_getMethodName($xmlrpc_request); $params = XMLRPC_getParams($xmlrpc_request); if (!isset($xmlrpc_methods[$methodName])){ XMLRPC_error('1',"你所调用的方法不存在"); }else { $xmlrpc_methods$methodName; } function insertRecords($params){ if (emptyempty($params)){ XMLRPC_error('2',"参数出错"); } XMLRPC_response(XMLRPC_prepare('http://www.emtit.com')); } ?>
PHP客户端调用服务端方法例子 <div class="codetitle"><a style="CURSOR: pointer" data="264" class="copybut" id="copybut264" onclick="doCopy('code264')"> 代码如下:<div class="codebody" id="code264"> <?php include_once 'xml-rpc.inc'; $params=array(2,3); $result=XMLRPC_request("127.0.0.1","/services/server.php","insertRecords",$params);//服务端文件放在services文件夹下 print_r($result); ?>
结果会显示www.emtiit.com (编辑:李大同)
【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!
|