Wie zum senden von Nachrichten an bestimmte Benutzer Ratchet PHP Websocket

Ich versuche, ein system zu erstellen, wo Benutzer abonnieren kann, um eine Kategorie, auf der Verbindung zum websocket-server und dann wird er beginnen die updates für die Kategorie. Bisher habe ich mich mit Ratsche und ich bin in der Lage, senden Sie die Nachricht an alle angeschlossenen clients, aber das problem ist, ich will nicht senden Sie die Nachricht an alle Klienten, die ich nur wollen, senden Sie die Nachricht an die clients, die sich angemeldet haben die Kategorie, in der die Nachrichten gesendet wurde.

PHP-Code

Chat.php

<?php
namespace MyApp;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class Chat implements MessageComponentInterface
{
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients->attach($conn);
    }

    public function onMessage(ConnectionInterface $conn, $msg)
    {
        foreach ($this->clients as $client)
        {
            if($conn !== $client)
                $client->send($msg);
        }
    }

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

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

server.php

<?php
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\Chat;

require dirname(__DIR__) . '/Ratchet/vendor/autoload.php';

$server = IoServer::factory(
  new HttpServer(
    new WsServer(
      new Chat()
    )
  ),
  8080
);

$server->run();
?>

Client-Seite in js-code

<script type="text/javascript">
var conn = new WebSocket('ws://localhost:8080');

conn.onopen = function(e) {
  console.log("Connection established!");
};

conn.onmessage = function(e) {
  console.log(e.data);
};
</script>

InformationsquelleAutor | 2015-06-20

Grundsätzlich, wenn Sie möchten, eine syntax für das senden von Daten an den WebSocket, ich empfehlen die Verwendung einer JSON-Objekt, dies zu tun. In Ihrem WebSocket-Klasse müssen Sie eine lokale variable namens subscriptions und eine lokale variable namens users so gerne.

<?php
namespace MyApp;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class Chat implements MessageComponentInterface
{
    protected $clients;
    private $subscriptions;
    private $users;

    public function __construct()
    {
        $this->clients = new \SplObjectStorage;
        $this->subscriptions = [];
        $this->users = [];
    }

    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients->attach($conn);
        $this->users[$conn->resourceId] = $conn;
    }

    public function onMessage(ConnectionInterface $conn, $msg)
    {
        $data = json_decode($msg);
        switch ($data->command) {
            case "subscribe":
                $this->subscriptions[$conn->resourceId] = $data->channel;
                break;
            case "message":
                if (isset($this->subscriptions[$conn->resourceId])) {
                    $target = $this->subscriptions[$conn->resourceId];
                    foreach ($this->subscriptions as $id=>$channel) {
                        if ($channel == $target && $id != $conn->resourceId) {
                            $this->users[$id]->send($data->message);
                        }
                    }
                }
        }
    }

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

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

Javascript, um mit zu gehen, die sieht ein bisschen aus wie diese

<script type="text/javascript">
var conn = new WebSocket('ws://localhost:8080');

conn.onopen = function(e) {
  console.log("Connection established!");
};

conn.onmessage = function(e) {
  console.log(e.data);
};

function subscribe(channel) {
    conn.send(JSON.stringify({command: "subscribe", channel: channel}));
}

function sendMessage(msg) {
    conn.send(JSON.stringify({command: "message", message: msg}));
}
</script>

Hinweis: Dieser code ist ungetestet, ich schrieb es auf die Fliegen aus meiner Erfahrung mit Ratsche. Viel Glück 🙂

Eigentlich brauche ich, um verwenden Sie die Ratsche-Knopf. Und ich habe das getan, alles ist in Ordnung, aber das problem ist jetzt, dass der client bekommt die Verbindung nach paar Minuten Leerlauf ohne disconnect-Nachricht Stoppt den Empfang von Nachricht. Wenn ich senden Unordnung an den client alle 10 Minuten es nicht trennen, aber Wenn es eine Lücke gibt, wie mehr als 20 Minuten oder so, der client erhält keine Nachricht.
was verwenden Sie, um die Verbindung zum websocket? Sind Sie proxyweiterleitung durch nginx oder was?
Ich bin mit Ratsche mit Pusher aus diesem Beispiel link

InformationsquelleAutor MarshallOfSound

//SOCKET VARIABLE DECLARATION
var mySocket;

//MESSAGE
const socketMessageListener = function(event) {
    var data = JSON.parse(event.data);
};

//OPEN SOCKET
const socketOpenListener = function(event) {
    console.log('Connected');
};

//CLOSE OR DISCONNECT SOCKET
const socketCloseListener = function(event) {
    if (mySocket) {
        console.error('Disconnected.');
    }
    mySocket = new WebSocket('ws://localhost:8080');
    mySocket.addEventListener('open', socketOpenListener);
    mySocket.addEventListener('message', socketMessageListener);
    mySocket.addEventListener('close', socketCloseListener);
};

//CALL THE LISTENER
socketCloseListener();

function sendMessage(data) {
    mySocket.send(JSON.stringify(data));
}

user3049006 fand ich diesen code in meine Forschung, um die Verbindung dauerhaft gespeichert, wenn Sie fehlschlagen, wiederholen Sie die Verbindung erneut.

InformationsquelleAutor Rodrigo Santana

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.