تعد مكتبة XML-RPC الموجودة على الإنترنت مفيدة جدًا لتطوير واجهات الاتصال الخارجية الصغيرة. احفظ هذا الرمز باسم xml-rpc.inc.php
<?php
/*
تعد مكتبة XML-RPC الموجودة على الإنترنت مفيدة جدًا لتطوير واجهات الاتصال الخارجية الصغيرة.
*/
الوظيفة & XML_serialize($data، $level = 0، $prior_key = NULL){
#يفترض وجود تجزئة، والمفاتيح هي أسماء المتغيرات
$xml_serialized_string = "";
بينما(قائمة(مفتاح$، قيمة $) = كل($بيانات)){
$مضمنة = خطأ؛
$numeric_array = false;
سمات $ = "";
#echo "مفتاحي الحالي هو '$key'، ويتم استدعاؤه باستخدام المفتاح السابق '$prior_key'<br>";
if(!strstr($key, " attr")){ #if لم تكن سمة
إذا (array_key_exists("$key attr"، $data)){
while(list($attr_name, $attr_value) = every($data["$key attr"])){
#echo "تم العثور على السمة $attribute_name بقيمة $attribute_value<br>";
$attr_value = &htmlspecialchars($attr_value, ENT_QUOTES);
$attributes .= " $attr_name="$attr_value"";
}
}
إذا (is_numeric(مفتاح $)){
#echo "مفتاحي الحالي ($key) رقمي. مفتاحي الأصلي هو '$prior_key'<br>";
$key = $prior_key;
}آخر{
# لا يمكن أن يكون لديك مفاتيح رقمية على مستويين متتاليين، لذا فلا بأس بذلك
#echo "يتم التحقق لمعرفة ما إذا كان هناك مفتاح رقمي في البيانات.";
إذا (is_array($value) وray_key_exists(0, $value)){
# echo "إنه كذلك! أتصل بنفسي كنتيجة لمصفوفة رقمية.<br>";
$numeric_array = صحيح؛
$xml_serialized_string .= XML_serialize($value, $level, $key);
}
#echo "<br>";
}
إذا(!$numeric_array){
$xml_serialized_string .= str_repeat("t", $level) "<$key$attributes>";
إذا (is_array($value)){
$xml_serialized_string .= "rn" .XML_serialize($value, $level+1);
}آخر{
$مضمنة = صحيح؛
$xml_serialized_string .= htmlspecialchars($value);
}
$xml_serialized_string .= (!$inline ? str_repeat("t", $level) : "") . "</$key>rn";
}
}آخر{
#echo "تخطي سجل السمة للمفتاح $key<bR>";
}
}
إذا($المستوى == 0){
$xml_serialized_string = "<?xml version="1.0" ?>rn" $xml_serialized_string;
إرجاع $xml_serialized_string؛
}آخر{
إرجاع $xml_serialized_string؛
}
}
فئة XML {
var $parser; #a مرجع إلى محلل XML
var $document; # بنية XML بأكملها التي تم إنشاؤها حتى الآن
var $current#مؤشر للعنصر الحالي - ما هذا؟
var $parent; #a مؤشر إلى الأصل الحالي - سيكون الأصل عبارة عن مصفوفة
var $parents; #مصفوفة من الأصل الأحدث في كل مستوى
فار $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, "data");
# Register_shutdown_function(array($this, 'destruct'));
}
تدمير الوظيفة () {
xml_parser_free($this->parser);
}
تحليل الوظيفة(بيانات $){
$this->document = array();
$this->parent = $this->document;
$this->parents = array();
$this->last_opened_tag = NULL;
xml_parse($this->parser, $data);
إرجاع $this->document;
}
وظيفة مفتوحة($محلل، $tag، $attributes){
#echo "فتح العلامة $tag<br>n";
$this->data = "";
$this->last_opened_tag = $tag; #tag عبارة عن سلسلة
إذا (array_key_exists($tag, $this->parent)){
#echo "يوجد بالفعل مثيل لـ '$tag' عند المستوى الحالي ($level)<br>n";
if(is_array($this->parent[$tag]) and array_key_exists(0, $this->parent[$tag])){ #if المفاتيح رقمية
# بحاجة للتأكد من أنها رقمية (حساب السمات)
$key = count_numeric_items($this->parent[$tag]);
#echo "توجد مثيلات $key: المفاتيح رقمية.<br>n";
}آخر{
#echo "هناك مثيل واحد فقط. تغيير كل شيء<br>n";
$temp = $this->parent[$tag];
unset($this->parent[$tag]);
$this->parent[$tag][0] = $temp;
إذا (array_key_exists("$tag attr"، $this->parent)){
#shift السمات أيضًا إذا كانت موجودة
$temp = $this->parent["$tag attr"];
unset($this->parent["$tag attr"]);
$this->parent[$tag]["0 attr"] = $temp;
}
مفتاح $ = 1؛
}
$this->parent = $this->parent[$tag];
}آخر{
مفتاح $ = علامة $؛
}
إذا(سمات $){
$this->parent["$key attr"] = $attributes;
}
$this->parent[$key] = array();
$this->parent = $this->parent[$key];
array_unshift($this->parents, $this->parent);
}
بيانات الوظيفة(محلل $، بيانات $){
#echo "البيانات هي '"، htmlspecialchars($data)، "'<br>n";
إذا($this->last_opened_tag != NULL){
$this->data .= $data;
}
}
إغلاق الوظيفة($محلل، علامة $){
#echo "علامة الإغلاق $tag<br>n";
إذا($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 = new XML();
$data = $xml_parser->parse($xml);
$xml_parser->destruct();
إرجاع بيانات $؛
}
الوظيفة & XMLRPC_parse(طلب $){
إذا (محدد('XMLRPC_DEBUG') وXMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_parse', "<p>تم استلام الطلب الأولي التالي:</p>" . XMLRPC_show($request, 'print_r', true));
}
$data = &XML_unserialize($request);
إذا (محدد('XMLRPC_DEBUG') وXMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_parse', "<p>إرجاع الطلب المحلل التالي:</p>" . XMLRPC_show($data, 'print_r', true));
}
إرجاع بيانات $؛
}
الوظيفة & XMLRPC_prepare($data, $type = NULL){
إذا (is_array($data)){
$num_elements = العد($data);
if((array_key_exists(0, $data) أو !$num_elements) و $type != 'struct'){ # إنها مصفوفة
if(!$num_elements){ # إذا كانت المصفوفة فارغة
$returnvalue = array('array' => array('data' => NULL));
}آخر{
$returnvalue['array']['data']['value'] = array();
$temp = $returnvalue['array']['data']['value'];
$count = count_numeric_items($data);
for($n=0; $n<$count; $n++){
نوع $ = NULL;
إذا (array_key_exists("نوع $n"، $data)){
$type = $data["$n type"];
}
$temp[$n] = XMLRPC_prepare($data[$n], $type);
}
}
}else{ # إنها بنية
if(!$num_elements){ #if كانت البنية فارغة
$returnvalue = array('struct' => NULL);
}آخر{
$returnvalue['struct']['member'] = array();
$temp = $returnvalue['struct']['member'];
بينما(قائمة(مفتاح$، قيمة $) = كل($بيانات)){
if(substr($key, -5) != 'type'){ #if لم يكن محددًا للنوع
نوع $ = NULL;
إذا (array_key_exists("$key type"، $data)){
$type = $data["$key type"];
}
$temp[] = array('name' => $key, 'value' => XMLRPC_prepare($value, $type));
}
}
}
}
}else{ #إنه عددي
إذا(!$نوع){
إذا (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){
إذا (is_array($current_node)){
إذا(isset($current_node['array'])){
إذا(!is_array($current_node['array']['data'])){
# إذا لم تكن هناك عناصر، قم بإرجاع مصفوفة فارغة
صفيف الإرجاع () ؛
}آخر{
#echo "التخلص من المصفوفة -> البيانات -> القيمة<br>n";
$temp = $current_node['array']['data']['value'];
إذا (is_array($temp) وray_key_exists(0, $temp)){
$count = العد($درجة الحرارة);
for($n=0;$n<$count;$n++){
$temp2[$n] = &XMLRPC_adjustValue($temp[$n]);
}
درجة الحرارة $ = درجة الحرارة $2؛
}آخر{
$temp2 = &XMLRPC_adjustValue($temp);
$temp = array($temp2);
# أقوم بالمهمة المؤقتة لأنه يتجنب النسخ،
# لأنني أستطيع وضع مرجع في المصفوفة
النموذج المرجعي لـ #PHP سخيف بعض الشيء، ولا يمكنني أن أقول فقط:
# $temp = array(&XMLRPC_adjustValue($temp));
}
}
}elseif(isset($current_node['struct'])){
إذا(!is_array($current_node['struct'])){
# إذا لم يكن هناك أعضاء، قم بإرجاع مصفوفة فارغة
صفيف الإرجاع () ؛
}آخر{
#echo "التخلص من البنية -> العضو<br>n";
$temp = $current_node['struct']['عضو'];
إذا (is_array($temp) وray_key_exists(0, $temp)){
$count = العد($درجة الحرارة);
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[name]<br>n";
$temp2[$temp['name']] = &XMLRPC_adjustValue($temp['value']);
}
درجة الحرارة $ = درجة الحرارة $2؛
}
}آخر{
$types = array('string', 'int', 'i4', 'double', 'dateTime.iso8601', 'base64', 'boolean');
$fell_through = true;
foreach(أنواع $ كنوع $){
إذا (array_key_exists($type، $current_node)){
#echo "التخلص من '$type'<br>n";
$temp = $current_node[$type];
#echo "adjustValue(): تم تعيين العقدة الحالية بنوع $type<br>n";
$fell_through = false;
استراحة؛
}
}
إذا($سقط_خلال){
$type = 'string';
#echo "سقط! النوع هو $type<br>n";
}
التبديل (نوع) {
الحالة 'int': الحالة 'i4': $temp = (int)$temp;
الحالة 'سلسلة': $temp = (string)$tempbreak;
الحالة 'double': $temp = (double)$tempbreak;
الحالة 'منطقية': $temp = (bool)$temp;
}
}
}آخر{
$temp = (string)$current_node;
}
إرجاع درجة الحرارة $؛
}
الدالة XMLRPC_getParams($request){
إذا(!is_array($request['methodCall']['params'])){
# إذا لم تكن هناك معلمات، قم بإرجاع مصفوفة فارغة
صفيف الإرجاع () ؛
}آخر{
#echo "التخلص من MethodCall -> Params -> Param<br>n";
$temp = $request['methodCall']['params']['param'];
إذا (is_array($temp) وray_key_exists(0, $temp)){
$count = العد($درجة الحرارة);
for($n = 0; $n < $count; $n++){
#echo "معلمة تسلسل $n<br>";
$temp2[$n] = &XMLRPC_adjustValue($temp[$n]['value']);
}
}آخر{
$temp2[0] = &XMLRPC_adjustValue($temp['value']);
}
درجة الحرارة $ = درجة الحرارة $2؛
إرجاع درجة الحرارة $؛
}
}
الدالة XMLRPC_getMethodName($methodCall){
# يُرجع اسم الطريقة
إرجاع $methodCall['methodCall']['methodName'];
}
الدالة XMLRPC_request($site, $location, $methodName, $params = NULL, $user_agent = NULL){
$site = تنفجر(':', $site);
إذا(isset($site[1]) وis_numeric($site[1])){
$port = $site[1];
}آخر{
منفذ $ = 80؛
}
$الموقع = $الموقع[0];
$data["methodCall"]["methodName"] = $methodName;
$param_count = العد($params);
إذا(!$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);
إذا (محدد('XMLRPC_DEBUG') وXMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>تم استلام قائمة المعلمات التالية للإرسال:</p>" . XMLRPC_show($params, 'print_r', true));
}
$conn = fsockopen ($site, $port); #open the Connection
if(!$conn){ #if لم يتم فتح الاتصال بنجاح
إذا (محدد('XMLRPC_DEBUG') وXMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>فشل الاتصال: تعذر الاتصال بالموقع $.</p>");
}
return array(false, array('faultCode'=>10532, 'faultString'=>"فشل الاتصال: تعذر الاتصال بموقع $."));
}آخر{
رؤوس $ =
"POST $location HTTP/1.0rn" .
"المضيف: $sitern" .
"الاتصال: إغلاقrn" .
($user_agent ? "User-Agent: $user_agentrn" : '') .
"نوع المحتوى: نص/xmlrn" .
"طول المحتوى: " . strlen($data) "rnrn";
fputs($conn, "$headers");
fputs($conn, $data);
إذا (محدد('XMLRPC_DEBUG') وXMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>أرسل الطلب التالي:</p>nn" . XMLRPC_show($headers . $data, 'print_r', true));
}
#socket_set_blocking ($conn، false)؛
استجابة $ = "";
بينما(!feof($conn)){
$response .= fgets($conn, 1024);
}
fClose($conn);
#إزالة الرؤوس من الاستجابة
$data = XML_unserialize(substr($response, strpos($response, "rnrn")+4));
إذا (محدد('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));
}
إذا(isset($data['methodResponse']['خطأ'])){
$return = array(false, XMLRPC_adjustValue($data['methodResponse']['fault']['value']));
إذا (محدد('XMLRPC_DEBUG') وXMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>الإرجاع:</p>nn" . XMLRPC_show($return, 'var_dump', true));
}
إرجاع $return؛
}آخر{
$return = array(true, XMLRPC_adjustValue($data['methodResponse']['params']['param']['value']));
إذا (محدد('XMLRPC_DEBUG') وXMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_request', "<p>الإرجاع:</p>nn" . XMLRPC_show($return, 'var_dump', true));
}
إرجاع $return؛
}
}
}
الدالة XMLRPC_response($return_value, $server = NULL){
$data["methodResponse"]["params"]["param"]["value"] = $return_value;
$return = XML_serialize($data);
إذا (محدد('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("نوع المحتوى: نص/xml");
header("التاريخ: " . date("r"));
إذا(خادم $){
header("الخادم: $server");
}
إذا (محدد('XMLRPC_DEBUG') وXMLRPC_DEBUG){
XMLRPC_debug('XMLRPC_response', "<p>أرسل الرد التالي:</p>nn" . XMLRPC_show($return, 'print_r', true));
}
صدى $return؛
}
الدالة 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("الاتصال: إغلاق");
header("Content-Length: " . strlen($return));
header("نوع المحتوى: نص/xml");
header("التاريخ: " . date("r"));
إذا(خادم $){
header("الخادم: $server");
}
إذا (محدد('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 ويحوله إلى ISO8601 المطلوب بواسطة XMLRPC
#مثال على وقت التاريخ ISO8601 هو "20010822T03:14:33"
تاريخ الإرجاع("YmdTH:i:s", $timestamp);
}
الدالة XMLRPC_convert_iso8601_to_timestamp($iso8601){
إرجاع strtotime($iso8601);
}
وظيفة count_numeric_items($صفيف){
العودة is_array($array) ? count(array_filter(array_keys($array), 'is_numeric')) : 0;
}
الدالة XMLRPC_debug($function_name, $debug_message){
$GLOBALS['XMLRPC_DEBUG_INFO']] = array($function_name, $debug_message);
}
الدالة XMLRPC_debug_print(){
إذا($GLOBALS['XMLRPC_DEBUG_INFO']){
echo "<table border="1" width="100%">n";
foreach($GLOBALS['XMLRPC_DEBUG_INFO'] كـ $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>";
}
}
الدالة XMLRPC_show($data, $func = "print_r", $return_str = false){
ob_start();
$func($data);
$output = ob_get_contents();
ob_end_clean();
إذا($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);
إذا (!isset($xmlrpc_methods[$methodName])){
XMLRPC_error('1',"الطريقة التي اتصلت بها غير موجودة");
}آخر {
$xmlrpc_methods[$methodName]($params);
}
وظيفة إدراجالسجلات($params){
إذا (فارغة فارغة($params)){
XMLRPC_error('2'،"خطأ في المعلمة");
}
XMLRPC_response(XMLRPC_prepare('http://www.emtit.com'));
}
?>
مثال على طريقة استدعاء عميل PHP للخادم
<?php
include_once 'xml-rpc.inc';
$params=array(2,3);
$result=XMLRPC_request("127.0.0.1"،/services/server.php"،insertRecords"،$params);// يتم وضع ملف الخادم في مجلد الخدمات
print_r(نتيجة $);
?>