sse的完整实现php,PHP+SSE实现消息推送

SSE(server-sent event)是基于HTML5的服务器推送消息事件，它允许服务端单向向浏览器客户端发送数据，SSE使用流信息向浏览器推送信息，浏览器自动接收服务端推送过来的消息，它是基于HTTP协议。

客户端

新建一个html页面在script中添加代码

if(typeof(EventSource) !== "undefined") {

var source = new EventSource("sse.php");

//监听test事件

source.addEventListener('test', function (event) {

console.log(event.data)

});

} else {

alert("您的浏览器不支持SSE");

}

服务端

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;

}