Ratchet PHP WAMP - React / ZeroMQ-diffusion spécifique à l'utilisateur

Remarque: Ma réponse ici ne pas incluez des références à ZeroMQ, car je ne l'utilise plus. Cependant, je suis sûr que vous serez en mesure de comprendre comment utiliser ZeroMQ avec cette réponse si vous avez besoin.

utilisez JSON

d'Abord et avant tout, le Websocket RFC et Wamp Spec préciser que le sujet auquel s'abonner doit être un chaîne. Je triche un peu ici, mais je suis toujours fidèle à la spécification: je passe JSON à travers à la place.

{
    "topic": "subject here",
    "userId": "1",
    "token": "dsah9273bui3f92h3r83f82h3"
}

JSON est toujours une chaîne, mais il me permet de passer à travers plus de données à la place du "topic", et il est simple pour PHP de faire un json_decode() sur l'autre extrémité. Bien sûr, vous devriez valider que vous recevez réellement JSON, mais c'est à votre mise en œuvre.

alors qu'est-ce que je traverse ici, et pourquoi?

• thème

le sujet est Le sous réserve que l'utilisateur s'abonne à. Vous utilisez ceci pour décider quelles données vous renvoyez à l'utilisateur.

• nom d'utilisateur

évidemment L'ID de l'utilisateur. Vous vérifier que cet utilisateur existe et est autorisé à souscrire, à l'aide de la partie suivante:

• Jeton

Ce doit être un utilisation jeton généré au hasard, généré dans votre PHP, et passé à un Variable JavaScript. Quand je dis "une utilisation", je veux dire chaque fois que vous rechargez la page (et, par extension, sur chaque requête HTTP), votre variable JavaScript devrait avoir un nouveau token. Ce token doit être stocké dans la base de données contre L'ID de l'utilisateur.

ensuite, une fois qu'une requête websocket est faite, vous faites correspondre le token et l'identifiant de l'utilisateur à ceux de la base de données pour s'assurer que l'utilisateur est bien qui ils disent qu'ils sont, et qu'ils n'ont pas joué avec le JS variable.

Remarque: Dans votre gestionnaire d'événements, vous pouvez utiliser $conn->remoteAddress pour obtenir L'adresse IP de la connexion, donc si quelqu'un essaie de se connecter de manière malveillante, vous pouvez le bloquer (le log ou quelque chose).

Pourquoi ce travail?

Cela fonctionne parce que chaque fois qu'une nouvelle connexion à l'entrée, et le jeton unique garantit qu'Aucun utilisateur n'aura accès aux données d'abonnement de quiconque.

le Le serveur

voici ce que j'utilise pour exécuter la boucle et le gestionnaire d'événements. Je suis en train de créer la boucle, de faire toute la création d'objets de style décorateur, et de passer dans mon EventHandler (que je viendrai bientôt) avec la boucle là aussi.

$loop = Factory::create();

new IoServer(
    new WsServer(
        new WampServer(
            new EventHandler($loop) // This is my class. Pass in the loop!
        )
    ),
    $webSock
);

$loop->run();

Le Gestionnaire D'Événement

class EventHandler implements WampServerInterface, MessageComponentInterface
{
    /**
     * @var \React\EventLoop\LoopInterface
     */
    private $loop;

    /**
     * @var array List of connected clients
     */
    private $clients;

    /**
     * Pass in the react event loop here
     */
    public function __construct(LoopInterface $loop)
    {
        $this->loop = $loop;
    }

    /**
     * A user connects, we store the connection by the unique resource id
     */
    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients[$conn->resourceId]['conn'] = $conn;
    }

    /**
     * A user subscribes. The JSON is in $subscription->getId()
     */
    public function onSubscribe(ConnectionInterface $conn, $subscription)
    {
        // This is the JSON passed in from your JavaScript
        // Obviously you need to validate it's JSON and expected data etc...
        $data = json_decode(subscription->getId());

        // Validate the users id and token together against the db values

        // Now, let's subscribe this user only
        // 5 = the interval, in seconds
        $timer = $this->loop->addPeriodicTimer(5, function() use ($subscription) {
            $data = "whatever data you want to broadcast";
            return $subscription->broadcast(json_encode($data));
        });

        // Store the timer against that user's connection resource Id
        $this->clients[$conn->resourceId]['timer'] = $timer;
    }

    public function onClose(ConnectionInterface $conn)
    {
        // There might be a connection without a timer
        // So make sure there is one before trying to cancel it!
        if (isset($this->clients[$conn->resourceId]['timer']))
        {
            if ($this->clients[$conn->resourceId]['timer'] instanceof TimerInterface)
            {
                $this->loop->cancelTimer($this->clients[$conn->resourceId]['timer']);
            }
        }

        unset($this->clients[$conn->resourceId]);
    }

    /** Implement all the extra methods the interfaces say that you must use **/
}

c'est en gros ça. Les principaux points sont ici:

• jeton Unique, id utilisateur et id de connexion de fournir la combinaison unique nécessaires pour s'assurer qu'un utilisateur Je ne vois pas les données d'un autre utilisateur.
• token Unique signifie que si le même utilisateur ouvre une autre page et demande de s'abonner, il aura son propre combo d'id de connexion + token de sorte que le même utilisateur n'aura pas le double des abonnements sur la même page (essentiellement, chaque connexion a ses propres données individuelles).

Extension

vous devriez vous assurer que toutes les données sont validées et pas une tentative de piratage avant de faire quoi que ce soit avec elle. Enregistrer toutes les tentatives de connexion utiliser quelque chose comme Monolog, et mettre en place le renvoi d'e-mail si une situation critique se produit (comme le serveur s'arrête de fonctionner parce que quelqu'un est un bâtard et tente de pirater votre serveur).

Points De Fermeture

• Validez Tout. Je ne peux pas le souligner assez. Votre jeton unique qui change chaque demande est important.
• rappelez-vous, si vous re-générez le token sur chaque requête HTTP, et que vous faites une requête POST avant d'essayer de vous connecter via websockets, vous devrez transmettre le token généré à votre JavaScript avant d'essayer de vous connecter (sinon votre token sera invalide).
• Journal tout. Tenez un registre de toutes les personnes qui se connectent, qui demandent quel sujet et qui se déconnectent. Monolog est parfait pour ça.