Comment envoyer des messages à des utilisateurs en particulier à Cliquet PHP Websocket

Je suis en train de construire un système où l'utilisateur peut s'abonner à une catégorie à l'établissement de la connexion serveur websocket et puis il va commencer à recevoir des mises à jour pour cette catégorie. Jusqu'à présent, j'ai travaillé avec Ratchet et je suis en mesure d'envoyer un message à tous les clients connectés, mais le problème est que je ne veux pas envoyer le message à tous les clients que je veux juste envoyer le message aux clients qui ont souscrit à la à la catégorie particulière dans laquelle les messages ont été envoyés.

Code PHP

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

Côté Client code js

<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>

OriginalL'auteur | 2015-06-20

Fondamentalement, vous voulez une syntaxe pour l'envoi de données vers le WebSocket, je vous conseille d'utiliser un objet JSON pour ce faire. Dans votre WebSocket classe vous avez besoin d'une variable locale appelée subscriptions et une variable locale appelée users comme si.

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

Le javascript pour aller avec ça ressemble un peu à ce

<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>

Remarque: Ce code n'est pas testé je l'ai écrit à la volée à partir de mon expérience avec la clé à Cliquet. Bonne chance 🙂

En fait j'ai besoin d'utiliser la clé à Cliquet Poussoir. Et j'ai réalisé que tout fonctionne bien, mais maintenant le problème est que, que le client est déconnecté au bout de quelques minutes d'inactivité, sans déconnecter le message qu'il cesse de recevoir des messages. Si je continuer à envoyer des mess pour le client dans toutes les 10 minutes, il ne se déconnecte pas, mais Si il y a un écart de plus de 20 minutes ou ainsi, le client ne reçoit pas de message.
ce que vous utilisez pour vous connecter à la websocket? Êtes-vous l'utilisation de proxy à travers nginx ou quelque chose?
Je suis aide à Cliquet avec Poussoir à partir de cet exemple, lien

OriginalL'auteur 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 j'ai trouvé ce code dans mes recherches pour conserver la connexion persistante si échec de réessayer à nouveau la connexion.

OriginalL'auteur Rodrigo Santana

Vous devez vous connecter pour publier un commentaire.