curl.init.php 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251
  1. <?php
  2. if (!defined('IS_INITPHP')) exit('Access Denied!');
  3. /*********************************************************************************
  4. * InitPHP 3.8.2 国产PHP开发框架 扩展类库-CURL
  5. *-------------------------------------------------------------------------------
  6. * 版权所有: CopyRight By initphp.com
  7. * 您可以自由使用该源码,但是在使用过程中,请保留作者信息。尊重他人劳动成果就是尊重自己
  8. *-------------------------------------------------------------------------------
  9. * Author:zhuli Dtime:2014-11-25
  10. ***********************************************************************************/
  11. class curlInit {
  12. public function __construct(){
  13. if (!extension_loaded("curl")){
  14. throw new Exception("PHP不支持curl扩展,请检查php.ini配置!");
  15. }
  16. }
  17. private $cookie = '/data/cookie.txt'; //cookie保存路径,相对于APP_PATH
  18. private $timeout = 10;
  19. /**
  20. * CURL-get方式获取数据
  21. * @param string $url URL
  22. * @param string $proxy 是否代理
  23. * @param int $timeout 请求时间
  24. * @param array $header header信息
  25. */
  26. public function get($url, $proxy = null, $timeout = 10, $header=null) {
  27. if (!$url) return false;
  28. $ssl = stripos($url,'https://') === 0 ? true : false;
  29. $curl = curl_init();
  30. if (!is_null($proxy)) curl_setopt ($curl, CURLOPT_PROXY, $proxy);
  31. curl_setopt($curl, CURLOPT_URL, $url);
  32. if ($ssl) {
  33. curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0); // 对认证证书来源的检查
  34. curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 1); // 从证书中检查SSL加密算法是否存在
  35. }
  36. $cookie_file = $this->get_cookie_file();
  37. curl_setopt($curl, CURLOPT_COOKIEJAR, $cookie_file); //连接结束后保存cookie信息的文件。
  38. curl_setopt($curl, CURLOPT_COOKIEFILE, $cookie_file);//包含cookie数据的文件名,cookie文件的格式可以是Netscape格式,或者只是纯HTTP头部信息存入文件。
  39. curl_setopt($curl, CURLOPT_USERAGENT, $_SERVER['HTTP_USER_AGENT']); //在HTTP请求中包含一个"User-Agent: "头的字符串。
  40. curl_setopt($curl, CURLOPT_HEADER, 0); //启用时会将头文件的信息作为数据流输出。
  41. curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1); //启用时会将服务器服务器返回的"Location: "放在header中递归的返回给服务器,使用CURLOPT_MAXREDIRS可以限定递归返回的数量。
  42. curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); //文件流形式
  43. curl_setopt($curl, CURLOPT_TIMEOUT, $timeout); //设置cURL允许执行的最长秒数。
  44. if (is_array($header))
  45. curl_setopt($curl, CURLOPT_HTTPHEADER, $header); //设置请求的Header
  46. $content = curl_exec($curl);
  47. $curl_errno = curl_errno($curl);
  48. if ($curl_errno > 0){
  49. $error = sprintf("curl error=%s, errno=%d.", curl_error($curl), $curl_errno);
  50. curl_close($curl);
  51. throw new Exception($error);
  52. }
  53. curl_close($curl);
  54. return $content;
  55. }
  56. /**
  57. * CURL-post方式获取数据
  58. * @param string $url URL
  59. * @param array $data POST数据
  60. * @param string $proxy 是否代理
  61. * @param int $timeout 请求时间
  62. * @param array $header header信息
  63. */
  64. public function post($url, $data, $proxy = null, $timeout = 10, $header=null) {
  65. if (!$url) return false;
  66. if ($data) {
  67. $data = http_build_query($data);
  68. }
  69. $ssl = stripos($url,'https://') === 0 ? true : false;
  70. $curl = curl_init();
  71. if (!is_null($proxy)) curl_setopt ($curl, CURLOPT_PROXY, $proxy);
  72. curl_setopt($curl, CURLOPT_URL, $url);
  73. if ($ssl) {
  74. curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0); // 对认证证书来源的检查
  75. curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 1); // 从证书中检查SSL加密算法是否存在
  76. }
  77. $cookie_file = $this->get_cookie_file();
  78. curl_setopt($curl, CURLOPT_COOKIEJAR, $cookie_file); //连接结束后保存cookie信息的文件。
  79. curl_setopt($curl, CURLOPT_COOKIEFILE, $cookie_file);//包含cookie数据的文件名,cookie文件的格式可以是Netscape格式,或者只是纯HTTP头部信息存入文件。
  80. curl_setopt($curl, CURLOPT_USERAGENT, $_SERVER['HTTP_USER_AGENT']); //在HTTP请求中包含一个"User-Agent: "头的字符串。
  81. curl_setopt($curl, CURLOPT_HEADER, 0); //启用时会将头文件的信息作为数据流输出。
  82. curl_setopt($curl, CURLOPT_POST, true); //发送一个常规的Post请求
  83. curl_setopt($curl, CURLOPT_POSTFIELDS, $data);//Post提交的数据包
  84. curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1); //启用时会将服务器服务器返回的"Location: "放在header中递归的返回给服务器,使用CURLOPT_MAXREDIRS可以限定递归返回的数量。
  85. curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); //文件流形式
  86. curl_setopt($curl, CURLOPT_TIMEOUT, $timeout); //设置cURL允许执行的最长秒数。
  87. if (is_array($header))
  88. curl_setopt($curl, CURLOPT_HTTPHEADER, $header); //设置请求的Header
  89. $content = curl_exec($curl);
  90. $curl_errno = curl_errno($curl);
  91. if ($curl_errno > 0){
  92. $error = sprintf("curl error=%s, errno=%d.", curl_error($curl), $curl_errno);
  93. curl_close($curl);
  94. throw new Exception($error);
  95. }
  96. curl_close($curl);
  97. return $content;
  98. }
  99. /**
  100. * CURL-put方式获取数据
  101. * @param string $url URL
  102. * @param array $data POST数据
  103. * @param string $proxy 是否代理
  104. * @param int $timeout 请求时间
  105. * @param array $header header信息
  106. */
  107. public function put($url, $data, $proxy = null, $timeout = 10, $header=null) {
  108. if (!$url) return false;
  109. if ($data) {
  110. $data = http_build_query($data);
  111. }
  112. $ssl = stripos($url,'https://') === 0 ? true : false;
  113. $curl = curl_init();
  114. if (!is_null($proxy)) curl_setopt ($curl, CURLOPT_PROXY, $proxy);
  115. curl_setopt($curl, CURLOPT_URL, $url);
  116. if ($ssl) {
  117. curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0); // 对认证证书来源的检查
  118. curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 1); // 从证书中检查SSL加密算法是否存在
  119. }
  120. $cookie_file = $this->get_cookie_file();
  121. curl_setopt($curl, CURLOPT_COOKIEJAR, $cookie_file); //连接结束后保存cookie信息的文件。
  122. curl_setopt($curl, CURLOPT_COOKIEFILE, $cookie_file);//包含cookie数据的文件名,cookie文件的格式可以是Netscape格式,或者只是纯HTTP头部信息存入文件。
  123. curl_setopt($curl, CURLOPT_USERAGENT, $_SERVER['HTTP_USER_AGENT']); //在HTTP请求中包含一个"User-Agent: "头的字符串。
  124. curl_setopt($curl, CURLOPT_HEADER, 0); //启用时会将头文件的信息作为数据流输出。
  125. curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1); //启用时会将服务器服务器返回的"Location: "放在header中递归的返回给服务器,使用CURLOPT_MAXREDIRS可以限定递归返回的数量。
  126. curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); //文件流形式
  127. curl_setopt($curl, CURLOPT_TIMEOUT, $timeout); //设置cURL允许执行的最长秒数
  128. $data = (is_array($data)) ? http_build_query($data) : $data;
  129. curl_setopt($curl, CURLOPT_CUSTOMREQUEST, 'PUT');
  130. curl_setopt($curl, CURLOPT_HTTPHEADER, array('Content-Length: ' . strlen($data)));
  131. curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
  132. if (is_array($header))
  133. curl_setopt($curl, CURLOPT_HTTPHEADER, $header); //设置请求的Header
  134. $content = curl_exec($curl);
  135. $curl_errno = curl_errno($curl);
  136. if ($curl_errno > 0){
  137. $error = sprintf("curl error=%s, errno=%d.", curl_error($curl), $curl_errno);
  138. curl_close($curl);
  139. throw new Exception($error);
  140. }
  141. curl_close($curl);
  142. return $content;
  143. }
  144. /**
  145. * CURL-DEL方式获取数据
  146. * @param string $url URL
  147. * @param array $data POST数据
  148. * @param string $proxy 是否代理
  149. * @param int $timeout 请求时间
  150. * @param array $header header信息
  151. */
  152. public function del($url, $data, $proxy = null, $timeout = 10, $header=null) {
  153. if (!$url) return false;
  154. if ($data) {
  155. $data = http_build_query($data);
  156. }
  157. $ssl = stripos($url,'https://') === 0 ? true : false;
  158. $curl = curl_init();
  159. if (!is_null($proxy)) curl_setopt ($curl, CURLOPT_PROXY, $proxy);
  160. curl_setopt($curl, CURLOPT_URL, $url);
  161. if ($ssl) {
  162. curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0); // 对认证证书来源的检查
  163. curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 1); // 从证书中检查SSL加密算法是否存在
  164. }
  165. $cookie_file = $this->get_cookie_file();
  166. curl_setopt($curl, CURLOPT_COOKIEJAR, $cookie_file); //连接结束后保存cookie信息的文件。
  167. curl_setopt($curl, CURLOPT_COOKIEFILE, $cookie_file);//包含cookie数据的文件名,cookie文件的格式可以是Netscape格式,或者只是纯HTTP头部信息存入文件。
  168. curl_setopt($curl, CURLOPT_USERAGENT, $_SERVER['HTTP_USER_AGENT']); //在HTTP请求中包含一个"User-Agent: "头的字符串。
  169. curl_setopt($curl, CURLOPT_HEADER, 0); //启用时会将头文件的信息作为数据流输出。
  170. curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1); //启用时会将服务器服务器返回的"Location: "放在header中递归的返回给服务器,使用CURLOPT_MAXREDIRS可以限定递归返回的数量。
  171. curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); //文件流形式
  172. curl_setopt($curl, CURLOPT_TIMEOUT, $timeout); //设置cURL允许执行的最长秒数
  173. $data = (is_array($data)) ? http_build_query($data) : $data;
  174. curl_setopt($curl, CURLOPT_CUSTOMREQUEST, 'DEL');
  175. curl_setopt($curl, CURLOPT_HTTPHEADER, array('Content-Length: ' . strlen($data)));
  176. curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
  177. if (is_array($header))
  178. curl_setopt($curl, CURLOPT_HTTPHEADER, $header); //设置请求的Header
  179. $content = curl_exec($curl);
  180. $curl_errno = curl_errno($curl);
  181. if ($curl_errno > 0){
  182. $error = sprintf("curl error=%s, errno=%d.", curl_error($curl), $curl_errno);
  183. curl_close($curl);
  184. throw new Exception($error);
  185. }
  186. curl_close($curl);
  187. return $content;
  188. }
  189. /**
  190. * 自定义执行curl函数,作为默认get/post/put/del方法的补充
  191. * @todo 下一步准备用exec封装get/post/put/del方法,减少代码冗余
  192. * @param string $url 请求的URL的完整地址如:http://www.initphp.com/
  193. * @param array|string $data post/put/del提交的数据,可以是query string或php数组
  194. * @param array $options 自定义参数,格式与curl_setopt_array要求一致
  195. * @return string
  196. * @throws Exception
  197. */
  198. public function exec($url, $data=array(), array $options=array()){
  199. $curl = curl_init();
  200. if ($url) $options[CURLOPT_URL] = $url; //请求的URL,完整地址
  201. if($data){//post/put/del请求的数据设置
  202. $options[CURLOPT_POSTFIELDS] = is_array($data) ? http_build_query($data) : strval($data);
  203. !isset($options[CURLOPT_CUSTOMREQUEST]) && $options[CURLOPT_POST] = true;
  204. }
  205. //默认选项
  206. !isset($options[CURLOPT_HEADER]) && $options[CURLOPT_HEADER] = 0;//启用时会将头文件的信息作为数据流输出。
  207. !isset($options[CURLOPT_FOLLOWLOCATION]) && $options[CURLOPT_FOLLOWLOCATION] = 1;//启用时会将服务器服务器返回的"Location: "放在header中递归的返回给服务器,使用CURLOPT_MAXREDIRS可以限定递归返回的数量。
  208. !isset($options[CURLOPT_RETURNTRANSFER]) && $options[CURLOPT_RETURNTRANSFER] = 1;//文件流形式
  209. !isset($options[CURLOPT_TIMEOUT]) && $options[CURLOPT_TIMEOUT] = $this->get_timeout();//curl执行超时时间
  210. !isset($options[CURLOPT_COOKIEJAR]) && $options[CURLOPT_COOKIEJAR] = $this->get_cookie_file();//连接结束后保存cookie信息的文件。
  211. !isset($options[CURLOPT_COOKIEFILE]) && $options[CURLOPT_COOKIEFILE] = $this->get_cookie_file();//包含cookie数据的文件名,cookie文件的格式可以是Netscape格式,或者只是纯HTTP头部信息存入文件。
  212. !isset($options[CURLOPT_USERAGENT]) && $options[CURLOPT_USERAGENT] = $_SERVER['HTTP_USER_AGENT'];//在HTTP请求中包含一个"User-Agent: "头的字符串。
  213. curl_setopt_array($curl, $options);
  214. //执行并返回
  215. $content = curl_exec($curl);
  216. $curl_errno = curl_errno($curl);
  217. if ($curl_errno > 0){
  218. $error = sprintf("curl error=%s, errno=%d.", curl_error($curl), $curl_errno);
  219. curl_close($curl);
  220. throw new Exception($error);
  221. }
  222. curl_close($curl);
  223. return $content;
  224. }
  225. /**
  226. * 获取COOKIE存放文件的地址
  227. */
  228. private function get_cookie_file() {
  229. return APP_PATH . $this->cookie;
  230. }
  231. /**
  232. * 获取curl超时时间
  233. * @return int
  234. */
  235. private function get_timeout(){
  236. return $this->timeout;
  237. }
  238. }