如何获得特定用户的连接对象? [英] how to get the connection object of a specific user?

问题描述

我正在使用 Ratchet 库实时运行 Symfony 应用，在此应用中，我需要向特定用户发送一些数据，因此逻辑解决方案是使用 SessionProvider ，它将Symfony2 Session对象附加到每个传入的Connection对象. 根据文档说明，我已经设置了一个非本地会话处理程序以将我的会话存储在数据库中，即通过PDO存储在数据库中. 并暂时可以正常工作，但是我需要获取特定用户的Connection对象才能向他发送一些数据，因此以其他方式我需要找到引用该用户的连接对象，而我找不到方法它 ? 她是我的服务器代码:

I am working in a real time Symfony app using Ratchet library, in this app I need to send some data to a specific user so the logic solution was to use the SessionProvider that will attach a Symfony2 Session object to each incoming Connection object. As the documentation states I have setup a non-native session handler to store my sessions i.e. in a database via PDO. and that work fine for the moment but I need to get the Connection object of a specific user to send him some data so in other way I need to find the connection object that reference to this user and I can't find a way to do it ? her's my server code :

    $app=new AggregateApplication();
    $loop   = \React\EventLoop\Factory::create();
    $context = new \React\ZMQ\Context($loop);
    $pull = $context->getSocket(\ZMQ::SOCKET_PULL);
    $pull->bind('tcp://127.0.0.1:5555');
    $pull->on('message', array($app, 'onNotification'));
    $webSock = new \React\Socket\Server($loop);
    $webSock->listen(8080, '127.0.0.1');
    $handler = $this->getContainer()->get('session.handler');
    $server=new \Ratchet\Wamp\WampServer($app);
    $server = new SessionProvider($server, $handler);
    $webServer = new \Ratchet\Server\IoServer(new \Ratchet\WebSocket\WsServer($server),$webSock);
    $loop->run();

推荐答案

我自己有一个完全相同的问题(不包括Symfony)，这是我的工作.

I had the exact same question myself (minus Symfony) and here is what I did.

基于 hello world教程，我已将SplObjectStorage替换为数组.在介绍我的修改之前，我想评论一下，如果您通读了该教程并理解了它，那么使您自己无法获得此解决方案的唯一原因可能是不知道

Based on the hello world tutorial, I have substituted SplObjectStorage with an array. Before presenting my modifications, I'd like to comment that if you followed through that tutorial and understood it, the only thing that prevented you from arriving at this solution yourself is probably not knowing what SplObjectStorage is.

class Chat implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = array();
    }

    public function onOpen(ConnectionInterface $conn) {
        // Store the new connection to send messages to later
        $this->clients[$conn->resourceId] = $conn;
        echo "New connection! ({$conn->resourceId})\n";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        $numRecv = count($this->clients) - 1;
        echo sprintf('Connection %d sending message "%s" to %d other connection%s' . "\n"
            , $from->resourceId, $msg, $numRecv, $numRecv == 1 ? '' : 's');

        foreach ($this->clients as $key => $client) {
            if ($from !== $client) {
                // The sender is not the receiver, send to each client connected
                $client->send($msg);
            }
        }
        // Send a message to a known resourceId (in this example the sender)
        $client = $this->clients[$from->resourceId];
        $client->send("Message successfully sent to $numRecv users.");
    }

    public function onClose(ConnectionInterface $conn) {
        // The connection is closed, remove it, as we can no longer send it messages
        unset($this->clients[$conn->resourceId]);

        echo "Connection {$conn->resourceId} has disconnected\n";
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "An error has occurred: {$e->getMessage()}\n";

        $conn->close();
    }
}

当然，要使其真正有用，您可能还需要添加一个数据库连接，并存储/检索那些resourceId.

Of course to make it really useful you may also want to add in a DB connection, and store/retrieve those resourceIds.

这篇关于如何获得特定用户的连接对象?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！