restfule 接口
适用的平台：跨平台
所依赖：curl扩展
git：https://git.oschina.net/anziguoer/restapi
apiserver.php
authorization(); $this->method = strtolower($_server['request_method']); //所有的请求都是pathinfo模式 $pathinfo = $_server['path_info']; //将pathinfo数据信息映射为实际请求方法 $this->getresourse($pathinfo); //获取传输的具体参数 $this->getdata(); //执行响应 $this->doresponse(); } /** * 根据不同的请求方式，获取数据 * @return [type] */ private function doresponse(){ switch ($this->method) { case 'get': $this->_get(); break; case 'post': $this->_post(); break; case 'delete': $this->_delete(); break; case 'put': $this->_put(); break; default: $this->_get(); break; } } // 将pathinfo数据信息映射为实际请求方法 private function getresourse($pathinfo){ /** * 将pathinfo数据信息映射为实际请求方法 * get /users: 逐页列出所有用户； * post /users: 创建一个新用户； * get /users/123: 返回用户为123的详细信息; * put /users/123: 更新用户123; * delete /users/123: 删除用户123; * * 根据以上规则，将pathinfo第一个参数映射为需要操作的数据表， * 第二个参数映射为操作的id */ $info = explode('/', ltrim($pathinfo, '/')); list($this->resourse, $this->resourseid) = $info; } /** * 验证请求 */ private function authorization(){ $token = $_server['http_client_token']; $authorization = md5(substr(md5($token), 8, 24).$token); if($authorization != $_server['http_client_code']){ //验证失败，输出错误信息给客户端 $this->output($status = 1); } } /** * [getdata 获取传送的参数信息] * @param [type] $pad [description] * @return [type] [description] */ private function getdata(){ //所有的参数都是get传参 $this->param = $_get; } /** * 获取资源操作 * @return [type] [description] */ protected function _get(){ //逻辑代码根据自己实际项目需要实现 } /** * 新增资源操作 * @return [type] [description] */ protected function _post(){ //逻辑代码根据自己实际项目需要实现 } /** * 删除资源操作 * @return [type] [description] */ protected function _delete(){ //逻辑代码根据自己实际项目需要实现 } /** * 更新资源操作 * @return [type] [description] */ protected function _put(){ //逻辑代码根据自己实际项目需要实现 } /** * 出入服务端返回的数据信息 json格式 */ public function output($stat, $data=array()){ $status = array( //0 状态表示请求成功 0 => array( 'code' => 1, 'info' => '请求成功', 'data' =>$data ), //验证失败 1 => array( 'code' => 0, 'info' => '请求不合法' ) ); try{ if(!in_array($stat, array_keys($status))){ throw new exception('输入的状态码不合法'); }else{ echo json_encode($status[$stat]); } }catch (exception $e){ die($e->getmessage()); } }}
apiclient.php
requesttype = strtolower($requesttype); $paramurl = ''; // pathinfo模式 if (!empty($data)) { foreach ($data as $key => $value) { $paramurl.= $key . '=' . $value.'&'; } $url = $url .'?'. $paramurl; } //初始化类中的数据 $this->url = $url; $this->data = $data; try{ if(!$this->curl = curl_init()){ throw new exception('curl初始化错误：'); }; }catch (exception $e){ echo ''; print_r($e->getmessage()); echo '
'; } curl_setopt($this->curl, curlopt_url, $this->url); curl_setopt($this->curl, curlopt_returntransfer, 1); } /** * [_post 设置get请求的参数] * @return [type] [description] */ public function _get() { } /** * [_post 设置post请求的参数] * post 新增资源 * @return [type] [description] */ public function _post() { curl_setopt($this->curl, curlopt_post, 1); curl_setopt($this->curl, curlopt_postfields, $this->data); } /** * [_put 设置put请求] * put 更新资源 * @return [type] [description] */ public function _put() { curl_setopt($this->curl, curlopt_customrequest, 'put'); } /** * [_delete 删除资源] * delete 删除资源 * @return [type] [description] */ public function _delete() { curl_setopt($this->curl, curlopt_customrequest, 'delete'); } /** * [dorequest 执行发送请求] * @return [type] [description] */ public function dorequest() { //发送给服务端验证信息 if((null !== self::token) && self::token){ $this->headers = array( 'client_token: '.self::token, 'client_code: '.$this->setauthorization() ); } //发送头部信息 $this->setheader(); //发送请求方式 switch ($this->requesttype) { case 'post': $this->_post(); break; case 'put': $this->_put(); break; case 'delete': $this->_delete(); break; default: curl_setopt($this->curl, curlopt_httpget, true); break; } //执行curl请求 $info = curl_exec($this->curl); //获取curl执行状态信息 $this->status = $this->getinfo(); return $info; } /** * 设置发送的头部信息 */ private function setheader(){ curl_setopt($this->curl, curlopt_httpheader, $this->headers); } /** * 生成授权码 * @return string 授权码 */ private function setauthorization(){ $authorization = md5(substr(md5(self::token), 8, 24).self::token); return $authorization; } /** * 获取curl中的状态信息 */ public function getinfo(){ return curl_getinfo($this->curl); } /** * 关闭curl连接 */ public function __destruct(){ curl_close($this->curl); }}
testclient.php
'anziguoer', 'passwd' => 'yangyulong');// $url = 'http://localhost/restapi/restserver.php';$url = 'http://localhost/restapi/testserver.php/user/123'; $rest = new restclient($url, $arr, 'get');$info = $rest->dorequest(); //获取curl中的状态信息$status = $rest->status;echo '';print_r($info);echo '
';
testserver.php
obj = $obj; //$this->resourse; 父类中已经实现，此类中可以直接使用 //$tihs->resourseid; 父类中已经实现，此类中可以直接使用 } /** * 获取资源操作 * @return [type] [description] */ protected function _get(){ echo get; //逻辑代码根据自己实际项目需要实现 } /** * 新增资源操作 * @return [type] [description] */ protected function _post(){ echo post; //逻辑代码根据自己实际项目需要实现 } /** * 删除资源操作 * @return [type] [description] */ protected function _delete(){ //逻辑代码根据自己实际项目需要实现 } /** * 更新资源操作 * @return [type] [description] */ protected function _put(){ echo put; //逻辑代码根据自己实际项目需要实现 }} $server = new testserver();
以上所述就是本文的全部内容了，希望大家能够喜欢。