• Process->read
    • 注意事项

    Process->read

    从管道中读取数据。

    1. function Process->read(int $buffer_size=8192) : string | bool;
    • $buffer_size是缓冲区的大小,默认为8192,最大不超过64K
    • 管道类型为DGRAM数据报时,read可以读取完整的一个数据包
    • 管道类型为STREAM时,read是流式的,需要自行处理包完整性问题
    • 读取成功返回二进制数据字符串,读取失败返回false
    这里是同步阻塞读取的,可以使用swoole_event_add将管道加入到事件循环中,变为异步模式

    示例:

    1. function callback_function_async(swoole_process $worker)
    2. {
    3. $GLOBALS['worker'] = $worker;
    4. swoole_event_add($worker->pipe, function($pipe) {
    5. $worker = $GLOBALS['worker'];
    6. $recv = $worker->read();
    7. echo "From Master: $recv\n";
    8. //send data to master
    9. $worker->write("hello master\n");
    10. sleep(2);
    11. $worker->exit(0);
    12. });
    13. }

    注意事项

    由于Swoole底层使用了epollLT模式,因此swoole_event_add添加的事件监听,在事件发生后回调函数中必须调用read方法读取socket中的数据,否则底层会持续触发事件回调。