基于curl的php多线程类(异步请求)

古城微笑少年丶 2023-10-16 23:04 53阅读 0赞

来源:http://blog.csdn.net/sunjier/article/details/8375073

1.  <?php 
2.  /\*\*
3.   \* @name CurlRequest php 请求类
4.   \* @license 基于curl 实现， 可模拟多线程任务
5.   \*/
6.  **class** CurlRequest 
7.  \{ 
8.  /\*\*
9.   \* @name 成员变量
10.  \*/
11. // param
12. **protected**$url; // url参数
13. **protected**$data; // data参数
14. // request
15. **protected**$request\_url = ''; // 请求地址
16. **protected**$request\_data = **array**(); // 请求参数
17. **protected**$request\_timeout = 30; // 请求超时时间(单位秒) 0为无限等待
18. 
19. /\*\*
20.  \* @name 请求地址
21.  \* @param $url
22.  \*/
23. **public****function** url($url) 
24.  \{ 
25. $this\->url = $url; 
26. 
27. $parseUrl = parse\_url($url); 
28. $this\->request\_url = ''; 
29. $this\->request\_url .= $parseUrl\['scheme'\]=='https' ? 'https://' : 'http://'; 
30. $this\->request\_url .= $parseUrl\['host'\]; 
31. $this\->request\_url .= $parseUrl\['port'\] ? ':'.$parseUrl\['port'\] : ':80'; 
32. $this\->request\_url .= $parseUrl\['path'\]; 
33. parse\_str($parseUrl\['query'\], $parseStr); 
34. $this\->request\_data = array\_merge($this\->request\_data, $parseStr); 
35. 
36. **return**$this; 
37.  \} 
38. 
39. /\*\*
40.  \* @name 请求数据
41.  \* @param $data 为数组
42.  \*/
43. **public****function** data($data) 
44.  \{ 
45. $this\->request\_data = array\_merge($this\->request\_data, $data); 
46. **return**$this; 
47.  \} 
48. 
49. /\*\*
50.  \* @name 请求超时时间
51.  \* @param $timeout 超时， 当timeout 为0 或 flase时， 类为多线程执行
52.  \*/
53. **public****function** timeout($timeout) 
54.  \{ 
55. // $this->request\_timeout = (int)$timeout==0 ? 1 : (int)$timeout;
56. $this\->request\_timeout = (int)$timeout; 
57. **return**$this; 
58.  \} 
59. 
60. /\*\*
61.  \* @name get请求
62.  \* @return mixed \[status, data\]
63.  \*/
64. **public****function** get() 
65.  \{ 
66. $returnData; 
67. // 1. 初始化
68. $ch = curl\_init(); 
69. // 2. 设置选项，包括URL
70. $url = $this\->request\_url.'?'.http\_build\_query($this\->request\_data); 
71.  curl\_setopt($ch, CURLOPT\_HTTPGET, 1); // 请求类型 get
72.  curl\_setopt($ch, CURLOPT\_URL, $url); // 请求地址
73.  curl\_setopt($ch, CURLOPT\_RETURNTRANSFER, 1); // 将curl\_exec()获取的信息以文件流的形式返回,不直接输出。
74.  curl\_setopt($ch, CURLOPT\_CONNECTTIMEOUT, $this\->request\_timeout); // 连接等待时间
75.  curl\_setopt($ch, CURLOPT\_TIMEOUT, $this\->request\_timeout); // curl允许执行时间
76. 
77. // 3. 执行并获取返回内容
78. $output = curl\_exec($ch); 
79. **if** ($output === false) 
80.  \{ 
81. $returnData\['status'\] = 0; 
82. $returnData\['data'\] = curl\_error($ch); 
83.  \} 
84. **else**
85.  \{ 
86. $returnData\['status'\] = 1; 
87. $returnData\['data'\] = $output; 
88.  \} 
89. // 4. 释放curl句柄
90.  curl\_close($ch); 
91. **return**$returnData; 
92.  \} 
93. /\*\*
94.  \* @name post请求
95.  \* @return mixed \[status, data\]
96.  \*/
97. **public****function** post() 
98.  \{ 
99. $returnData; 
100. // 1. 初始化
101. $ch = curl\_init(); 
102. // 2. 设置选项，包括URL
103.  curl\_setopt($ch, CURLOPT\_POST, 1); // 请求类型 post
104.  curl\_setopt($ch, CURLOPT\_URL, $this\->request\_url); // 请求地址
105.  curl\_setopt($ch, CURLOPT\_POSTFIELDS, $this\->request\_data); // 请求数据 
106.  curl\_setopt($ch, CURLOPT\_RETURNTRANSFER, 1); // 将curl\_exec()获取的信息以文件流的形式返回,不直接输出。
107.  curl\_setopt($ch, CURLOPT\_CONNECTTIMEOUT, $this\->request\_timeout); // 连接等待时间
108.  curl\_setopt($ch, CURLOPT\_TIMEOUT, $this\->request\_timeout); // curl允许执行时间
109. // 3. 执行并获取返回内容
110. $output = curl\_exec($ch); 
111. **if** ($output === false) 
112.  \{ 
113. $returnData\['status'\] = 0; 
114. $returnData\['data'\] = curl\_error($ch); 
115.  \} 
116. **else**
117.  \{ 
118. $returnData\['status'\] = 1; 
119. $returnData\['data'\] = $output; 
120.  \} 
121. // 4. 释放curl句柄
122.  curl\_close($ch); 
123. **return**$returnData; 
124.  \} 
125. \}