Swoole筆記（四）

yzd 發(fā)布于2019-06-28 13:28 / 706人閱讀

摘要：配合模塊，創(chuàng)建的子進(jìn)程可以異步的事件驅(qū)動模式。默認(rèn)為阻塞讀取。函數(shù)用于將一個加入到的事件監(jiān)聽中。為事件類型的掩碼，可選擇關(guān)閉開啟可讀可寫事件，如，，或者。在程序中使用，可以理解為在進(jìn)程中將此注冊到事件中。

Process

Process是swoole內(nèi)置的進(jìn)程管理模塊，用來替代PHP的pcntl擴展。

swoole_process支持重定向標(biāo)準(zhǔn)輸入和輸出，在子進(jìn)程內(nèi)echo不會打印屏幕，而是寫入管道，讀鍵盤輸入可以重定向為管道讀取數(shù)據(jù)。

配合swoole_event模塊，創(chuàng)建的PHP子進(jìn)程可以異步的事件驅(qū)動模式。

創(chuàng)建子進(jìn)程

函數(shù)原型：

int swoole_process::__construct(mixed $function, $redirect_stdin_stdout = false, $create_pipe = true);

$function，子進(jìn)程創(chuàng)建成功后要執(zhí)行的函數(shù)，底層會自動將函數(shù)保存到對象的callback屬性上。

如果希望更改執(zhí)行的函數(shù)，可賦值新的函數(shù)到對象的callback屬性。

$redirect_stdin_stdout，重定向子進(jìn)程的標(biāo)準(zhǔn)輸入和輸出。啟用此選項后，在進(jìn)程內(nèi)echo將不是打印屏幕，而是寫入到管道。讀取鍵盤輸入將變?yōu)閺墓艿乐凶x取數(shù)據(jù)。默認(rèn)為阻塞讀取。

$create_pipe，是否創(chuàng)建管道，啟用$redirect_stdin_stdout后，此選項將忽略用戶參數(shù)，強制為true 如果子進(jìn)程內(nèi)沒有進(jìn)程間通信，可以設(shè)置為false。

1.7.22或更高版本允許設(shè)置管道的類型，默認(rèn)為SOCK_STREAM流式
參數(shù)$create_pipe為2時，管道類型將設(shè)置為SOCK_DGRAM。

read();
        passthru($cmd);
    }    
}, true, 2);
$process->start();

$process->write("ls -l");//將參數(shù)傳入子進(jìn)程內(nèi)
echo $data = $process->read();//獲取執(zhí)行結(jié)果

實例：web版本的shell
https://github.com/52fhy/swoo...

EventLoop

swoole還提供了直接操作底層epoll/kqueue事件循環(huán)的接口。可將其他擴展創(chuàng)建的socket，PHP代碼中stream/socket擴展創(chuàng)建的socket等加入到Swoole的EventLoop中。

swoole_event_add函數(shù)用于將一個socket加入到swoole的reactor事件監(jiān)聽中。函數(shù)原型：

bool swoole_event_add(int $sock, mixed $read_callback, mixed $write_callback = null, int `$flags` = null);

$sock支持文件描述符、stream資源、sockets資源。

$read_callback為可讀回調(diào)函數(shù)。

$write_callback為可寫事件回調(diào)。

$flags為事件類型的掩碼，可選擇關(guān)閉/開啟可讀可寫事件，如SWOOLE_EVENT_READ，SWOOLE_EVENT_WRITE，或者SWOOLE_EVENT_READ | SWOOLE_EVENT_WRITE。

在Server程序中使用，可以理解為在worker/taskworker進(jìn)程中將此socket注冊到epoll事件中。

在Client程序中使用，可以理解為在客戶端進(jìn)程中將此socket注冊到epoll事件中。

示例：


對比一下，下面這個會阻塞進(jìn)程：

" ;
} else {
     fwrite ( $fp ,  "GET / HTTP/1.1
Host: www.52fhy.com

" );
    while (! feof ( $fp )) {
        echo  fgets ( $fp ,  1024 );
    }
     fclose ( $fp );
}

echo "Finish
";