PHP creates a cross-platform restfule interface based on curl extension

restfule interface
Applicable platforms: cross-platform
Depends on: curl extension
git: https://git.oschina.net/anzigu

restfule interface
Applicable Platform: Cross-platform
Depends on: curl extension
git: https://git.oschina.net/anziguoer/restAPI

ApiServer.php

<?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 = &#39;&#39;;
  
  /**
   * 客户端发送的数据
   * @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[&#39;REQUEST_METHOD&#39;]);
  
    //所有的请求都是pathinfo模式
    $pathinfo = $_SERVER[&#39;PATH_INFO&#39;];
  
    //将pathinfo数据信息映射为实际请求方法
    $this->getResourse($pathinfo);
  
    //获取传输的具体参数
    $this->getData();
  
    //执行响应
    $this->doResponse();
  }
  
  /**
   * 根据不同的请求方式，获取数据
   * @return [type]
   */
  private function doResponse(){
    switch ($this->method) {
      case &#39;get&#39;:
        $this->_get();
        break;
      case &#39;post&#39;:
        $this->_post();
        break;
      case &#39;delete&#39;:
        $this->_delete();
        break;
      case &#39;put&#39;:
        $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(&#39;/&#39;, ltrim($pathinfo, &#39;/&#39;));
    list($this->resourse, $this->resourseId) = $info;
  }
  
  /**
   * 验证请求
   */
  private function authorization(){
    $token = $_SERVER[&#39;HTTP_CLIENT_TOKEN&#39;];
    $authorization = md5(substr(md5($token), 8, 24).$token);
    if($authorization != $_SERVER[&#39;HTTP_CLIENT_CODE&#39;]){
      //验证失败，输出错误信息给客户端
      $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(
        &#39;code&#39; => 1,
        &#39;info&#39; => &#39;请求成功&#39;,
        &#39;data&#39; =>$data
      ),
      //验证失败
      1 => array(
        &#39;code&#39; => 0,
        &#39;info&#39; => &#39;请求不合法&#39;
      )
    );
  
    try{
      if(!in_array($stat, array_keys($status))){
        throw new Exception(&#39;输入的状态码不合法&#39;);
      }else{
        echo json_encode($status[$stat]);
      }
    }catch (Exception $e){
      die($e->getMessage());
    }
  }
}

ApiClient.php

<?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=&#39;yangyulong&#39;;
  
  //请求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 = &#39;get&#39;) {
      
    //url是必须要传的,并且是符合PATHINFO模式的路径
    if (!$url) {
      return false;
    }
    $this->requestType = strtolower($requestType);
    $paramUrl = &#39;&#39;;
    // PATHINFO模式
    if (!empty($data)) {
      foreach ($data as $key => $value) {
        $paramUrl.= $key . &#39;=&#39; . $value.&#39;&&#39;;
      }
      $url = $url .&#39;?&#39;. $paramUrl;
    }
      
    //初始化类中的数据
    $this->url = $url;
      
    $this->data = $data;
    try{
      if(!$this->curl = curl_init()){
        throw new Exception(&#39;curl初始化错误：&#39;);
      };
    }catch (Exception $e){
      echo &#39;<pre class="brush:php;toolbar:false">&#39;;
      print_r($e->getMessage());
      echo &#39;

';     }        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

<?php
/**
 * Created by PhpStorm.
 * User: anziguoer@sina.com
 * Date: 2015/4/29
 * Time: 12:35
 */
  
include &#39;./ApiClient.php&#39;;
  
$arr = array(
  &#39;user&#39; => &#39;anziguoer&#39;,
  &#39;passwd&#39; => &#39;yangyulong&#39;
);
// $url = &#39;http://localhost/restAPI/restServer.php&#39;;
$url = &#39;http://localhost/restAPI/testServer.php/user/123&#39;;
  
$rest = new restClient($url, $arr, &#39;get&#39;);
$info = $rest->doRequest();
  
//获取curl中的状态信息
$status = $rest->status;
echo &#39;<pre class="brush:php;toolbar:false">&#39;;
print_r($info);
echo &#39;

';

testServer.php

<?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 &#39;./ApiServer.php&#39;;
  
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();

The above is the entire content of this article, I hope you all like it.

For more PHP-based curl extensions to create cross-platform restfule interface related articles, please pay attention to the PHP Chinese website!