Websocket Cowboy Traitement global

Question

J'ai un serveur cow-boy websocket. De nombreux clients envoient un message sur le WebSocket. Je dois faire le traitement sur le message. Je peux le faire dans websocket_handle, Cependant comme c'est en temps réel je voudrais l'éviter à la place je veux envoyer le message à un processus global où tout le traitement peut être fait.

Comme chaque cow-boy a son propre processus Comment exécuter un processus où chaque utilisateur peut envoyer un message et le traitement peut être fait dans ce processus.

Answer 1

Juste pour préciser, chaque connexion websocket aura son propre processus de Erlang dans Cowboy, de sorte que les messages de différents clients WebSocket seront traitées dans processus différents. Si vous devez déplacer le traitement depuis la WebSocket, vous pouvez simplement démarrer un nouveau processus gestionnaire/serveur lorsque votre application démarre (par exemple lorsque vous démarrez Cowboy) qui écoute les commandes et les données du processus. Exemple de code de traitement:

-module(my_processor). 

-export([start/0]). 

start() -> 
    spawn(fun process_loop/0). 

process_loop() -> 
    receive 
    {process_cmd, Data} -> 
     process(Data) 
    end, 
    process_loop(). 

Lorsque vous le démarrez, enregistrez également le processus avec un nom global. De cette façon, nous pouvons le référencer à partir des gestionnaires websocket plus tard.

Pid=my_processor:start(). 
register(processor, Pid). 

Maintenant, vous pouvez envoyer les données de la fonction de Cowboy websocket_handle/3 au processus de manutention:

websocket_handle(Data, Req, State) -> 
     ..., 
     processor ! {process_cmd, Data}, 
     ..., 
     {ok,Req,State}. 

Notez que le processus my_processor traitera les demandes de traitement de toutes les connexions. Si vous voulez avoir un processus séparé pour chaque connexion websocket vous pouvez commencer my_processor dans la fonction websocket_init/3 de Cowboy, stocker le Pid du processus my_processor dans le paramètre State retourné depuis websocket_init et utiliser ce pid au lieu du nom global processor.