本篇文章給大家帶來的內容是關于swoole_process父子進程管道通信的代碼示例，有一定的參考價值，有需要的朋友可以參考一下，希望對你有所幫助。

話不多說直接上代碼

創建的子進程：

1. public function __construct() 
2.  
3.     { 
4.  
5.         $this->redis   = Container::get(SwooleRedis::class);//獲取異步redis獲取更高性能 
6.  
7.         $this->process = new swoole_process(function (swoole_process $process) { 
8.  
9.             return $this->process($process); 
10.  
11.         }, false, SOCK_DGRAM); 
12.  
13.         $this->process->name('Test_Gateway'); 
14.  
15.         $this->process->useQueue(); 
16.  
17.         $this->process->start();//啟動子進程 
18.  
19.     } 
20.  
21.       
22.  
23.     /** 
24.  
25.      * 子進程處理邏輯 
26.  
27.      * @param swoole_process $process 
28.  
29.      */ 
30.  
31.     private function process(swoole_process $process) 
32.  
33.     { 
34.  
35.         $client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC); //異步非阻塞 
36.  
37.           
38.  
39.         $client->on("connect", function (swoole_client $cli) use ($process) { 
40.  
41.             $process->write('connected'); 
42.  
43.         }); 
44.  
45.           
46.  
47.         $client->on("receive", function (swoole_client $cli, $data) use ($process) { 
48.  
49.             $process->write($data); 
50.  
51.         }); 
52.  
53.           
54.  
55.         $client->on("error", function (swoole_client $cli) use ($process) { 
56.  
57.             $process->write('error'); 
58.  
59.         }); 
60.  
61.           
62.  
63.         $client->on("close", function (swoole_client $cli) use ($process) { 
64.  
65.             $process->write('close'); 
66.  
67.         }); 
68.  
69.           
70.  
71.         if ($client->connect('127.0.0.1', 90, -1)) { 
72.  
73.           
74.  
75.         } else { 
76.  
77.             $process->write('網關連接失敗'); 
78.  
79.         } 
80.  
81.           
82.  
83.         swoole_event_add($process->pipe, 
84.  
85.             function ($pipe) use ($process, $client) {//讀取父進程管道消息 
86.  
87.                 $client->send($process->read()); 
88.  
89.             }); 
90.  
91.     } 

父進程onWorkerStart:

1. /** 
2.  
3.      * @param swoole_server $serv 
4.  
5.      * @param               $worker_id 
6.  
7.      */ 
8.  
9.     public function onWorkerStart(/swoole_server $serv, $worker_id) 
10.  
11.     { 
12.  
13.         if ($worker_id === 0) { 
14.  
15.             swoole_timer_tick(1000, function () { 
16.  
17.                 $this->process->write('ping'); 
18.  
19.             }); 
20.  
21.             $process = $this->process; 
22.  
23.             swoole_event_add($process->pipe, 
24.  
25.                 function ($pipe) use ($process) {//獲取子進程的管道消息 
26.  
27.                     echo "子進程消息：" . $process->read() . PHP_EOL; 
28.  
29.                 }); 
30.  
31.         } 
32.  
33.     } 

子進程的client客戶端可以忽略不計，本demo只是掩飾管道通信的例子

使用管道就不可以使用消息隊列：$process_push()和$process->pop();

理論上在父子進程各注冊一個event_loop即可實現一邊發消息一邊接收

其他的后續補充