阅读量:0
在 PHP EventSource 中，要实现消息的有序传递，可以使用以下方法：
使用队列（Queue）数据结构来存储和处理消息。这样可以确保消息按照先进先出（FIFO）的顺序被处理。你可以使用 PHP 的 SplQueue 类来实现队列。
在服务器端，当有新的消息到达时，将其添加到队列中。然后，使用一个循环来检查队列中是否有新的消息。如果有新消息，就将其发送给客户端。
在客户端，使用 JavaScript 监听服务器发送的消息。当收到新消息时，将其添加到一个显示区域，并确保它们按照接收顺序显示。
以下是一个简单的示例：
server.php:
<?php header('Content-Type: text/event-stream'); header('Cache-Control: no-cache'); // 创建一个队列来存储消息 $queue = new SplQueue(); // 模拟新消息的到达 for ($i = 1; $i <= 5; $i++) { $queue->enqueue("Message " . $i); sleep(1); } // 发送队列中的消息 while (!$queue->isEmpty()) { $message = $queue->dequeue(); echo "data: " . $message . "\n\n"; ob_flush(); flush(); sleep(1); } client.html:
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>EventSource Example</title> </head> <body> <ul id="messages"></ul> <script> const messages = document.getElementById('messages'); const source = new EventSource('server.php'); source.onmessage = function (event) { const message = event.data; const li = document.createElement('li'); li.textContent = message; messages.appendChild(li); }; </script> </body> </html> 在这个示例中，我们创建了一个队列来存储消息，并在 server.php 中模拟新消息的到达。然后，我们使用一个循环来检查队列中是否有新的消息，并将其发送给客户端。
在 client.html 中，我们使用 JavaScript 监听服务器发送的消息。当收到新消息时，我们将其添加到一个无序列表中，并确保它们按照接收顺序显示。
