http请求处理类

http://blog.qita.in/?post=496

1. /**
2. * http请求处理类（基于CURL进行封装）
3. *
4. * @author Xiwei Ye
5. * @version $Id$
6. */
7. class cls_http_request
8. {
10. /**
11. * get方式请求（curl）
12. *
13. * @param string $url 请求的url
14. * @param integer $timeout 超时时间（s）
15. * @return string(请求成功) | false(请求失败)
16. */
17. public static function curl_get($url, $timeout = 1)
18. {
19. $ch = curl_init();
20. curl_setopt($ch, CURLOPT_URL, $url);
21. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
22. curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
23. $result = curl_exec($ch);
24. curl_close($ch);
25. if (is_string($result) && strlen($result))
26. {
27. return $result;
28. }
29. else
30. {
31. return false;
32. }
33. }
35. /**
36. * post方式请求
37. *
38. * @param string $url 请求的url
39. * @param array $data 请求的参数数组（关联数组）
40. * @param integer $timeout 超时时间（s）
41. * @return string(请求成功) | false(请求失败)
42. */
43. public static function curl_post($url, $data, $timeout = 2)
44. {
45. $ch = curl_init();
46. curl_setopt($ch, CURLOPT_URL, $url);
47. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
48. curl_setopt($ch, CURLOPT_POST, 1);
49. curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
50. curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_0);
51. curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
52. $result = curl_exec($ch);
53. curl_close($ch);
54. if (is_string($result) && strlen($result))
55. {
56. return $result;
57. }
58. else
59. {
60. return false;
61. }
62. }
64. /**
65. * 多个url并行请求
66. *
67. * @param array $urls url数组
68. * @param integer $timeout 超时时间(s)
69. * @return array $res 返回结果
70. */
71. public static function curl_get_urls($urls, $timeout = 1)
72. {
73. $mh=curl_multi_init();
74. $chs=array();
75. foreach($urls as $url)
76. {
77. $ch=curl_init();
78. curl_setopt($ch,CURLOPT_URL,$url);
79. curl_setopt($ch,CURLOPT_HEADER,false);
80. curl_setopt($ch,CURLOPT_RETURNTRANSFER,true);
81. curl_setopt($ch,CURLOPT_CONNECTTIMEOUT,1);
82. curl_setopt($ch,CURLOPT_TIMEOUT,$timeout);
83. curl_multi_add_handle($mh,$ch);
84. $chs[]=$ch;
85. }
86. $active=null;
87. do {
88. $mrc=curl_multi_exec($mh,$active);
89. }while($mrc == CURLM_CALL_MULTI_PERFORM);
90. while($active && $mrc == CURLM_OK)
91. {
92. if(curl_multi_select($mh) != -1)
93. {
94. do{
95. $mrc=curl_multi_exec($mh,$active);
96. }while($mrc == CURLM_CALL_MULTI_PERFORM);
97. }
98. }
99. $res=array();
100. foreach($chs as $ch)
101. {
102. $res[]=curl_multi_getcontent($ch);
103. curl_multi_remove_handle($mh,$ch);
104. }
105. curl_multi_close($mh);
106. return $res;
107. }
108. }

复制代码