PHP 与 Ratchet Websockets 实时聊天

Question

我是 PHP Websockets 的初学者，我正在尝试使用数据库存储创建实时聊天。我做得很好，但现在我遇到了一个问题。有问题，当 user1 向 user2 发送消息并且 user2 首先访问该站点（首先在 localhoste 上重新加载）时，它不会 "real-time"。

让我再解释一下。

这是我的 server.php。它与棘轮教程几乎相同：

$loop = React\EventLoop\Factory::create();    
$pusher = new \Pusher();
$context = new React\ZMQ\Context($loop);
$pull = $context->getSocket(ZMQ::SOCKET_PULL);
$pull->bind('tcp://127.0.0.1:5555'); // Binding to 127.0.0.1 means the only client that can connect is itself
$pull->on('message', array($pusher, 'onBlogEntry'));
$webSock = new React\Socket\Server($loop);
$webSock->listen(8080, '0.0.0.0'); // Binding to 0.0.0.0 means remotes can connect
$webServer = new Ratchet\Server\IoServer(
        new Ratchet\Http\HttpServer(
        new Ratchet\WebSocket\WsServer(
        new Ratchet\Wamp\WampServer($pusher ))), $webSock);
$loop->run();

在pusher.php中最重要的是这些方法（我省略了其他不重要的东西）：

protected $subscribedTopics = array();
protected $myID = array();

public function onSubscribe(ConnectionInterface $conn, $data) { 
    $this->subscribedTopics[json_decode($data)->teamID] = $data;
    $this->myID[json_decode($data)->userID] = $data;    
}

public function onBlogEntry($entry) {
    $entryData = json_decode($entry, true);

    if ((!array_key_exists($entryData['team_id'], $this->subscribedTopics)) ||
            (!array_key_exists($entryData['to_user_id'], $this->myID))
    ) {
        return;
    }

    $teamID = $this->subscribedTopics[$entryData['team_id']];
    $teamID->broadcast($entryData);   
}

在我的 演示者中 Class 我有简单的形式。当用户提交此表单时，此代码如下：

$this->chatPartner = $values['to_user_id'];       //this I get from the form
$this->redrawControl('msg');                      //here I redraw my layout
$this->messages_model->addMessage($values);       //here I send data to database
$context = new \ZMQContext();
$socket = $context->getSocket(\ZMQ::SOCKET_PUSH, 'my pusher');
$socket->connect("tcp://localhost:5555");
$socket->send(json_encode($values));

然后，在 视图中 我有这个 JavaScript 代码：

var myJSON = '{'
            + '"teamID" : {$teamId},'     //this I get from the presenter
            + '"userID"  : {$userId}'     //this I get from the presenter
            + '}'; 
var conn = new ab.Session('ws://localhost:8080',
       function() {
            conn.subscribe(myJSON, function(topic, data) { 
             if (data.from_user_id == mypartnerIdA) {                     
                         //here I edit the DOM
                     }  
                });
            },
            function() {
                console.warn('WebSocket connection closed');
            },
            {'skipSubprotocolCheck': true}
    );

所以，回到我的问题。我模拟了 2 个用户。 User1 重新加载此页面，首先是 javascript 连接。用户 2 在他之后重新加载此页面。当 User1 向 user2 发送消息时，消息会立即（实时）显示。但是当 user2 向 user1 发送消息时，此消息不会立即出现 - 它只会在下次重新加载页面后出现。

我的问题是 - 如何解决这个问题？如何让 user2 的消息也实时？我该如何修复我的代码？

Answer 1

你可能对你最终订阅的数据是什么有误解。它旨在用于聊天会话的 ID。

例如：

A 与 B 聊天 (chatId = 1)
B 与 C 聊天 (chatId = 2)
C 与 A 聊天 (chatId = 3)

A、B、C 在一个聊天中 (chatId = 4)

var chatId = 2; //this chat is only between users B and C
conn.subscribe( chatId , function(topic, data) {
    ...
}

我理解它的最简单方法是将它与 Twitter 上的主题标签进行比较。在您的情况下，每个主题标签都是一个 chatId。并且每订阅一个hashtag/chatId。您将拥有一个 WebSocket 连接，以便您接收它的所有更新。

在长运行中，这将是一种更简单的方法，然后通过为 userId 参数细分连接。它还可以轻松地存储在数据库中，以便您知道将消息发送给谁以及不发送给谁。

PHP 与 Ratchet Websockets 实时聊天

PHP Real Time chat with Ratchet Websockets

php

websocket

wamp

zeromq

ratchet