1、php服务端代码
<?php
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()来发送到浏览器了
while(1) {
$time = date('Y-m-d H:i:s');
$c = "retry:1000" . PHP_EOL; //重试毫秒数
$c = "event:my_test_message" . PHP_EOL; //定义事件
$c .= "data: The server time is: {$time}" . PHP_EOL; //推送内容
echo $c . PHP_EOL;
sleep(3);
}
2、客户端代码
<body id="result">
</body>
<script>
var source = new EventSource("sse.php");
source.addEventListener(' message ', function (event) {
console.log(event)
})
source.addEventListener('my_test_message', function(event) { //自定义事件回调
console.log(event)
})
</script>
