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

前端之家收集整理的这篇文章主要介绍了php基于curl扩展制作跨平台的restfule 接口前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

restfule 接口 适用的平台:跨平台 所依赖:curl扩展 git:

ApiServer.PHP

PHP;"> 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数据信息映射为实际请求<a href="/tag/fangfa/" target="_blank" class="keywords">方法</a>
$this->getResourse($pathinfo);

//<a href="/tag/huoqu/" target="_blank" class="keywords">获取</a>传输的具体参数
$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数据信息映射为实际请求<a href="/tag/fangfa/" target="_blank" class="keywords">方法</a>
 * GET /users: 逐页列出所有<a href="/tag/yonghu/" target="_blank" class="keywords">用户</a>;
 * POST /users: 创建一个<a href="/tag/xinyonghu/" target="_blank" class="keywords">新用户</a>;
 * GET /users/123: 返回<a href="/tag/yonghu/" target="_blank" class="keywords">用户</a>为123的详细信息;
 * PUT /users/123: 更<a href="/tag/xinyonghu/" target="_blank" class="keywords">新用户</a>123;
 * DELETE /users/123: <a href="/tag/shanchu/" target="_blank" class="keywords">删除</a><a href="/tag/yonghu/" target="_blank" class="keywords">用户</a>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

PHP;"> /**

//请求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初始化<a href="/tag/cuowu/" target="_blank" class="keywords">错误</a>:');
  };
}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,'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);

//<a href="/tag/huoqu/" target="_blank" class="keywords">获取</a>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),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 './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 '

    ';
    print_r($info);
    echo '
    ';

    testServer.PHP

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

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

    猜你在找的PHP相关文章