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

<?php/** * @Author: yangyulong * @Email : anziguoer@sina.com * @Date:  2015-04-30 05:38:34 * @Last Modified by:  yangyulong * @Last Modified time: 2015-04-30 17:14:11 */ class apiServer{  /**   * 客户端请求的方式   * @var string   */  private $method = '';   /**   * 客户端发送的数据   * @var [type]   */  protected $param;   /**   * 要操作的资源   * @var [type]   */  protected $resourse;   /**   * 要操作的资源id   * @var [type]   */  protected $resourseId;    /**   * 构造函数， 获取client 请求的方式，以及传输的数据   * @param object 可以自定义传入的对象   */  public function __construct()  {    //首先对客户端的请求进行验证    $this->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());    }  }}

<?php /** * Created by PhpStorm. * User: anziguoer@sina.com * Date: 2015/4/29 * Time: 12:36 * link: http://www.ruanyifeng.com/blog/2014/05/restful_api.html [restful设计指南] *//*** * * * * * * * * * * * * * * * * * * * * * * * * * ***/ * 定义路由的请求方式                  * *                            * * $url_model=0                     * * 采用传统的URL参数模式                 * * http://serverName/appName/?m=module&a=action&id=1   * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * PATHINFO模式（默认模式）               * * 设置url_model 为1                   * * http://serverName/appName/module/action/id/1/     * ** * * * * * * * * * * * * * * * * * * * * * * * * * * ***/class restClient{  //请求的token  const token='yangyulong';   //请求url  private $url;     //请求的类型  private $requestType;     //请求的数据  private $data;     //curl实例  private $curl;   public $status;   private $headers = array();  /**   * [__construct 构造方法, 初始化数据]   * @param [type] $url     请求的服务器地址   * @param [type] $requestType 发送请求的方法   * @param [type] $data    发送的数据   * @param integer $url_model  路由请求方式   */  public function __construct($url, $data = array(), $requestType = 'get') {         //url是必须要传的,并且是符合PATHINFO模式的路径    if (!$url) {      return false;    }    $this->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 '<pre>';      print_r($e->getMessage());      echo '</pre>';    }     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);  }}

<?php/** * Created by PhpStorm. * User: anziguoer@sina.com * Date: 2015/4/29 * Time: 12:35 */ include './ApiClient.php'; $arr = array(  'user' => '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 '<pre>';print_r($info);echo '</pre>';

<?php/** * @Author: anziguoer@sina.com * @Email: anziguoer@sina.com * @link: https://git.oschina.net/anziguoer * @Date:  2015-04-30 16:52:53 * @Last Modified by:  yangyulong * @Last Modified time: 2015-04-30 17:26:37 */ include './ApiServer.php'; class testServer extends apiServer{  /**   * 先执行apiServer中的方法，初始化数据   * @param object $obj 可以传入的全局对象[数据库对象，框架全局对象等]   */     private $obj;   function __construct()//object $obj  {    parent::__construct();    //$this->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();