如何区分不同服务器发送的事件监听器？

Question

我有一个应用程序，在该应用程序中，不同的用户监听服务器发送的事件源以获取定期响应。我打算从服务器发送具有相应 ID 和 json 格式数据的响应。在客户端，每个客户端在数据到达时检查匹配如果发现它处理数据，则忽略它。但是这种方法的缺陷是每个用户都从定期更新中获取数据，即使它不是为他们准备的。我读了几篇关于 sse 的文章，但找不到任何关于这个

我的问题是使用服务器端事件是否有任何方法可以向特定的侦听器发送响应，如果可以，如何.？

Answer 1

更新基于问题澄清：如何阻止客户端接收不适合它的 SSE 消息。

最好的方法是不发送。在服务器端过滤消息。 （正如我回答的前面部分所解释的，这很容易，因为每个 SSE 连接已经有一个专用服务器进程来决定向它发送哪些数据。）这种方法在所有方面都优越（CPU/内存、网络带宽、安全性、隐私、程序员工作量）。

另一种方法是在客户端过滤它，有两种方法可以做到这一点。一种是向客户端发送 json 数据。在您的 onMessage() 处理程序中，使用这些字段之一来确定此消息是否针对此客户端。

另一种是使用 SSE 的 event: 字段，然后监听该消息：

es = new EventSource(...);
es.addEventListener("forUser123", function(e) {
  //Process their data here
  }, false);

event:forUser123 标头将在您发送 data: 字段之前在服务器上设置。 （但是，如果您不得不麻烦添加一个额外的标头，最好在此时过滤您发送的消息。）

---

原答案

您想做的事情（特定于客户端）很容易，而您认为 Server-Sent-Events 的工作方式（广播）更难。

到您的服务器的每个EventSource 连接都是一个专用套接字。所以它就像任何其他与 Web 服务器的连接一样，唯一的区别是套接字没有关闭，而是保持打开状态，以便服务器可以继续发送数据。这也意味着服务器上有一个专用进程或线程来处理要发送到该客户端的消息。

因此，服务器知道每个用户是谁（假设他们通过会话 cookie 来标识自己），并且可以选择向该客户端发送哪些数据。

旁白：为什么广播更难？假设您有 100 个连接的 SSE 客户端 - 您实际上有 100 个独立的服务器进程在运行。要将单个消息广播给所有 100 个，您首先必须告诉这 100 个服务器端进程该消息是什么，以便它们可以传递它。您可以使用上游套接字执行此操作，或者他们可能会定期轮询“messagesToSendToEveryone”数据库表以查看是否添加了任何新内容。

Answer 2

我所做的是注册用户/询问用户登录并返回一个唯一的标识密钥。使用此密钥作为事件名称事件侦听器在注册/登录 $post(); 的回发成功函数中初始化。

所以基本上每个事件侦听器都会监听一个唯一的事件。在服务器端，每个事件名称都会被广播，然后是数据，因此唯一的事件侦听器会收到只为他们准备的消息。

客户端

$.post( "chatReg.php", { xxx: xxxx, time: xxx}).done(function( data ) {

     if((typeof(EventSource) !== "undefined")&&((localStorage.getItem("uname") !== null))) {
    var source = new EventSource("XXXXXXXX.php");   

    source.addEventListener(localStorage.getItem("uname"), function(e) {
     var data = JSON.parse(e.data);

     $('div.chat-box-content').append('<div class="msgWrapper"><div class="msgwrapperleft"><div class="iconright"><img src="http://placehold.it/40X40"></img></div><div class="MessageRight">'+data.Message+ '</div> </div><p class="ArrivedTimeRight"><span ><span class="timeago" >'+CreateTimestamp()+'</span></span></p></div>');

    }, false);


    } 

}

服务器

header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');
header('Connection: keep-alive');
header("refresh: 5;");

    echo  'event: '.$row['SpecialId'];
            echo PHP_EOL;

            echo  'data: {"Message":"'.$row['Message'].'","xxxId":"'.$row['xxxId'].'"}';
            echo PHP_EOL;
            echo PHP_EOL;