当前位置：Gxlcms > PHP教程 > php基于curl扩展制作跨平台的restfule接口，phpcurlrestfule_PHP教程

php基于curl扩展制作跨平台的restfule接口，phpcurlrestfule_PHP教程

时间：2021-07-01 10:21:17 帮助过：25人阅读

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


restfule 接口
适用的平台：跨平台
所依赖：curl扩展
git：https://git.oschina.net/anziguoer/restAPI

ApiServer.php

  1. <?php
  2. /**
  3.  * @Author: yangyulong
  4.  * @Email : anziguoer@sina.com
  5.  * @Date:  2015-04-30 05:38:34
  6.  * @Last Modified by:  yangyulong
  7.  * @Last Modified time: 2015-04-30 17:14:11
  8.  */
  9.  
  10. class apiServer
  11. {
  12.   /**
  13.    * 客户端请求的方式
  14.    * @var string
  15.    */
  16.   private $method = '';
  17.  
  18.   /**
  19.    * 客户端发送的数据
  20.    * @var [type]
  21.    */
  22.   protected $param;
  23.  
  24.   /**
  25.    * 要操作的资源
  26.    * @var [type]
  27.    */
  28.   protected $resourse;
  29.  
  30.   /**
  31.    * 要操作的资源id
  32.    * @var [type]
  33.    */
  34.   protected $resourseId;
  35.  
  36.  
  37.   /**
  38.    * 构造函数， 获取client 请求的方式，以及传输的数据
  39.    * @param object 可以自定义传入的对象
  40.    */
  41.   public function __construct()
  42.   {
  43.     //首先对客户端的请求进行验证
  44.     $this->authorization();
  45.  
  46.     $this->method = strtolower($_SERVER['REQUEST_METHOD']);
  47.  
  48.     //所有的请求都是pathinfo模式
  49.     $pathinfo = $_SERVER['PATH_INFO'];
  50.  
  51.     //将pathinfo数据信息映射为实际请求方法
  52.     $this->getResourse($pathinfo);
  53.  
  54.     //获取传输的具体参数
  55.     $this->getData();
  56.  
  57.     //执行响应
  58.     $this->doResponse();
  59.   }
  60.  
  61.   /**
  62.    * 根据不同的请求方式，获取数据
  63.    * @return [type]
  64.    */
  65.   private function doResponse(){
  66.     switch ($this->method) {
  67.       case 'get':
  68.         $this->_get();
  69.         break;
  70.       case 'post':
  71.         $this->_post();
  72.         break;
  73.       case 'delete':
  74.         $this->_delete();
  75.         break;
  76.       case 'put':
  77.         $this->_put();
  78.         break;
  79.       default:
  80.         $this->_get();
  81.         break;
  82.     }
  83.   }
  84.  
  85.   // 将pathinfo数据信息映射为实际请求方法
  86.   private function getResourse($pathinfo){
  87.  
  88.     /**
  89.      * 将pathinfo数据信息映射为实际请求方法
  90.      * GET /users: 逐页列出所有用户；
  91.      * POST /users: 创建一个新用户；
  92.      * GET /users/123: 返回用户为123的详细信息;
  93.      * PUT /users/123: 更新用户123;
  94.      * DELETE /users/123: 删除用户123;
  95.      *
  96.      * 根据以上规则，将pathinfo第一个参数映射为需要操作的数据表，
  97.      * 第二个参数映射为操作的id
  98.      */
  99.      
  100.     $info = explode('/', ltrim($pathinfo, '/'));
  101.     list($this->resourse, $this->resourseId) = $info;
  102.   }
  103.  
  104.   /**
  105.    * 验证请求
  106.    */
  107.   private function authorization(){
  108.     $token = $_SERVER['HTTP_CLIENT_TOKEN'];
  109.     $authorization = md5(substr(md5($token), 8, 24).$token);
  110.     if($authorization != $_SERVER['HTTP_CLIENT_CODE']){
  111.       //验证失败，
输出错误信息给客户端 $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

  1. <?php
  2.  
  3. /**
  4.  * Created by PhpStorm.
  5.  * User: anziguoer@sina.com
  6.  * Date: 2015/4/29
  7.  * Time: 12:36
  8.  * link: http://www.ruanyifeng.com/blog/2014/05/restful_api.html [restful设计指南]
  9.  */
  10. /*** * * * * * * * * * * * * * * * * * * * * * * * * * ***\
  11.  * 定义路由的请求方式                  *
  12.  *                            *
  13.  * $url_model=0                     *
  14.  * 采用传统的URL参数模式                 *
  15.  * http://serverName/appName/?m=module&a=action&id=1   *
  16.  * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
  17.  * PATHINFO模式（默认模式）               *
  18.  * 设置url_model 为1                   *
  19.  * http://serverName/appName/module/action/id/1/     *
  20.  ** * * * * * * * * * * * * * * * * * * * * * * * * * * **
  21. */
  22. class restClient
  23. {
  24.   //请求的token
  25.   const token='yangyulong';
  26.  
  27.   //请求url
  28.   private $url;
  29.    
  30.   //请求的类型
  31.   private $requestType;
  32.    
  33.   //请求的数据
  34.   private $data;
  35.    
  36.   //curl实例
  37.   private $curl;
  38.  
  39.   public $status;
  40.  
  41.   private $headers = array();
  42.   /**
  43.    * [__construct 构造方法, 初始化数据]
  44.    * @param [type] $url     请求的服务器地址
  45.    * @param [type] $requestType 发送请求的方法
  46.    * @param [type] $data    发送的数据
  47.    * @param integer $url_model  路由请求方式
  48.    */
  49.   public function __construct($url, $data = array(), $requestType = 'get') {
  50.      
  51.     //url是必须要传的,并且是符合PATHINFO模式的路径
  52.     if (!$url) {
  53.       return false;
  54.     }
  55.     $this->requestType = strtolower($requestType);
  56.     $paramUrl = '';
  57.     // PATHINFO模式
  58.     if (!empty($data)) {
  59.       foreach ($data as $key => $value) {
  60.         $paramUrl.= $key . '=' . $value.'&';
  61.       }
  62.       $url = $url .'?'. $paramUrl;
  63.     }
  64.      
  65.     //初始化类中的数据
  66.     $this->url = $url;
  67.      
  68.     $this->data = $data;
  69.     try{
  70.       if(!$this->curl = curl_init()){
  71.         throw new Exception('curl初始化错误：');
  72.       };
  73.     }catch (Exception $e){
  74.       echo '<pre class="brush:php;toolbar:false layui-box layui-code-view layui-code-notepad"><ol class="layui-code-ol"><li>';</li><li>      print_r($e->getMessage());</li><li>      echo '</li></ol></pre>';
  75.     }
  76.  
  77.     curl_setopt($this->curl, CURLOPT_URL, $this->url);
  78.     curl_setopt($this->curl, CURLOPT_RETURNTRANSFER, 1);
  79.  
  80.   }
  81.    
  82.   /**
  83.    * [_post 设置get请求的参数]
  84.    * @return [type] [description]
  85.    */
  86.   public function _get() {
  87.  
  88.   }
  89.    
  90.   /**
  91.    * [_post 设置post请求的参数]
  92.    * post 新增资源
  93.    * @return [type] [description]
  94.    */
  95.   public function _post() {
  96.  
  97.     curl_setopt($this->curl, CURLOPT_POST, 1);
  98.  
  99.     curl_setopt($this->curl, CURLOPT_POSTFIELDS, $this->data);
  100.      
  101.   }
  102.    
  103.   /**
  104.    * [_put 设置put请求]
  105.    * put 更新资源
  106.    * @return [type] [description]
  107.    */
  108.   public function _put() {
  109.      
  110.     curl_setopt($this->curl, CURLOPT_CUSTOMREQUEST, 'PUT');
  111.   }
  112.    
  113.   /**
  114.    * [_delete 删除资源]
  115.    * delete 删除资源
  116.    * @return [type] [description]
  117.    */
  118.   public function _delete() {
  119.     curl_setopt($this->curl, CURLOPT_CUSTOMREQUEST, 'DELETE');
  120.  
  121.   }
  122.    
  123.   /**
  124.    * [doRequest 执行发送请求]
  125.    * @return [type] [description]
  126.    */
  127.   public function doRequest() {
  128.     //发送给服务端验证信息
  129.     if((null !== self::token) && self::token){
  130.       $this->headers = array(
  131.         'Client_Token: '.self::token,
  132.         'Client_Code: '.$this->setAuthorization()
  133.       );
  134.     }
  135.  
  136.     //发送头部信息
  137.     $this->setHeader();
  138.  
  139.     //发送请求方式
  140.     switch ($this->requestType) {
  141.       case 'post':
  142.         $this->_post();
  143.         break;
  144.  
  145.       case 'put':
  146.         $this->_put();
  147.         break;
  148.  
  149.       case 'delete':
  150.         $this->_delete();
  151.         break;
  152.  
  153.       default:
  154.         curl_setopt($this->curl, CURLOPT_HTTPGET, TRUE);
  155.         break;
  156.     }
  157.     //执行curl请求
  158.     $info = curl_exec($this->curl);
  159.  
  160.     //获取curl执行状态信息
  161.     $this->status = $this->getInfo();
  162.     return $info;
  163.   }
  164.  
  165.   /**
  166.    * 设置发送的头部信息
  167.    */
  168.   private function setHeader(){
  169.     curl_setopt($this->curl, CURLOPT_HTTPHEADER, $this->headers);
  170.   }
  171.  
  172.   /**
  173.    * 生成授权码
  174.    * @return string 授权码
  175.    */
  176.   private function setAuthorization(){
  177.     $authorization = md5(substr(md5(self::token), 8, 24).self::token);
  178.     return $authorization;
  179.   }
  180.   /**
  181.    * 获取curl中的状态信息
  182.    */
  183.   public function getInfo(){
  184.     return curl_getinfo($this->curl);
  185.   }
  186.  
  187.   /**
  188.    * 关闭curl连接
  189.    */
  190.   public function __destruct(){
  191.     curl_close($this->curl);
  192.   }
  193. }

testClient.php

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: anziguoer@sina.com
  5.  * Date: 2015/4/29
  6.  * Time: 12:35
  7.  */
  8.  
  9. include './ApiClient.php';
  10.  
  11. $arr = array(
  12.   'user' => 'anziguoer',
  13.   'passwd' => 'yangyulong'
  14. );
  15. // $url = 'http://localhost/restAPI/restServer.php';
  16. $url = 'http://localhost/restAPI/testServer.php/user/123';
  17.  
  18. $rest = new restClient($url, $arr, 'get');
  19. $info = $rest->doRequest();
  20.  
  21. //获取curl中的状态信息
  22. $status = $rest->status;
  23. echo '<pre class="brush:php;toolbar:false layui-box layui-code-view layui-code-notepad"><ol class="layui-code-ol"><li>';</li><li>print_r($info);</li><li>echo '</li></ol></pre>';

testServer.php

  1. <?php
  2. /**
  3.  * @Author: anziguoer@sina.com
  4.  * @Email: anziguoer@sina.com
  5.  * @link: https://git.oschina.net/anziguoer
  6.  * @Date:  2015-04-30 16:52:53
  7.  * @Last Modified by:  yangyulong
  8.  * @Last Modified time: 2015-04-30 17:26:37
  9.  */
  10.  
  11. include './ApiServer.php';
  12.  
  13. class testServer extends apiServer
  14. {
  15.   /**
  16.    * 先执行apiServer中的方法，初始化数据
  17.    * @param object $obj 可以传入的全局对象[数据库对象，框架全局对象等]
  18.    */
  19.    
  20.   private $obj;
  21.  
  22.   function __construct()//object $obj
  23.   {
  24.     parent::__construct();
  25.     //$this->obj = $obj;
  26.     //$this->resourse; 父类中已经实现，此类中可以直接使用
  27.     //$tihs->resourseId; 父类中已经实现，此类中可以直接使用
  28.   }
  29.    
  30.   /**
  31.    * 获取资源操作
  32.    * @return [type] [description]
  33.    */
  34.   protected function _get(){
  35.     echo "get";
  36.     //逻辑代码根据自己实际项目需要实现
  37.   }  
  38.  
  39.   /**
  40.    * 新增资源操作
  41.    * @return [type] [description]
  42.    */
  43.   protected function _post(){
  44.     echo "post";
  45.     //逻辑代码根据自己实际项目需要实现
  46.   }
  47.  
  48.   /**
  49.    * 删除资源操作
  50.    * @return [type] [description]
  51.    */
  52.   protected function _delete(){
  53.     //逻辑代码根据自己实际项目需要实现
  54.   }
  55.  
  56.   /**
  57.    * 更新资源操作
  58.    * @return [type] [description]
  59.    */
  60.   protected function _put(){
  61.     echo "put";
  62.     //逻辑代码根据自己实际项目需要实现
  63.   }
  64. }
  65.  
  66. $server = new testServer();

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

www.bkjia.comtruehttp://www.bkjia.com/PHPjc/997902.htmlTechArticlephp基于curl扩展制作跨平台的restfule 接口，phpcurlrestfule restfule 接口 适用的平台：跨平台 所依赖：curl扩展 git：https://git.oschina.net/anziguoer/re...

人气教程排行

本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！