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

这篇文章主要介绍了php基于curl扩展制作跨平台的restfule 接口的相关资料以及详细的代码，有需要的小伙伴可以参考下。

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. //验证失败，输出错误信息给客户端 
112. $this->outPut($status = 1); 
113. } 
114. } 
115.  
116. /** 
117. * [getData 获取传送的参数信息] 
118. * @param [type] $pad [description] 
119. * @return [type] [description] 
120. */ 
121. private function getData(){ 
122. //所有的参数都是get传参 
123. $this->param = $_GET; 
124. } 
125.  
126. /** 
127. * 获取资源操作 
128. * @return [type] [description] 
129. */ 
130. protected function _get(){ 
131. //逻辑代码根据自己实际项目需要实现 
132. }  
133.  
134. /** 
135. * 新增资源操作 
136. * @return [type] [description] 
137. */ 
138. protected function _post(){ 
139. //逻辑代码根据自己实际项目需要实现 
140. } 
141.  
142. /** 
143. * 删除资源操作 
144. * @return [type] [description] 
145. */ 
146. protected function _delete(){ 
147. //逻辑代码根据自己实际项目需要实现 
148. } 
149.  
150. /** 
151. * 更新资源操作 
152. * @return [type] [description] 
153. */ 
154. protected function _put(){ 
155. //逻辑代码根据自己实际项目需要实现 
156. } 
157.  
158. /** 
159. * 出入服务端返回的数据信息 json格式 
160. */ 
161. public function outPut($stat, $data=array()){ 
162. $status = array( 
163. //0 状态表示请求成功 
164. 0 => array( 
165. 'code' => 1, 
166. 'info' => '请求成功', 
167. 'data' =>$data 
168. ), 
169. //验证失败 
170. 1 => array( 
171. 'code' => 0, 
172. 'info' => '请求不合法' 
173. ) 
174. ); 
175.  
176. try{ 
177. if(!in_array($stat, array_keys($status))){ 
178. throw new Exception('输入的状态码不合法'); 
179. }else{ 
180. echo json_encode($status[$stat]); 
181. } 
182. }catch (Exception $e){ 
183. die($e->getMessage()); 
184. } 
185. } 
186. } 

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 (!emptyempty($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>'; 
75. print_r($e->getMessage()); 
76. echo '</pre>'; 
77. } 
78.  
79. curl_setopt($this->curl, CURLOPT_URL, $this->url); 
80. curl_setopt($this->curl, CURLOPT_RETURNTRANSFER, 1); 
81.  
82. } 
83.  
84. /** 
85. * [_post 设置get请求的参数] 
86. * @return [type] [description] 
87. */ 
88. public function _get() { 
89.  
90. } 
91.  
92. /** 
93. * [_post 设置post请求的参数] 
94. * post 新增资源 
95. * @return [type] [description] 
96. */ 
97. public function _post() { 
98.  
99. curl_setopt($this->curl, CURLOPT_POST, 1); 
100.  
101. curl_setopt($this->curl, CURLOPT_POSTFIELDS, $this->data); 
102.  
103. } 
104.  
105. /** 
106. * [_put 设置put请求] 
107. * put 更新资源 
108. * @return [type] [description] 
109. */ 
110. public function _put() { 
111.  
112. curl_setopt($this->curl, CURLOPT_CUSTOMREQUEST, 'PUT'); 
113. } 
114.  
115. /** 
116. * [_delete 删除资源] 
117. * delete 删除资源 
118. * @return [type] [description] 
119. */ 
120. public function _delete() { 
121. curl_setopt($this->curl, CURLOPT_CUSTOMREQUEST, 'DELETE'); 
122.  
123. } 
124.  
125. /** 
126. * [doRequest 执行发送请求] 
127. * @return [type] [description] 
128. */ 
129. public function doRequest() { 
130. //发送给服务端验证信息 
131. if((null !== self::token) && self::token){ 
132. $this->headers = array( 
133. 'Client_Token: '.self::token, 
134. 'Client_Code: '.$this->setAuthorization() 
135. ); 
136. } 
137.  
138. //发送头部信息 
139. $this->setHeader(); 
140.  
141. //发送请求方式 
142. switch ($this->requestType) { 
143. case 'post': 
144. $this->_post(); 
145. break; 
146.  
147. case 'put': 
148. $this->_put(); 
149. break; 
150.  
151. case 'delete': 
152. $this->_delete(); 
153. break; 
154.  
155. default: 
156. curl_setopt($this->curl, CURLOPT_HTTPGET, TRUE); 
157. break; 
158. } 
159. //执行curl请求 
160. $info = curl_exec($this->curl); 
161.  
162. //获取curl执行状态信息 
163. $this->status = $this->getInfo(); 
164. return $info; 
165. } 
166.  
167. /** 
168. * 设置发送的头部信息 
169. */ 
170. private function setHeader(){ 
171. curl_setopt($this->curl, CURLOPT_HTTPHEADER, $this->headers); 
172. } 
173.  
174. /** 
175. * 生成授权码 
176. * @return string 授权码 
177. */ 
178. private function setAuthorization(){ 
179. $authorization = md5(substr(md5(self::token), 8, 24).self::token); 
180. return $authorization; 
181. } 
182. /** 
183. * 获取curl中的状态信息 
184. */ 
185. public function getInfo(){ 
186. return curl_getinfo($this->curl); 
187. } 
188.  
189. /** 
190. * 关闭curl连接 
191. */ 
192. public function __destruct(){ 
193. curl_close($this->curl); 
194. } 
195. } 

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>'; 
24. print_r($info); 
25. echo '</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(); 

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