Process->write
向管道内写入数据。
int Process->write(string $data);
$data
的长度在Linux
系统下最大不超过8K
,MacOS/FreeBSD
下最大不超过2K
- 在子进程内调用
write
,父进程可以调用read
接收此数据 - 在父进程内调用
write
,子进程可以调用read
接收此数据Swoole
底层使用Unix Socket
实现通信,Unix Socket
是内核实现的全内存通信,无任何IO消耗。在1进程write,1进程read,每次读写1024
字节数据的测试中,100
万次通信仅需1.02
秒。
管道通信默认的方式是流式,write
写入的数据在read
可能会被底层合并。可以设置swoole_process
构造函数的第三个参数为2
改变为数据报式。
MacOS/FreeBSD可以设置net.local.dgram.maxdgram
内核参数修改最大长度
异步模式
如果进程内使用了异步IO,比如swoole_event_add
,进程内执行write操作将变为异步模式。swoole底层会监听可写事件,自动完成管道写入。
异步模式下如果SOCKET缓存区已满,Swoole的处理逻辑请参考 swoole_event_write
同步模式
进程内未使用任何异步IO,当前管道为同步阻塞模式,如果缓存区已满,将阻塞等待直到write操作完成。
- Task进程就是同步阻塞的模式,如果管道的缓存区已满,调用
write
时会发生阻塞
乱序丢包
很多网络文章提到DGRAM
模式下会出现丢包、乱序问题,实际上这些问题仅存在于Internet
网络的UDP
通信。UnixSocket
是Linux内核实现的内存数据队列,不会出现丢包乱序问题。write
写入和read
读取的顺序是完全一致的。write
返回成功后一定是可以read
到的。