如何在php eventsource中處理客戶端連接

PHP
小樊
90
2024-08-27 17:21:13
欄目: 編程語言

在 PHP EventSource 中處理客戶端連接,您需要?jiǎng)?chuàng)建一個(gè)長輪詢服務(wù)器,以便在客戶端與服務(wù)器之間實(shí)時(shí)傳輸數(shù)據(jù)

  1. 首先,創(chuàng)建一個(gè)名為 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);
?>
  1. 然后,創(chuàng)建一個(gè) HTML 文件,例如 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>
  1. 將這兩個(gè)文件放在 Web 服務(wù)器上(例如 Apache 或 Nginx),并通過瀏覽器訪問 index.html 文件。您應(yīng)該會(huì)看到來自服務(wù)器的實(shí)時(shí)消息。

注意:如果您在本地運(yùn)行此示例,請(qǐng)確保您的 Web 服務(wù)器支持 PHP。如果您使用的是諸如 XAMPP 之類的本地服務(wù)器解決方案,那么您應(yīng)該已經(jīng)具備所需的一切。如果您在線托管此示例,請(qǐng)確保您的托管提供商支持 PHP。

0