這篇文章主要介紹了php實(shí)現(xiàn)的一個(gè)簡單json rpc框架實(shí)例,本文給出了RPC服務(wù)端和客戶端代碼以及應(yīng)用實(shí)例,需要的朋友可以參考下

json rpc 是一種以json為消息格式的遠(yuǎn)程調(diào)用服務(wù)，它是一套允許運(yùn)行在不同操作系統(tǒng)、不同環(huán)境的程序?qū)崿F(xiàn)基于Internet過程調(diào)用的規(guī)范和一系列的實(shí)現(xiàn)。這種遠(yuǎn)程過程調(diào)用可以使用http作為傳輸協(xié)議，也可以使用其它傳輸協(xié)議，傳輸?shù)膬?nèi)容是json消息體。

下面我們code一套基于php的rpc框架，此框架中包含rpc的服務(wù)端server，和應(yīng)用端client；

（一）PHP服務(wù)端RPCserver jsonRPCServer.php

(二)Rpc客戶端，jsonRPCClient.php

private $debug;
private $url;
// 請(qǐng)求id
private $id;
private $notification = false;
/**
* @param $url
* @param bool $debug
*/
public function __construct($url,$debug = false) {
// server URL
$this->url = $url;
// proxy
empty($proxy) ? $this->proxy = '' : $this->proxy = $proxy;
// debug state
empty($debug) ? $this->debug = false : $this->debug = true;
// message id
$this->id = 1;
}

/**
*
* @param boolean $notification
*/
public function setRPCNotification($notification) {
empty($notification) ? $this->notification = false : $this->notification = true;
}

/**
* @param $method
* @param $params
* @return bool
* @throws Exception
*/
public function __call($method,$params) {
// 檢驗(yàn)request信息
if (!is_scalar($method)) {
throw new Exception('Method name has no scalar value');
}
if (is_array($params)) {
$params = array_values($params);
} else {
throw new Exception('Params must be given as array');
}

if ($this->notification) {
$currentId = NULL;
} else {
$currentId = $this->id;
}

// 拼裝成一個(gè)request請(qǐng)求
$request = array( 'method' => $method, 'params' => $params,'id' => $currentId);
$request = json_encode($request);
$this->debug && $this->debug.='***** Request *****'."/n".$request."/n".'***** End Of request *****'."/n/n";
$opts = array ('http' => array (
'method' => 'POST',
'header' => 'Content-type: application/json',
'content' => $request
));
// 關(guān)鍵幾部
$context = stream_context_create($opts);
if ( $result = file_get_contents($this->url, false, $context)) {
$response = json_decode($result,true);
} else {
throw new Exception('Unable to connect to '.$this->url);
}
// 輸出調(diào)試信息
if ($this->debug) {
echo nl2br(($this->debug));
}
// 檢驗(yàn)response信息
if (!$this->notification) {
// check
if ($response['id'] != $currentId) {
throw new Exception('Incorrect response id (request id: '.$currentId.', response id: '.$response['id'].')');
}
if (!is_null($response['error'])) {
throw new Exception('Request error: '.$response['error']);
}
return $response['result'];

} else {
return true;
}
}
}
?>

(三) 應(yīng)用實(shí)例
（1）服務(wù)端 server.php

（2）測(cè)試類文件，member.php

（3）客戶端 client.php

$url = 'http://localhost/rpc/server.php';
$myExample = new jsonRPCClient($url);