php三种实现多线程类似的方法

这篇文章主要介绍了php三种实现多线程类似的方法，需要的朋友可以参考下

1、curl_multi方法

当需要多线程的时候，可以用curl_multi一次性请求多个操作来完成，但curl走的是网络通信，效率与可靠性就比较差了的。

1. function main(){  
2.  
3. $sql = "select waybill_id,order_id from waybill where status>40 order by update_time desc limit 10 ";  
4.  
5. $data = Yii::app()->db->createCommand($sql)->queryAll(); //yii 框架格式  
6.  
7. foreach ($data as $k => $v) {  
8.  
9. if ($k % 2 == 0) { //偶数发一个网址  
10.  
11. $send_data[$k]['url'] = '';  
12.  
13. $send_data[$k]['body'] = $v['waybill_id'];  
14.  
15. } else { //奇数发送另外一个网址  
16. $send_data[$k]['url'] = 'http://www.abc.com';  
17.  
18. $send_data[$k]['body']=array($v['order_id'] => array('extra' => 16));  
19.  
20. }  
21.  
22. }  
23.  
24. $back_data =sendMulitRequest($send_data);  
25.  
26. var_dump($back_data);  
27.  
28. }  
29. function sendMulitRequest($send_data){  
30. $params = array();  
31. $curl = $text = array();  
32. $handle = curl_multi_init();  
33.  
34. foreach ($data as $k => $v) {  
35.  
36. if (empty($v['url'])) {  
37.  
38. $v['url'] = "http://www.xxx.com"; //if url is empty,set defalut url  
39.  
40. }  
41.  
42. $reqBody = json_encode($v['body']);  
43.  
44. $reqStream = array(  
45.  
46. 'body' => $reqBody,  
47. );  
48. $encRequest = base64_encode(json_encode($reqStream));  
49. $params['data'] = $encRequest;  
50. $curl[$k] = curl_init();  
51. curl_setopt($curl[$k], CURLOPT_URL, $v['url']);  
52. curl_setopt($curl[$k], CURLOPT_POST, TRUE);  
53. curl_setopt($curl[$k], CURLOPT_HEADER, 0);  
54. curl_setopt($curl[$k], CURLOPT_POSTFIELDS, http_build_query($params));  
55. curl_setopt($curl[$k], CURLOPT_RETURNTRANSFER, 1);  
56. curl_multi_add_handle($handle, $curl[$k]);  
57. }  
58. $active = null;  
59.  
60. do {  
61.  
62. $mrc = curl_multi_exec($handle, $active);  
63.  
64. } while ($mrc == CURLM_CALL_MULTI_PERFORM);  
65. while ($active && $mrc == CURLM_OK) {  
66.  
67. if (curl_multi_select($handle) != -1) {  
68.  
69. do {  
70.  
71. $mrc = curl_multi_exec($handle, $active);  
72.  
73. } while ($mrc == CURLM_CALL_MULTI_PERFORM);  
74.  
75. }  
76.  
77. }  
78. foreach ($curl as $k => $v) {  
79. if (curl_error($curl[$k]) == "") {  
80. $text[$k] = (string) curl_multi_getcontent($curl[$k]);  
81. }  
82. curl_multi_remove_handle($handle, $curl[$k]);  
83. curl_close($curl[$k]);  
84. }  
85. curl_multi_close($handle);  
86. return $text;  
87. } 

2、通过stream_socket_client 方式

1. function sendStream() {  
2. $english_format_number = number_format($number, 4, '.', '');  
3.  
4. echo $english_format_number;  
5. exit();  
6. $timeout = 10;  
7. $result = array();  
8. $sockets = array();  
9. $convenient_read_block = 8192;  
10. $host = "test.local.com";  
11. $sql = "select waybill_id,order_id from xm_waybill where status>40 order by update_time desc limit 1 ";  
12. $data = Yii::app()->db->createCommand($sql)->queryAll();  
13. $id = 0;  
14.  
15. foreach ($data as $k => $v) {  
16. if ($k % 2 == 0) {  
17. $send_data[$k]['body'] = NoticeOrder::getSendData($v['waybill_id']);  
18.  
19. } else {  
20. $send_data[$k]['body'] = array($v['order_id'] => array('extra' => 16));  
21. }  
22. $data = json_encode($send_data[$k]['body']);  
23. $s = stream_socket_client($host . ":80", $errno, $errstr, $timeout, STREAM_CLIENT_ASYNC_CONNECT | STREAM_CLIENT_CONNECT);  
24. if ($s) {  
25. $sockets[$id++] = $s;  
26. $http_message = "GET /php/test.php?data=" . $data . " HTTP/1.0/r/nHost:" . $host . "/r/n/r/n";  
27. fwrite($s, $http_message);  
28. } else {  
29. echo "Stream " . $id . " failed to open correctly.";  
30. }  
31. }  
32.  
33. while (count($sockets)) {  
34.  
35. $read = $sockets;  
36.  
37. stream_select($read, $w = null, $e = null, $timeout);  
38. if (count($read)) {  
39. /* stream_select generally shuffles $read, so we need to  
40. compute from which socket(s) we're reading. */ 
41. foreach ($read as $r) {  
42.  
43. $id = array_search($r, $sockets);  
44. $data = fread($r, $convenient_read_block);  
45. if (strlen($data) == 0) {  
46. echo "Stream " . $id . " closes at " . date('h:i:s') . ".<br> ";  
47. fclose($r);  
48. unset($sockets[$id]);  
49. } else {  
50. $result[$id] = $data;  
51. }  
52. }  
53. } else {  
54. /* A time-out means that *all* streams have failed  
55. to receive a response. */ 
56. echo "Time-out!/n";  
57. break;  
58. }  
59. }  
60. print_r($result);  
61.  
62. } 

3、通过多进程代替多线程

1. function daemon($func_name,$args,$number){  
2. while(true){  
3. $pid=pcntl_fork();  
4. if($pid==-1){  
5. echo "fork process fail";  
6. exit();  
7. }elseif($pid){//创建的子进程  
8.  
9. static $num=0;  
10. $num++;  
11. if($num>=$number){  
12. //当进程数量达到一定数量时候，就对子进程进行回收。  
13. pcntl_wait($status);  
14.  
15. $num--;  
16. }  
17. }else{ //为0 则代表是子进程创建的，则直接进入工作状态  
18.  
19. if(function_exists($func_name)){  
20. while (true) {  
21. $ppid=posix_getpid();  
22. var_dump($ppid);  
23. call_user_func_array($func_name,$args);  
24. sleep(2);  
25. }  
26. }else{  
27. echo "function is not exists";  
28. }  
29. exit();  
30. }  
31. }  
32. }  
33. function worker($args){  
34. //do something  
35.  
36. }  
37. daemon('worker',array(1),2);  

以上就是为大家分享的三种php实现多线程类似的方法，希望对大家的学习有所帮助。