PHP流

一.解释
       流的作用是提供统一的公共函数来处理文件、网络和数据压缩等操作。简单而言，流是具有流式行为的资源对象。流可以线性读写，并且可以通过fseek()之类的函数定位到流中的任何位置。简化一点，其实流的作用是在出发地和目的地之间传输数据。出发地和目的地可以是文件、命令行进程、网络连接、zip或tar压缩文件、临时内存、标准输入输出，或者是通过PHP流封装协议实现的任何其他资源。

       比如你读写了文件，其实就已经使用了流。流为PHP的很多IO函数提供了底层实现，如file_get_contents，fopen，fread，fwrite等等。PHP的流函数提供了不同资源的统一接口。
       我们可以把流比作管道，把水(资源数据)从一个地方引到另一个地方。从水的出发地到目的地的过程中，我们可以过滤水，可以改变水质，可以添加水，可以排出水。

二.流封装协议
       流式数据种类各异，每种类型需要独特的协议，以便数据读写，我们把这些协议称为流封装协议。
       每个流都有一个协议和一个目标。指定协议和目标的方法是使用流标识符：

        <scheme>://<target>
        <scheme>是流的封装协议，<target>是流的数据源

1.http://流封装协议

file_get_contents("http://www.google.com");

       以上是使用了http流封装协议创建了一个与google的通信http流，file_get_contents函数的字符串参数其实是一个流标识符。http协议会让PHP使用http流封装协议，在这个参数中，http之后就是流的目标。
注意：普通的URL其实是PHP流封装协议标识符的伪装。

2.file://流封装协议
       常用的fopen，fwrite，fclose等函数，使用的都是PHP流。PHP默认使用的流封装协议是file://。

$handle = fopen("file:///etc/hosts", "rb");

       通常会省略file://，因为这个是默认值。

3.php://流封装协议
       (1)php://stdin 只读PHP流，其中的数据来自标准输入。可使用它来接受命令行传入的数据。
       (2)php://stdout 把数据写入当前的缓冲区，只写。
       (3)php://input 访问请求的原始数据的只读流。当enctype="multipart/form-data"时，php://input无效。

4.更多数据流参考官网：http://php.net/manual/zh/wrappers.php.php

三.流上下文
       有些PHP流能接受一系列的可选参数，这些参数称为流上下文，用于指定流的行为。不同流封装协议使用的流上下文有所不同。流上下文使用stream_context_create()函数创建。

    stream_context_create ([ array $options [, array $params ]] ) : resource
    参数：
    options 必须是一个二维关联数组，格式如：$arr['wrapper']['option'] = $value
            默认是个空数组
    params 必须是$arr['parameter'] = $value格式的关联数组
    返回：
        上下文资源流，类型为resource
        For Example：
        $opts = array(
        'http' => array(
        'method' => 'GET',
        'header' => 'Accept-language:zh\r\n',
        ),
    );
    $context = stream_context_create($opts);
    $fp = file_get_contents("http://google.com", false, $context);
    流上下文是个关联数组，最外层是流封装协议的名称，不同流协议封装，流上下文数组中的值不同。

四.流过滤器
       PHP流真正强大的地方在于过滤、转换、添加或删除流中传输的数据。PHP所有可用的的流过滤器可参考官方文档：http://php.net/manual/zh/filters.php
       如果想把过滤器附加到现有的流上，要使用stream_filter_append()函数，下面以string.toupper过滤器为例子：

$handle = fopen("test.txt", "rb");
stream_filter_append($handle, "string.toupper");
while(feof($handle) !== true){
echo fget($handle);
}   
fclose($handle);

五.自定义流过滤器
       我们可以编写自定义的流过滤器。自定义的流过滤器是个PHP类，需要继承php_user_filter类，并且要实现filter()，onCreate()，onClose()方法，最后使用stream_filter_register()函数注册自定义的流过滤器。
       注：PHP流会把数据分成按次序排序的桶，一个桶盛放的流数据是固定的，如果还用管道比喻，就是把水放到一个个水桶内，顺着管道从出发地漂流到目的地，在漂流过程中会经过过滤器，过滤器一次可以处理一个或多个桶，一定时间内过滤器接收到的桶叫桶排序。桶队列中的每个桶对象有两个公共属性，data和datalen，表示桶的内容和长度。以下为一个例子:

/**
 * 脏词过滤器
 * 1.php自定义过滤器必须继承内置php_user_filter类
 * 2.必须实现filter方法
 * 3.必须使用stream_filter_register注册自定义过滤器
 */
class DirtyWordsFilter extends php_user_filter{
   /** 
    * @desc: 过滤方法
    * @param resource $in 流入的桶队列
    * @param resource $out 流出的桶队列
    * @param int &$consumed 处理的字节数
    * @param bool $closing 是否最后一个桶队列
    */
    public function filter($in, $out, &$consumed, $closing){
        $words = array('fuck', 'asshole', 'bitch');
        $wordData = array();
        foreach($words as $word){
            $replacement = array_fill(0, strlen($word), '*');
            $wordData[$word] = implode('', $replacement);
        }   
        $bad_word = array_keys($wordData);
        $replace_str = array_values($wordData);
        while($bucket = stream_bucket_make_writeable($in)){ //迭代每一个流入的桶
        $bucket->data = str_replace($bad_word, $replace_str, $bucket->data);//替换bad word
            $consumed += $bucket->datalen; //增加已处理的数据量
            stream_bucket_append($out, $bucket); //将该桶对象放入流向下游的队列   
        }   
        return PSFS_PASS_ON; //过滤器处理成功，输出流有可用数据返回 (PSFS_FEED_ME-过滤器处理成功，但没有数据返回; PSFS_ERR_FATAL-默认返回值，有错误，不返回
    }
}
stream_filter_register('dirty_words_filter', 'DirtyWordsFilter');//注册流过滤器
//TEST CODE
$handle = fopen('bad_word.txt', 'rb');
stream_filter_append($handle, 'dirty_words_filter');
while(feof($handle) !== true){
    echo fgets($handle);
}
fclose($handle);