PHP+SSE实现消息推送

SSE(server-sent event)是基于HTML5的服务器推送消息事件,它允许服务端单向向浏览器客户端发送数据,SSE使用流信息向浏览器推送信息,浏览器自动接收服务端推送过来的消息,它是基于HTTP协议。
客户端
新建一个html页面在script中添加代码

<script>
    if(typeof(EventSource) !== "undefined") {
        var source = new EventSource("sse.php");
        //监听test事件
        source.addEventListener('test', function (event) {
            console.log(event.data)
        });
    } else {
        alert("您的浏览器不支持SSE");
    }
</script>

服务端

        header('X-Accel-Buffering: no');
        header('Content-Type: text/event-stream');
        header('Cache-Control: no-cache');

        set_time_limit(0); //防止超时
        ob_end_clean(); //清空(擦除)缓冲区并关闭输出缓冲
        ob_implicit_flush(1); //这个函数强制每当有输出的时候,即刻把输出发送到浏览器。这样就不需要每次输出(echo)后,都用flush()来发送到浏览器了
        //从redis中取出消息
        $res = redis()->rpop('test');
        if($res) {
            $c = "event:test" . PHP_EOL; //定义事件
            $c .= "data: $res" . PHP_EOL; //推送内容
            echo $c . PHP_EOL;
        }else {  //没消息时也得有个输出 不能会报错
            echo 1;
        }
  
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。