インターネット上にある XML-RPC ライブラリは、小規模な外部通信インターフェイスの開発に非常に役立ちます。このコードを xml-rpc.inc.php
<?php
として保存します。
/*
インターネット上にある XML-RPC ライブラリは、小規模な外部通信インターフェイスを開発するのに非常に役立ちます。
*/
関数 & XML_serialize($data, $level = 0, $prior_key = NULL){
#ハッシュを想定しており、キーは変数名です
$xml_serialized_string = "";
while(list($key, $value) = each($data)){
$inline = false;
$numeric_array = false;
$attributes = "";
#echo "私の現在のキーは '$key' で、前のキー '$prior_key' で呼び出されます<br>";
if(!strstr($key, " attr")){ #属性ではない場合
if(array_key_exists("$key attr", $data)){
while(list($attr_name, $attr_value) = each($data["$key attr"])){
#echo "値 $attribute_value を持つ属性 $attribute_name が見つかりました<br>";
$attr_value = &htmlspecialchars($attr_value, ENT_QUOTES);
$attributes .= " $attr_name="$attr_value"";
}
}
if(is_numeric($key)){
#echo "現在のキー ($key) は数値です。親キーは '$prior_key'<br>";
$key = $prior_key;
}それ以外{
#数字キーを 2 つのレベルに連続して使用することはできないので、これは問題ありません
#echo "データ内に数値キーが存在するかどうかを確認しています。";
if(is_array($value) および array_key_exists(0, $value)){
# echo "そうなります!数値配列の結果として自分自身を呼び出します。<br>";
$numeric_array = true;
$xml_serialized_string .= XML_serialize($value, $level, $key);
}
#エコー "<br>";
}
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);
}それ以外{
$inline = true;
$xml_serialized_string .= htmlspecialchars($value);
}
$xml_serialized_string .= (!$inline ? str_repeat("t", $level) : "") "</$key>rn";
}
}それ以外{
#echo "キー $key<bR> の属性レコードをスキップします";
}
}
if($レベル == 0){
$xml_serialized_string = "<?xml version="1.0" ?>rn" 。
$xml_serialized_string を返します。
}それ以外{
$xml_serialized_string を返します。
}
}
クラスXML {
var $parser; #XML パーサーへの参照
var $document; #これまでに構築された XML 構造全体
var $current; #現在の項目へのポインタ - これは何ですか
var $parent; #現在の親へのポインタ - 親は配列になります
var $parents; #各レベルの最新の親の配列
var $last_opened_tag;
関数 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, "データ");
# register_shutdown_function(array($this, 'destruct'));
}
関数破壊(){
xml_parser_free($this->parser);
}
関数解析($data){
$this->document = array();
$this->parent = $this->ドキュメント;
$this->parents = array();
$this->last_opened_tag = NULL;
xml_parse($this->parser, $data);
$this->document を返します。
}
関数 open($parser, $tag, $attributes){
#echo "開始タグ $tag<br>n";
$this->data = "";
$this->last_opened_tag = $tag; #tag は文字列です
if(array_key_exists($tag, $this->parent)){
#echo "現在のレベル ($level) に '$tag' のインスタンスがすでに存在します<br>n";
if(is_array($this->parent[$tag]) および array_key_exists(0, $this->parent[$tag])){ #キーが数値の場合
#それらが数値であることを確認する必要があります(属性を考慮)
$key = count_numeric_items($this->parent[$tag]);
#echo "$key インスタンスがあります: キーは数値です。<br>n";
}それ以外{
#echo "インスタンスは 1 つだけです。すべてを移動します<br>n";
$temp = $this->parent[$tag];
unset($this->parent[$tag]);
$this->parent[$tag][0] = $temp;
if(array_key_exists("$tag attr", $this->parent)){
#属性が存在する場合は属性もシフトします
$temp = $this->parent["$tag attr"];
unset($this->parent["$tag attr"]);
$this->parent[$tag]["0 属性"] = $temp;
}
$キー = 1;
}
$this->parent = $this->parent[$tag];
}それ以外{
$key = $tag;
}
if($attributes){
$this->parent["$key attr"] = $attributes;
}
$this->parent[$key] = array();
$this->parent = $this->parent[$key];
array_unshift($this->parents, $this->parent);
}
関数データ($parser, $data){
#echo "データは '", htmlspecialchars($data), "'<br>n";
if($this->last_opened_tag != NULL){
$this->data .= $data;
}
}
関数 close($parser, $tag){
#echo "タグ $tag<br>を閉じる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];
}
}
関数 & XML_unserialize($xml){
$xml_parser = 新しい XML();
$data = $xml_parser->parse($xml);
$xml_parser->destruct();
$data を返します。
}
関数 & XMLRPC_parse($request){
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_parse', "<p>次の生のリクエストを受信しました:</p>" . XMLRPC_show($request, 'print_r', true));
}
$data = &XML_unserialize($request);
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_parse', "<p>次の解析されたリクエストを返します:</p>" . XMLRPC_show($data, 'print_r', true));
}
$data を返します。
}
関数 & XMLRPC_prepare($data, $type = NULL){
if(is_array($data)){
$num_elements = カウント($data);
if((array_key_exists(0, $data) または !$num_elements) and $type != 'struct'){ #配列です
if(!$num_elements){ #配列が空の場合空
$returnvalue = array('array' => array('data' => NULL));
}それ以外{
$returnvalue['array']['data']['value'] = array();
$temp = $returnvalue['配列']['データ']['値'];
$count = count_numeric_items($data);
for($n=0; $n<$count; $n++){
$type = NULL;
if(array_key_exists("$n 型", $data)){
$type = $data["$n タイプ"];
}
$temp[$n] = XMLRPC_prepare($data[$n], $type);
}
}
}else{ #これは構造体です
if(!$num_elements){ #構造体がemptyemptyの場合
$returnvalue = array('struct' => NULL);
}それ以外{
$returnvalue['struct']['member'] = array();
$temp = $returnvalue['構造']['メンバー'];
while(list($key, $value) = each($data)){
if(substr($key, -5) != ' type'){ #型指定子でない場合
$type = NULL;
if(array_key_exists("$キーの種類", $data)){
$type = $data["$key type"];
}
$temp[] = array('name' => $key, 'value' => XMLRPC_prepare($value, $type));
}
}
}
}
}else{ #これはスカラーです
if(!$type){
if(is_int($data)){
$returnvalue['int'] = $data;
$戻り値を返します;
}elseif(is_float($data)){
$returnvalue['double'] = $data;
$戻り値を返します;
}elseif(is_bool($data)){
$returnvalue['boolean'] = ($data ? 1 : 0);
$戻り値を返します;
}elseif(preg_match('/^d{8}Td{2}:d{2}:d{2}$/', $data, $matches)){ #日付です
$returnvalue['dateTime.iso8601'] = $data;
$戻り値を返します;
}elseif(is_string($data)){
$returnvalue['string'] = htmlspecialchars($data);
$戻り値を返します;
}
}それ以外{
$returnvalue[$type] = htmlspecialchars($data);
}
}
$戻り値を返します;
}
関数 & XMLRPC_adjustValue($current_node){
if(is_array($current_node)){
if(isset($current_node['array'])){
if(!is_array($current_node['array']['data'])){
#要素がない場合は空の空の配列を返す
戻り配列();
}それ以外{
#echo "配列 -> データ -> 値を削除します<br>n";
$temp = $current_node['配列']['データ']['値'];
if(is_array($temp) および array_key_exists(0, $temp)){
$count = カウント($temp);
for($n=0;$n<$count;$n++){
$temp2[$n] = &XMLRPC_adjustValue($temp[$n]);
}
$temp = $temp2;
}それ以外{
$temp2 = &XMLRPC_adjustValue($temp);
$temp = 配列($temp2);
#コピーを避けるため、一時割り当てを行います。
# 配列に参照を入れることができるので
#PHP の参照モデルは少しばかげているので、次のように言うことはできません。
# $temp = array(&XMLRPC_adjustValue($temp));
}
}
}elseif(isset($current_node['struct'])){
if(!is_array($current_node['struct'])){
#メンバーが存在しない場合は空の配列を返す
戻り配列();
}それ以外{
#echo "構造体 -> メンバーを削除しています<br>n";
$temp = $current_node['struct']['member'];
if(is_array($temp) および array_key_exists(0, $temp)){
$count = カウント($temp);
for($n=0;$n<$count;$n++){
#echo "名前 {$temp[$n][name]} を渡します。値は次のとおりです: " . show($temp[$n][value], var_dump, true) "<br>n";
$temp2[$temp[$n]['name']] = &XMLRPC_adjustValue($temp[$n]['value']);
#echo "adjustValue(): 割り当て後の値は " . show($temp2[$temp[$n]['name']], var_dump, true) "<br>n";
}
}それ以外{
#echo "名前 $temp[名前] を渡します<br>n";
$temp2[$temp['name']] = &XMLRPC_adjustValue($temp['value']);
}
$temp = $temp2;
}
}それ以外{
$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 "'$type' を削除しています<br>n";
$temp = $current_node[$type];
#echo "adjustValue(): 現在のノードは $type<br>n" のタイプで設定されています。
$fell_through = false;
壊す;
}
}
if($fell_through){
$type = '文字列';
#echo "失敗しました! タイプは $type<br>n";
}
スイッチ($type){
ケース 'int': ケース 'i4': $temp = (int)$temp;
case 'string': $temp = (string)$temp;
case 'double': $temp = (double)$temp;
case 'boolean': $temp = (bool)$temp;
}
}
}それ以外{
$temp = (文字列)$current_node;
}
$temp を返します。
}
関数 XMLRPC_getParams($request){
if(!is_array($request['methodCall']['params'])){
#パラメータがない場合は空の配列を返します
戻り配列();
}それ以外{
#echo "methodCall -> params -> param<br>を削除しますn";
$temp = $request['methodCall']['params']['param'];
if(is_array($temp) および array_key_exists(0, $temp)){
$count = カウント($temp);
for($n = 0; $n < $count; $n++){
#echo "パラメータ $n をシリアル化<br>";
$temp2[$n] = &XMLRPC_adjustValue($temp[$n]['value']);
}
}それ以外{
$temp2[0] = &XMLRPC_adjustValue($temp['value']);
}
$temp = $temp2;
$temp を返します。
}
}
関数 XMLRPC_getMethodName($methodCall){
#メソッド名を返します
$methodCall['methodCall']['methodName'] を返します。
}
function XMLRPC_request($site, $location, $methodName, $params = NULL, $user_agent = NULL){
$site =explode(':', $site);
if(isset($site[1]) および is_numeric($site[1])){
$ポート = $サイト[1];
}それ以外{
$ポート = 80;
}
$site = $site[0];
$data["メソッド呼び出し"]["メソッド名"] = $メソッド名;
$param_count = カウント($params);
if(!$param_count){
$data["methodCall"]["params"] = NULL;
}それ以外{
for($n = 0; $n<$param_count; $n++){
$data["methodCall"]["params"]["param"][$n]["value"] = $params[$n];
}
}
$data = XML_serialize($data);
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>送信する次のパラメータ リストを受信しました:</p>" . XMLRPC_show($params, 'print_r', true));
}
$conn = fsockopen ($site, $port); #接続を開きます
if(!$conn){ #接続が正常に開かれなかった場合
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>接続失敗: $site に接続できませんでした。</p>");
}
return array(false, array('faultCode'=>10532, 'faultString'=>"接続に失敗しました: $site に接続できませんでした。"));
}それ以外{
$ヘッダー =
"POST $location HTTP/1.0rn" 。
"ホスト: $sitern" 。
"接続: 閉じますrn" 。
($user_agent ? "ユーザー エージェント: $user_agentrn" : '') 。
"コンテンツ タイプ: text/xmlrn" 。
"コンテンツの長さ: " .strlen($data) . "rnrn";
fputs($conn, "$headers");
fputs($conn, $data);
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>次のリクエストを送信しました:</p>nn" . XMLRPC_show($headers . $data, 'print_r', true));
}
#socket_set_blocking ($conn, false);
$response = "";
while(!feof($conn)){
$response .= fgets($conn, 1024);
}
fclose($conn);
#応答からヘッダーを削除します
$data = XML_unserialize(substr($response, strpos($response, "rnrn")+4));
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>次の応答を受信しました:</p>nn" . XMLRPC_show($response, 'print_r', true) . "<p>次のデータにシリアル化されました:< /p>nn" . XMLRPC_show($data, 'print_r', true));
}
if(isset($data['methodResponse']['fault'])){
$return = array(false, XMLRPC_adjustValue($data['methodResponse']['fault']['value']));
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>Returning:</p>nn" . XMLRPC_show($return, 'var_dump', true));
}
$return を返します。
}それ以外{
$return = array(true, XMLRPC_adjustValue($data['methodResponse']['params']['param']['value']));
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>Returning:</p>nn" . XMLRPC_show($return, 'var_dump', true));
}
$return を返します。
}
}
}
function XMLRPC_response($return_value, $server = NULL){
$data["methodResponse"]["params"]["param"]["value"] = $return_value;
$return = XML_serialize($data);
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_response', "<p>返す次のデータを受信しました:</p>nn" . XMLRPC_show($return_value, 'print_r', true));
}
header("接続: 閉じる");
header("Content-Length: " .strlen($return));
header("Content-Type: text/xml");
header("日付: " . date("r"));
if($server){
header("サーバー: $server");
}
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_response', "<p>次の応答を送信しました:</p>nn" . XMLRPC_show($return, 'print_r', true));
}
エコー $return;
}
function XMLRPC_error($faultCode, $faultString, $server = NULL){
$array["methodResponse"]["fault"]["value"]["struct"]["member"] = array();
$temp = $array["methodResponse"]["fault"]["value"]["struct"]["member"];
$temp[0]["名前"] = "障害コード";
$temp[0]["value"]["int"] = $faultCode;
$temp[1]["名前"] = "障害文字列";
$temp[1]["値"]["文字列"] = $faultString;
$return = XML_serialize($array);
header("接続: 閉じる");
header("Content-Length: " .strlen($return));
header("Content-Type: text/xml");
header("日付: " . date("r"));
if($server){
header("サーバー: $server");
}
if(定義('XMLRPC_DEBUG') および XMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_error', "<p>次のエラー応答を送信しました:</p>nn" . XMLRPC_show($return, 'print_r', true));
}
エコー $return;
}
関数 XMLRPC_convert_timestamp_to_iso8601($timestamp){
#UNIX タイムスタンプを取得し、XMLRPC で必要な iso8601 に変換します
#iso8601 の日時の例は「20010822T03:14:33」です
return date("YmdTH:i:s", $timestamp);
}
関数 XMLRPC_convert_iso8601_to_timestamp($iso8601){
strtotime($iso8601)を返します;
}
関数 count_numeric_items($array){
戻り値 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);
}
関数 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]</th><td>$debug[1]</td></tr>n";
}
エコー "</table>n";
unset($GLOBALS['XMLRPC_DEBUG_INFO']);
}それ以外{
echo "<p>利用可能なデバッグ情報はまだありません。</p>";
}
}
function XMLRPC_show($data, $func = "print_r", $return_str = false){
ob_start();
$func($data);
$output = ob_get_contents();
ob_end_clean();
if($return_str){
"<pre>" を返します。 htmlspecialchars($output) "</pre>n";
}それ以外{
echo "<pre>"、htmlspecialchars($output)、"</pre>n";
}
}
?>
サーバープログラムの例、server.php
<?
「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',"呼び出したメソッドは存在しません");
}それ以外 {
$xmlrpc_methods[$methodName]($params);
}
関数 insertRecords($params){
if (emptyempty($params)){
XMLRPC_error('2',"パラメータエラー");
}
XMLRPC_response(XMLRPC_prepare('http://www.emtit.com'));
}
?>
PHP クライアントがサーバーメソッドを呼び出す例
<?php
include_once 'xml-rpc.inc';
$params=配列(2,3);
$result=XMLRPC_request("127.0.0.1","/services/server.php","insertRecords",$params);//サーバー ファイルはサービス フォルダーに配置されます
print_r($result);
?>