版权声明:转载请注明来源 https://blog.csdn.net/u013702678/article/details/82927087
swoole_process提供的read方法用于从管道中读取数据,其使用刑形式如下。
function swoole_process->read(int $buffer_size=8192)
$buffer_size
是缓冲区的大小,默认为8192
,最大不超过64K
- 管道类型为
DGRAM
数据报时,read
可以读取完整的一个数据包 - 管道类型为
STREAM
时,read
是流式的,需要自行处理包完整性问题 - 读取成功返回二进制数据字符串,读取失败返回
false
。
下面我们分析下其流程。
static PHP_METHOD(swoole_process, read)
{
long buf_size = 8192;
//解析输入参数,这里输入参数就一个,即读取的数据大小
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|l", &buf_size) == FAILURE)
{
RETURN_FALSE;
}
if (buf_size > 65536)//最大不能超过65536byte
{
buf_size = 65536;
}
swWorker *process = swoole_get_object(getThis());//获取swoole内部封装对象swWorker
if (process->pipe == 0)//没有设置管道
{
swoole_php_fatal_error(E_WARNING, "no pipe, can not read from pipe.");
RETURN_FALSE;
}
char *buf = emalloc(buf_size + 1);//申请空间
int ret = read(process->pipe, buf, buf_size);;//直接从管道读取数据
if (ret < 0)//读取失败
{
efree(buf);
if (errno != EINTR)//不是被信号中断的情况
{
swoole_php_error(E_WARNING, "read() failed. Error: %s[%d]", strerror(errno), errno);
}
RETURN_FALSE;
}
buf[ret] = 0;//C字符串处理,读取了ret的数据量,申请空间ret之后的都不做处理
SW_ZVAL_STRINGL(return_value, buf, ret, 0);//返回读取到的字符串
#if PHP_MAJOR_VERSION >= 7
efree(buf);
#endif
}