棘轮客户端消息

Question

我已经集成了使用棘轮的推杆。向所有用户广播工作正常。

现在我试图找到一种方式，当我得到它的连接时，如何向特定用户发送消息。

方法，该方法是在执行订阅：

public function onSubscribe(ConnectionInterface $conn, $topic) { 
    $conn->send(json_encode("Hello")); 
} 

JS在客户端：

var conn = new ab.Session('ws://127.0.0.1:8080', 
       function() { 
        conn.subscribe('chat', function(topic, data) { 
         console.log(data); // here I'd like to get that "Hello" message 
        }); 
       }, 
       function() { 
        console.warn('WebSocket connection closed'); 
       }, 
       {'skipSubprotocolCheck': true} 
     ); 

我没有得到任何消息，我想我还没有正确格式化它（json_encode（ “你好”））。任何帮助？

Answer 1

您需要以某种方式存储连接，然后直接调用它们。

例如：

$conns[$conn->resourceId] = $conn; 

再后来：

$conns[$resourceId]->write("new data"); 

至于为什么你没有收到关于订阅，请尝试write（）方法，而不是发送消息（）方法。

另外，检查控制台，看看你是否收到数据，但没有正确解包。