技术开发 频道

PHP教程:WebService最常用的两种方法

  Ping Service,博客程序提供一种通知机制,以便在第一时间将博客的更新信息发布到提供Ping Service服务的网站,写聚合的时候研究了一下

  先看标准吧

  这是一个标准的Ping Service,用XMLRPC来传数据的,注释写的这么详细,代码说明就不需要了吧,PHP5开启XMLRPC方法

  client.php

  代码:

01.  
  
02.$host = 'zxsv';
  03.$port = 80;
  
04.$rpc_server = '/test/xmlrpc_server.php';
  05.$title = 'zxsv';
  06.$server = 'http://zxsv/test/';
  07.$rss = 'http://zxsv/test/rss.php';
  08.//WeblogUpdates.Ping方法
  
09.$Ping = xmlrpc_encode_request('weblogUpdates.Ping', array($title, $server ));
  10.//weblogUpdates.extendedPing方法
  
11.$extendedPing = xmlrpc_encode_request('weblogUpdates.extendedPing', array($title, $server, $rss ));
  12.//调用rpc_client_call函数把所有请求发送给XML-RPC服务器端后获取信息
  
13.$response = rpc_client_call($host, $port, $rpc_server, $Ping);
  
14.$split = '';
  15.$xml = explode($split, $response);
  
16.$xml = $split . array_pop($xml);
  
17.$response = xmlrpc_decode($xml);
  
18.//输出从RPC服务器端获取的信息
  
19.print_r($response);
  
20./**
  
21.* 函数:提供给客户端进行连接XML-RPC服务器端的函数
  
22.* 参数:
  
23.* $host 需要连接的主机
  
24.* $port 连接主机的端口
  
25.* $rpc_server XML-RPC服务器端文件
  
26.* $request 封装的XML请求信息
  
27.* 返回:连接成功成功返回由服务器端返回的XML信息,失败返回false
  
28.*/
  
29.function rpc_client_call($host, $port, $rpc_server, $request) {
  
30.
  $fp
= fsockopen($host, $port);
  
31.
  $query
= "POST $rpc_server HTTP/1.0\nUser_Agent: XML-RPC Client\nHost: ".$host."\nContent-Type: text/xml\nContent-Length: ".strlen($request)."\n\n".$request."\n";
  
32.
  
if (!fputs($fp, $query, strlen($query))) {
  
33.
  $errstr
= "Write error";
  
34.
  return
false;
  
35.
  }
  
36.
  $contents
= '';
  37.
  
while (!feof($fp)){
  
38.
  $contents .
= fgets($fp);
  
39.
  }
  
40.
  fclose($fp);
  
41.
  return $contents;
  
42.}
  
43.?>

  server.php

  代码:

01.  
  
02./**
  
03.* 函数:提供给RPC客户端调用的函数
  
04.* 参数:
  
05.* $method 客户端需要调用的函数
  
06.* $params 客户端需要调用的函数的参数数组
  
07.* 返回:返回指定调用结果
  
08.*/
  
09.function rpc_server_extendedping($method, $params) {
  
10.
  $title
= $params[0];
  
11.
  $server
= $params[1];
  
12.
  $rss
= $params[2];
  
13.
  
//中间的判断,成功返回$XML_RPC_String
  
14.
  $XML_RPC_String
= array('flerror'=>false,'message'=>'Thanks for the ping.');
  15.
  return $XML_RPC_String;
  
16.}
  
17.function rpc_server_ping($method, $params) {
  
18.
  $title
= $params[0];
  
19.
  $server
= $params[1];
  
20.
  
//中间的判断,成功返回$XML_RPC_String
  
21.
  $XML_RPC_String
= array('flerror'=>false,'message'=>'Thanks for the ping.');
  22.
  return $XML_RPC_String;
  
23.}
  
24.//产生一个XML-RPC的服务器端
  
25.$xmlrpc_server = xmlrpc_server_create();
  
26.//注册一个服务器端调用的方法rpc_server,实际指向的是rpc_server_extendedping函数
  
27.xmlrpc_server_reGISter_method($xmlrpc_server, "weblogUpdates.extendedPing", "rpc_server_extendedping");
  
28.xmlrpc_server_register_method($xmlrpc_server, "weblogUpdates.Ping", "rpc_server_ping");
  
29.//接受客户端POST过来的XML数据
  
30.$request = $HTTP_RAW_POST_DATA;
  
31.//print_r($request);
  
32.//执行调用客户端的XML请求后获取执行结果
  
33.$xmlrpc_response = xmlrpc_server_call_method($xmlrpc_server, $request, null);
  
34.//把函数处理后的结果XML进行输出
  
35.header('Content-Type: text/xml');
  36.echo $xmlrpc_response;
  
37.//销毁XML-RPC服务器端资源
  
38.xmlrpc_server_destroy($xmlrpc_server);
  
39.?>

  类写的,有BUG

  代码:

 01.  
  
02.class Pings {
  
03.
  
public $xmlrpc_server;
  
04.
  
public $xmlrpc_response;
  
05.
  
public $methodName;
  
06.
  
public function __construct() {
  
07.
  
//产生一个XML-RPC的服务器端
  
08.
  $this
->xmlrpc_server = xmlrpc_server_create ();
  
09.
  $this
->run ();
  
10.
  }
  
11.
  
12.
  
//注册一个服务器端调用的方法rpc_server,实际指向的是ping函数
  
13.
  
public function rpc_server() {
  
14.
  $this
->methodName = !$this->methodName ? 'weblogUpdates.extendedPing':'weblogUpdates.Ping';
  15.
  xmlrpc_server_register_method ( $this
->xmlrpc_server, $this->methodName, array (__CLASS__, "ping"));
  
16.
  }
  
17.
  
/**
  
18.
  
* 函数:提供给RPC客户端调用的函数
  
19.
  
* 参数:
  
20.
  
* $method 客户端需要调用的函数
  
21.
  
* $params 客户端需要调用的函数的参数数组
  
22.
  
* 返回:返回指定调用结果
  
23.
  
*/
  
24.
  
public function ping($method, $params) {
  
25.
  $this
->title = $params [0];
  
26.
  $this
->server = $params [1];
  
27.
  $this
->rss = $params [2];
  
28.
  $this
->tag = $params [3];
  
29.
  
//$a = $this->title ? $this->update():'';
  30.
  $
string = array ('flerror' => false, 'message' => 'Thanks for the ping.', 'legal' => "You agree that use of the blueidea.com ping service is governed by the Terms of Use found at www.blueidea.com." );
  31.
  return $
string;
  
32.
  }
  
33.
  
34.
  
public function update(){
  
35.
  echo
'这里放更新的一些条件';
  36.
  }
  
37.
  
38.
  
public function run() {
  
39.
  $this
->rpc_server ();
  
40.
  $request
= isset ( $GLOBALS ["HTTP_RAW_POST_DATA"] ) ? file_get_contents ( "php://input" ) : $GLOBALS ["HTTP_RAW_POST_DATA"];
  
41.
  $this
->xmlrpc_response = xmlrpc_server_call_method ( $this->xmlrpc_server, $request, null );
  
42.
  
//把函数处理后的结果XML进行输出
  
43.
  header (
'Content-Type: text/xml' );
  44.
  echo $this
->xmlrpc_response;
  
45.
  }
  
46.
  
47.
  
//销毁XML-RPC服务器端资源
  
48.
  
public function __destruct() {
  
49.
  xmlrpc_server_destroy ( $this
->xmlrpc_server );
  
50.
  }
  
51.}
  
52.$Obj = new Pings ( );
  
53.?>

  WebService的最常用的两种方法算是写齐了。

0
相关文章