在 PHP EventSource 中處理客戶端連接,您需要?jiǎng)?chuàng)建一個(gè)長輪詢服務(wù)器,以便在客戶端與服務(wù)器之間實(shí)時(shí)傳輸數(shù)據(jù)
eventsource.php
的 PHP 文件。這將是您的服務(wù)器端代碼:<?php
header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');
header('Connection: keep-alive');
// 在這里添加您的業(yè)務(wù)邏輯,例如從數(shù)據(jù)庫獲取數(shù)據(jù)或其他操作
$data = array(
'message' => 'Hello from server!',
'time' => date('Y-m-d H:i:s')
);
echo "data: " . json_encode($data) . "\n\n";
flush();
// 設(shè)置一個(gè)延遲,以便客戶端可以不斷地請(qǐng)求更新
sleep(5);
?>
index.html
,并添加以下內(nèi)容:<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>EventSource Example</title>
</head>
<body>
<ul id="event-log"></ul>
<script>
// 創(chuàng)建一個(gè)新的 EventSource 對(duì)象,指向您的 eventsource.php 文件
var eventSource = new EventSource("eventsource.php");
// 當(dāng)服務(wù)器發(fā)送消息時(shí)觸發(fā)
eventSource.onmessage = function (event) {
var data = JSON.parse(event.data);
var listItem = document.createElement("li");
listItem.textContent = "Message: " + data.message + ", Time: " + data.time;
document.getElementById("event-log").appendChild(listItem);
};
// 當(dāng)連接打開時(shí)觸發(fā)
eventSource.onopen = function () {
console.log("Connection opened.");
};
// 當(dāng)連接關(guān)閉時(shí)觸發(fā)
eventSource.onerror = function (error) {
if (eventSource.readyState === EventSource.CLOSED) {
console.log("Connection closed.");
} else {
console.log("Error occurred:", error);
}
};
</script>
</body>
</html>
index.html
文件。您應(yīng)該會(huì)看到來自服務(wù)器的實(shí)時(shí)消息。注意:如果您在本地運(yùn)行此示例,請(qǐng)確保您的 Web 服務(wù)器支持 PHP。如果您使用的是諸如 XAMPP 之類的本地服務(wù)器解決方案,那么您應(yīng)該已經(jīng)具備所需的一切。如果您在線托管此示例,請(qǐng)確保您的托管提供商支持 PHP。