我是 websockets 的新手。我刚刚完成了我的第一个多用途套接字服务器，它在同一个套接字中提供 3 种类型的消息。此服务器的预期用途如下:

chat messages

real time market data

user specific alerts

前两个功能运行良好，我非常高兴，但是在识别和链接特定帐户连接中的对等点时，我完全不知所措，以便我可以向特定用户提供待处理的警报通知。

基本上，我将警报消息存储在数据库表中，如下所示:

Table: uc_notifications

account(varchar50) | message(varchar255) | id(primary,AI) | seen(default 0)

我想像这样将对等点存储在一个表中:

uc_notification_peers
account(varchar50) | peer_id(unique,varchar100) | id(primary,AI)

基本上，我遇到的问题是将对等方的信息存储在数据库中，然后检索它，这样我就可以在读取通知表时将消息发送给选定的对等方。脚本中的其他所有内容均有效。

我尝试的第一件事是使用 onopen 将帐户名传递给 websocket。这会使 websocket 崩溃。

接下来我尝试的是通过与 IP 地址相关的全局变量访问用户 session 。也不起作用，导致所有帐户都在同一 ip 上收到消息(我在所有 3 个浏览器的本地主机上进行测试)。

我最后尝试的是第一种方法。我在打开事件上设置了 2 秒的超时，然后发送了帐户消息。我终于能够在数据库中存储一个对等体!但是，令我懊恼的是，当我检查数据库时，它说(“资源 ID#6”)。我尝试将 $clients 数组转换为全局变量，但每次都是空的。我在谷歌上搜索了一下，然后我尝试序列化数组。这一切一直工作到我将消息发送给唯一对等方为止。

这里是发送消息的函数

function send_message_single_client($msg,$client) 
{
    @socket_write($client,$msg,strlen($msg));
    return true;
}

这是我使用此功能将最后 100 条消息推送到新同伴的聊天框的示例。

if (in_array($socket, $changed)) {
        $socket_new = socket_accept($socket);
        $clients[] = $socket_new;
        $header = socket_read($socket_new, 1024);
        perform_handshaking($header, $socket_new, $host, $port);
        socket_getpeername($socket_new, $ip);
        $found_socket = array_search($socket, $changed);
        //need to push last 100 messages to new peer.
        $query = $mysqli->query("SELECT * FROM (SELECT * FROM uc_chat_msg WHERE `hidden`='0' ORDER BY `id` DESC LIMIT 100) as last100 ORDER BY id");
        while($row = $query->fetch_assoc()) {
            $response_text = mask(json_encode(array('type'=>'usermsg', 'name'=>security($row["username"]), 'message'=>security($row["message"]), 'color'=>security($row["color"]))));
            send_message_single_client($response_text, $socket_new);//send old messages to the new client
        }
        $query->close();
        unset($changed[$found_socket]);
    }

那是几周前的事了，我把这个项目搁置一旁，这样我就可以继续前进并专注于其他事情。从那以后，我已经转向开发 vps 以适应应用程序不断增长的规模/复杂性。而不是 php，我使用的是 facebooks HHVM，不相关但我想我会提到它，因为它有一些怪癖迫使我稍微改变我的代码。

最佳答案

我不了解 PHP，但我认为这更像是一个方法问题，而不是编码问题。因此，我希望从我的推送架构经验中得出的这些想法能带来一些启示。

识别用户

通过 cookie 识别:

WebSockets 使用 HTTP 握手来发送该来源的 cookie。您可以将一个临时 ID(例如:GUID)附加到一个特殊的 session cookie，每次用户在同一 session 中重新连接时都会重新发送该 cookie。只要您遵守同源政策，您就可以从网站或在 HTTP 握手响应本身中部署 cookie。

通过给 token 识别:

当 WebSocket 连接时，您可以从服务器发送一 strip 有包含临时 ID 的 token 的初始消息。如果连接断开，可以在重新连接时重新发送该 token ，但如果用户重新加载页面，它将被遗忘，除非它保存在本地存储或任何其他类型的浏览器存储中。

关于临时ID的注意事项

临时 ID 如何映射到特定用户或帐户，是您不希望泄露到网络的实现细节。所以不要使用该信息来识别您的 WS 连接。

您应该保留一个“ session ”注册表，将临时 ID 映射到帐户，可能从内存中的字典映射到数据库中的表。由您决定，您的要求和服务。此元素必须保留对 WebSocket 连接的引用，以便您可以在需要时通过临时 ID 检索它。

切勿泄露内部详细信息，特别是帐户 ID(因为它们不会更改)。

接收消息

从 WebSocket 接收消息时，您必须创建一个消息对象，其中包含使用您保留的“ session ”信息的发件人帐户以及实际的消息内容。然后，将此消息对象传递给将决定要做什么的业务逻辑。

发送消息之前

为了发送消息，您必须首先定义几个元素:

存在感:

哪些帐户在线？将您的“ session ”存储与帐户表合并。当连接断开时，您应该删除断开的用户 session 。

属于:

哪些账户属于特定的组或信号？您必须根据您的要求进行设计。一些组可以预定义并在“帐户”实体中指示，其他一些可能是动态的，例如他属于聊天室。无论如何，您需要另一个将“组”映射到“帐户”的元素

发送消息

当您的业务逻辑决定要发送一条消息时，无论是作为对传入消息的响应、作为定时操作、主动性还是其他……它必须决定必须发送到哪个用户帐户、用户帐户或用户组已发送。

然后，使用您保留的 session 信息，收集必须接收该消息的临时 ID 列表，然后是该消息必须转发到的 WebSockets 列表，最后将消息发送到该消息的每个 WS列表。

关于php - Websockets，并识别独特的同行[PHP]，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/23101377/