Swoole笔记(四)

@date:2017-08-19 10:30:00

Process #

Process是swoole内置的进程管理模块,用来替代PHP的pcntl扩展。

swoole_process支持重定向标准输入和输出,在子进程内echo不会打印屏幕,而是写入管道,读键盘输入可以重定向为管道读取数据。

配合swoole_event模块,创建的PHP子进程可以异步的事件驱动模式。

创建子进程 #

函数原型:

int swoole_process::__construct(mixed $function, $redirect_stdin_stdout = false, $create_pipe = true);
  • $function,子进程创建成功后要执行的函数,底层会自动将函数保存到对象的callback属性上。
  • 如果希望更改执行的函数,可赋值新的函数到对象的callback属性。
  • $redirect_stdin_stdout,重定向子进程的标准输入和输出。启用此选项后,在进程内echo将不是打印屏幕,而是写入到管道。读取键盘输入将变为从管道中读取数据。默认为阻塞读取。
  • $create_pipe,是否创建管道,启用$redirect_stdin_stdout后,此选项将忽略用户参数,强制为true 如果子进程内没有进程间通信,可以设置为false。
  • 1.7.22或更高版本允许设置管道的类型,默认为SOCK_STREAM流式
    参数$create_pipe为2时,管道类型将设置为SOCK_DGRAM
<?php
$process = new swoole_process(function(swoole_process $worker){
	while (true){
        $cmd = $worker->read();
        passthru($cmd);
    }	
}, true, 2);
$process->start();

$process->write('ls -l');//将参数传入子进程内
echo $data = $process->read();//获取执行结果

实例:web版本的shell
https://github.com/52fhy/swoole_demo/blob/master/swoole_shell_server.php

EventLoop #

swoole还提供了直接操作底层epoll/kqueue事件循环的接口。可将其他扩展创建的socket,PHP代码中stream/socket扩展创建的socket等加入到Swoole的EventLoop中。

swoole_event_add函数用于将一个socket加入到swoole的reactor事件监听中。 函数原型:

bool swoole_event_add(int $sock, mixed $read_callback, mixed $write_callback = null, int `$flags` = null);
  • $sock支持文件描述符、stream资源、sockets资源。
  • $read_callback为可读回调函数。
  • $write_callback为可写事件回调。
  • $flags为事件类型的掩码,可选择关闭/开启可读可写事件,如SWOOLE_EVENT_READSWOOLE_EVENT_WRITE,或者SWOOLE_EVENT_READ | SWOOLE_EVENT_WRITE

在Server程序中使用,可以理解为在worker/taskworker进程中将此socket注册到epoll事件中。

在Client程序中使用,可以理解为在客户端进程中将此socket注册到epoll事件中。

示例:

<?php
$fp = stream_socket_client("tcp://www.52fhy.com:80", $errno, $errstr, 30);
fwrite($fp, "GET / HTTP/1.1\r\nHost: www.52fhy.com\r\n\r\n");

swoole_event_add($fp, function($fp) {

    echo $resp = fread($fp, 1024);
    //socket处理完成后,从epoll事件中移除socket
    swoole_event_del($fp);
    fclose($fp);
});
echo "Finish\n";  //swoole_event_add不会阻塞进程,这行代码会顺序执行

对比一下,下面这个会阻塞进程:

<?php
$fp  =  stream_socket_client ( "tcp://www.52fhy.com:80" ,  $errno ,  $errstr ,  30 );
if (! $fp ) {
    echo  " $errstr  ( $errno )<br />\n" ;
} else {
     fwrite ( $fp ,  "GET / HTTP/1.1\r\nHost: www.52fhy.com\r\n\r\n" );
    while (! feof ( $fp )) {
        echo  fgets ( $fp ,  1024 );
    }
     fclose ( $fp );
}

echo "Finish\n";
Build by Loppo 0.6.14