Websockets,并识别唯一的对等[PHP]

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地址有关的全局变量访问用户会话.也没有工作,导致所有帐户在同一个IP上收到消息(我在所有3个浏览器中测试localhost).

我尝试的最后一件事是第一种方法.我在开启事件上设置超时2秒,然后发送帐户消息.我终于能够在数据库中存储一个对等体了！但是,当我检查数据库时,我感到懊恼,它说(“资源ID#6).我尝试将$clients数组转换为全局,但每次都是空的.我google了一下,然后我尝试序列化数组.这一切工作直到我到达我发送消息给唯一同伴的部分.

这是发送消息的功能

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,我正在使用脸书HHVM,不相关,但我想提到它,因为它有一些怪癖,迫使我改变我的代码.