php基于curl扩展制作跨平台的restfule 接口

php  /  管理员 发布于 7年前   141

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();

以上所述就是本文的全部内容了，希望大家能够喜欢。

您可能感兴趣的文章:

• SpringMVC Restful api接口实现的代码
• 基于Restful接口调用方法总结(超详细)
• Ajax调用restful接口传送Json格式数据的方法
• PHP编写RESTful接口
• 在Python的框架中为MySQL实现restful接口的教程
• 高性能web服务器框架Tornado简单实现restful接口及开发实例
• 深入浅析Restful接口的两种使用方式