服务器发送事件（SSE）：如何广播消息？

Question

我想要实现的是：

$.post('events.php', {'message': 'hello world'}, function(res) {
 
});

• user1向服务器发送消息（一个简单的POST请求）

服务器部分是（events.php）

<?php
header('Content-Type: text/event-stream');
header('Cache-Control: no-cache'); // recommended to prevent caching of event data.

function sendMsg($id, $msg) {
    echo "id: $id" . PHP_EOL;
    echo "data: $msg" . PHP_EOL;
    echo PHP_EOL;
    ob_flush();
    flush();
}

while(true) {
    $serverTime = time();
    if (isset($_POST['message'])) {
        sendMsg($serverTime, 'message: ' . date("h:i:s", time()));
        sleep(5);
    }
}

我在（true）时尝试了无限循环以避免3秒的轮询。我也尝试过没有那个无限循环。只有发送消息的用户收到事件。

我理解这种做法并不好。但是，将SSE用于聊天应用程序的最佳实践是什么？

如何向所有用户发送事件？

Answer 1

SSE是每个客户端的专用套接字和专用进程。

这意味着您的服务器端进程与浏览器客户端的选择基本相同：轮询或订阅。

由于您的数据库可能与SSE服务器进程位于同一服务器/局域网上，因此重复轮询的缺点与浏览器客户端不同。因此，要创建一个聊天应用程序，您可以定期轮询存储聊天消息的SQL数据库，以查看是否有新消息。

subscribe方法的一个示例是让每个SSE进程打开一个本地运行的聊天服务器专用套接字，每当新聊天消息到达时，该套接字将广播给这些SSE侦听器。