Ratchet PHP Websockets：私人消息传递（控制消息发送给谁）

Question

还有一个问题。 我开始习惯 websocket 的工作方式。 我什至设法实现了跨域通信。 但现在我还没有达到另一个里程碑。

这是我当前实现的一个 sn-p

 public function onMessage(ConnectionInterface $conn, $msg)
{
     $msgjson = json_decode($msg);
     $tag = $msgjson->tag;
     global $users; 

     if($tag == "[msgsend]")
     {

            foreach($this->clients as $client)
            {
                  $client->send($msg);    
            }
     }
     else if($tag == "[bye]")
     {

         foreach($this->clients as $client)
         {
              $client->send($msg);    
         }

         foreach($users as $key => $user)
         {
             if($user->name == $msgjson->uname)
             {
                unset($users[$key]); 
             }
         }

         $this->clients->detach($conn);
     }
     else if($tag == "[connected]")
     {
         //store client information
         $temp = new Users();
         $temp->name = $msgjson->uname;
         $temp->connection = $conn;
         $temp->timestamp = new \DateTime();



         $users[] = $temp;





          usort($users, array($this, "cmp"));


         //send out messages
          foreach($this->clients as $client)
         {
              $client->send($msg);    
         }           

     }
     else if($tag == "[imalive]")
     {
         //update user timestamp who sent [imalive]
         global $users;

          foreach($users as $user)
             {
                if($msgjson->uname == $user->name)
                {
                        $user->timestamp = new \DateTime(); 
                }
             }

     }   

}

现在我的问题是。正如我们所看到的，在 onMessage() 函数和我做过的教程中，我知道如何读取和解析 JSON 数据，理解消息，知道消息来自谁（$conn）......

但是，当我在 JSON 数据包中发送消息时，我想包括消息来自谁的昵称以及消息将要发送给谁。 这将允许我在我正在构建的社交网络和聊天室中实现私人即时消息传递。

我只想向特定的客户端发送消息，而不是使用 for 循环向所有连接的客户端发送消息。我知道客户有一个属性（$this->$client->resourceID 或类似的东西），但也不知道如何将它合并为解决方案。我还希望用户在跳转到网站上的不同页面时保持连接，即使在刷新后，仍然能够继续发送消息。我假设每次刷新都会断开客户端的连接。所以我必须有一种方法，让服务器每次都能知道谁是谁，消息来自哪里以及它们要去哪里。

但是，是的，私人消息。我不想向所有人或非预期目标发送不必要的信息。我怎样才能做到这一点？ 我希望我的问题是有道理的。谢谢。

Answer 1

能够唯一标识连接到您的 WebSocket 服务器的用户，然后能够定位这些用户，特别是在发送消息时需要从实际与服务器协商连接的 onOpen 回调开始。

在您的onOpen 方法中，您应该有某种方法通过全局存储在您的数据库或持久性存储中的某个用户ID 来唯一地识别系统上的用户。由于连接是通过 HTTP 协商的，因此您可以通过 $conn->WebSocket->request 访问 HTTP 请求，这是一个包含客户端 HTTP 请求信息的 GuzzleHttp 对象。例如，您可以使用它来提取一个 cookie，其中包含一些用户 ID 数据或令牌，您可以将其与数据库进行比较以确定用户是谁，然后将其存储为 $client 对象的属性。

现在，让我们假设您正在编写一个普通的 PHP 脚本，您在其中通过 HTTP 进行用户身份验证并将用户 ID 存储在会话中。此会话在客户端机器上设置一个包含会话 ID 的 cookie（默认情况下，cookie 名称是会话名称，通常为 PHPSESSID，除非您更改它）。这个 session id 可以在你的 WebSocket 服务器中使用来访问 session 存储，就像在 PHP 中一样。

这是一个简单的例子，我们期望请求中的一个名为 PHPSESSID 的 cookie 从 cookie 中捕获会话 id。

public function onOpen(ConnectionInterface $conn) {
    // extract the cookie header from the HTTP request as a string
    $cookies = (string) $conn->WebSocket->request->getHeader('Cookie');
    // look at each cookie to find the one you expect
    $cookies = array_map('trim', explode(';', $cookies));
    $sessionId = null;
    foreach($cookies as $cookie) {
        // If the string is empty keep going
        if (!strlen($cookie)) {
            continue;
        }
        // Otherwise, let's get the cookie name and value
        list($cookieName, $cookieValue) = explode('=', $cookie, 2) + [null, null];
        // If either are empty, something went wrong, we'll fail silently here
        if (!strlen($cookieName) || !strlen($cookieValue)) {
            continue;
        }
        // If it's not the cookie we're looking for keep going
        if ($cookieName !== "PHPSESSID") {
            continue;
        }
        // If we've gotten this far we have the session id
        $sessionId = urldecode($cookieValue);
        break;
    }
    // If we got here and $sessionId is still null, then the user isn't logged in
    if (!$sessionId) {
        return $conn->close(); // close the connection - no session!
    }
}

现在您实际上拥有$sessionId，您可以使用它来访问该会话的会话存储，将会话信息拉入您的WebSocket 服务器并将其存储为客户端连接对象$conn 的属性。

因此，继续上面的示例，让我们将此代码添加到 onOpen 方法中。

public function onOpen(ConnectionInterface $conn) {
    $conn->session = $this->methodToGetSessionData($sessionId);
    // now you have access to things in the session
    $this->clinets[] = $conn;
}

现在，让我们回到您希望专门向一位用户发送消息的示例。假设我们在会话中存储了以下属性，现在可以从客户端连接对象访问这些属性...

$conn->session->userName = 'Bob';
$conn->session->userId   = 1;

假设 Bob 想向 Jane 发送消息。一个请求进入您的 WS 服务器，带有类似 {"from":1,"to":2,tag:"[msgsend]"} 的内容，其中该 JSON 的 to 和 from 属性基本上是消息来自 的用户的用户 ID，而用户是消息旨在分别发送到。对于这个例子，我们假设 Jane 是 userId = 2。

public function onMessage(ConnectionInterface $conn, $msg) {
    $msgjson = json_decode($msg);
    $tag = $msgjson->tag;
    if ($tag == '[msgsend]') {
        foreach($this->clients as $client) {
            // only send to the designated recipient user id
            if ($msgjson->to == $client->session->userId) {
                $client->send($msg);    
            }
        }
    }
}

显然，您可能希望在其中进行更详细的验证，但您应该能够从这里对此进行扩展。