wie man das connection-Objekt für einen bestimmten Benutzer?

Arbeite ich in einer real-time - Symfony - app mit Ratsche Bibliothek, in dieser app brauche ich, um Daten zu senden zu einem bestimmten Benutzer, so die Logik, die Lösung war die Verwendung der SessionProvider, das wird befestigen, Symfony2 Session-Objekt für jede eingehende Verbindung-Objekt.
Wie die Dokumentation besagt, ich habe setup eine nicht-native session-handler zu speichern, meine Sitzungen, d.h. in einer Datenbank via PDO.
und dass die Arbeit gut für den moment, aber ich brauche, um das Connection-Objekt für einen bestimmten Benutzer zu senden, ihm einige Daten, die so in anderen Weg, ich muss die connection-Objekt, das eine Referenz zu diesem user und ich kann nicht einen Weg finden, es zu tun ?
Sie ist mein 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();

Aber wie das senden einer Nachricht an einen bestimmten Benutzer? Wie implementieren Sie diese in dem Beispiel von 2-clients eine Verbindung mit einem WebSocket-server, jeder mit seiner eigenen connection-Objekt :$ConnSender,$ConnReceiver? Bitte klären Sie mich ich nicht finden, eine Antwort auf diese auf ratchet tag SO.Dank
jedes mal, wenn ein Benutzer verbunden ist, um den websocket-server bekomme ich seine Id und ich seine speichern connection-Objekt in ein array, indiziert mit seiner Id, so dass, wenn ich will zu senden einige Daten auf dem client bekomme ich nur seine connection-Objekt über seine Id und ich schicke meine Daten.
Ich verstehe, was du meinst, aber bitte lassen Sie mich hinzufügen, eine andere Frage, denn es ist nicht klar für mich. Wenn ich mein array mit zwei connection-Objekte mit zwei verschiedenen IDs (Id1 von sender-und Id2-Empfänger), wie wird der WebSocket-server bekommen, Id2, ihn zu senden der Nachricht? $client = $this->clients[$Id2];$client->send("Message");
Durch die Verwendung von symfony, können Sie die Kommunikation zwischen Ihnen wieder symfony-app und der websocket-server mit ZMQ also, wenn Sie wan ' T senden einer Nachricht an client client1 $context = new ZMQContext(); $socket = $context->getSocket(ZMQ::SOCKET_PUSH, 'myPusher'); $socket->connect("tcp://localhost:5555"); $entryData="{'id':'1','Daten':'einige Daten zu senden'}" $socket->senden(Funktionen json_encode($entryData));
Danke Anas. Und ich bin sehr Leid für die Umsetzung mehr newbie-Fragen hier. Wenn ich Sie gut verstehe, sollte ich auch die Karte user_id zu resourceId irgendwo (vielleicht in einer db-Tabelle). bin ich im Recht? die Indizierung der Arrays mit ResourceId ist nicht genug. Ich möchte in der Lage sein, um eine Nachricht zu senden Id2, ohne mit ZeroQM (da ich keine Interaktion mit den App-Skript, das ich verwenden werden entity-manager-Dienst in meinem Chat Klasse zu bestehen-Nachrichten). Sollte ich unbedingt vorbei stackoverflow.com/questions/17558657/...?
Definitiv es ist nicht nötig, aber was es empfohlen wird, alle Daten, die Sie senden, vom client zum server gemacht werden müssen, die mit ajax in einer http-Anforderung, die Sie verwenden sollten ZMQ zu sagen webSocketServer zu senden, die gleichen Daten auf einem anderen client mit webSockets, weil es eine Frage der Sicherheit, wenn Sie Händel-Daten in Sie re websocket-server. und auch wenn du den thread in dem link, den Sie weitergeben, indem Sie die re app-code in den thread
Aaah! vielen Dank für diese Zusatzinformationen. Ich sehe jetzt. Vom client zum server, ich schicke AJAX-call mit sender_id, receiver_id und message. Mit ZeroQM, schicke ich das ganze Zeug zum Websocket-server. dann in meinem Chat der Klasse, rufe ich die Verbindung von receiver_id aus clients array und senden Sie ihm die Nachricht.
Genau das war meine Lösung.
ich danke Ihnen sehr, sir, für Ihre Erfahrungen, gerade in diesem Teil des PHP-Programmierung, die wirklich fehlt, einfache und klare doc ( in der Betrachtung der newbs).
Anas, bitte ich umgesetzt, 90 Prozent von dem, was wir diskutiert haben, ich brauche nur Ihre Hilfe für den verbleibenden Teil stackoverflow.com/questions/29576033/.... nochmals vielen Dank
Ich habe geschrieben, eine Antwort hoffe, die helfen.

InformationsquelleAutor elkorchi anas | 2013-07-11

Ich hatte das exakt gleiche Frage, die ich mir (minus Symfony) und hier ist was ich getan habe.

Basiert auf der Hallo Welt tutorial, habe ich ersetzt SplObjectStorage mit einem array. Vor der Darstellung meiner änderungen, würde ich mag zu kommentieren, dass, wenn Sie gefolgt durch das tutorial und es so verstanden, das einzige, was verhindert, dass Sie von der Ankunft in dieser Lösung selbst ist wohl nicht zu wissen, was SplObjectStorage ist.

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();
    }
}

Natürlich machen es wirklich nützlich, Sie können auch hinzufügen möchten, in eine DB-Verbindung, und speichern/abrufen dieser resourceIds.

Denkt, ich habe bereits diese Lösung, aber ich Frage mich nur, warum in der offiziellen doc Rachet Sie haben zu sprechen, die wir brauchen, um zu befestigen, jedes connection-Objekt, um eine symfony-Sitzung mittels session-handler... Wenn wir können dies tun, einfach mit der sqlObjectStorage und Ids der clients?
Ich denke, Sie meinen das: "geben Sie nur-lese-Zugriff auf die session-Daten von Ihrer website."
Was ist, wenn ich die resourceIds selbst ? Hier ist, was ich Tue: wenn ich eine Verbindung aufzubauen, habe ich sofort eine Nachricht senden, dass die eigentliche id des Benutzers (nicht sein resourceId, ich spreche hier über die id, die ich verwenden zum abrufen des Benutzers Vorname, Nachname, etc), und dann nach Erhalt der Nachricht, dass ich den Benutzer ändern, ist resourceId die id, die ich mit der Nachricht gesendet, und dann wenn ich senden möchten, dass Benutzer eine Nachricht, ich im Grunde eine Schleife durch die spl Speicher und wenn ich ein match mit seiner id, schicke ich ihm die Nachricht. Sollte ich dies tun? Ist es sicher zu ersetzen, resourceIds ?

InformationsquelleAutor Scott Yang

dies ist, was ich Tat, hat einige Verbesserungen auf der gleichen Idee.

fügt 2 Funktionen, die Sie aufrufen können anderswo: send_to() und multicast().

namespace mine;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class ws implements MessageComponentInterface {
    protected $clients;
    protected $clientids;

    public function __construct() {
        $this->clients = new \SplObjectStorage; 
        $this->clientids = array();
    }

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

    public function send_to($to,$msg) {
        if (array_key_exists($to, $this->clientids)) $this->clientids[$to]->send($msg);
    }

    public function onOpen(ConnectionInterface $conn) {
        $socket_name = "{$conn->resourceId}@{$conn->WebSocket->request->getHeader('X-Forwarded-For')}";
        $this->clients->attach($conn,$socket_name);
        $this->clientids[$socket_name] = $conn;
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        $this->multicast($msg);
    }

    public function onClose(ConnectionInterface $conn) {
        unset($this->clientids[$this->clients[$conn]]);
        $this->clients->detach($conn);
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        $conn->close();
    }
}

InformationsquelleAutor Smellymoo

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.