Comment utiliser Golang pour créer un serveur WebSocket qui prend en charge le protocole STOMP?

Golang Build Stomp sur WebSocket Server Guide

La combinaison des protocoles WebSocket et Stomp est largement utilisée dans la communication en temps réel. Cet article vous guidera pour créer un serveur WebSocket qui prend en charge le protocole STOMP à l'aide de Golang et explorer comment surmonter le problème de la documentation insuffisante de la bibliothèque go-stomp .

arrière-plan

De nombreux développeurs ont constaté que go-stomp manque de documentation et d'exemples bien développés, qui pose des défis à l'implémentation côté serveur.

Solution

En raison de la documentation insuffisante de go-stomp , nous devons explorer son applicabilité et considérer d'autres solutions.

1. Évaluez go-stomp : Vérifiez le code de la bibliothèque go-stomp pour les signes de l'implémentation côté serveur WebSocket, tels que des exemples ou du code de test.

2. Alternative: Si go-stomp ne s'applique pas, considérez les alternatives suivantes:

   • Gorilla Websocket: la bibliothèque WebSocket populaire qui peut être utilisée en conjonction avec n'importe quel protocole de messagerie, y compris Stomp.
   • GO-STOMPIENT: Bien qu'il s'agisse d'une bibliothèque client, il peut être intégré aux serveurs WebSocket personnalisés.
   • Centrifugo: un serveur de messagerie mature en temps réel, prend en charge Native STOMP et WebSocket.

3. Exemple d'implémentation (à l'aide de Gorilla WebSocket et Go-stomp-Client):

   L'exemple suivant montre comment créer un serveur simple en conjonction avec Gorilla WebSocket et go-stomp-client :

    package principal
   
   importer (
       "FMT"
       "enregistrer"
       "net / http"
   
       "github.com/gorilla/websocket"
       "github.com/go-stomp/stomp"
   )
   
   var upgrader = Websocket.upgrade {}
   
   func wsendpoint (w http.responsewriter, r * http.request) {
       Conn, err: = uprader.upgrade (w, r, nil)
       Si err! = Nil {
           log.println ("Erreur de mise à niveau WebSocket:", err)
           Retour
       }
       différer conn.close ()
   
       stompconn, err: = stomp.dial ("tcp", "localhost: 61613") // remplace par votre adresse de serveur stomp si err! = nil {
           Log.println ("Erreur de connexion STOMP:", ERR)
           Retour
       }
       différer StompConn.Disconnect ()
   
       Go HandlewebsocketMessages (Conn, Stompconn)
   }
   
   func handlewebsocketMessages (wsonn * Websocket.conn, stompconn * stomp.conn) {
       pour {
           _, msg, err: = wsonn.readMessage ()
           Si err! = Nil {
               Log.println ("Erreur de lecture WebSocket:", err)
               casser
           }
           err = stompConn.send ("/ file d'attente / messages", "", msg) // Remplacez par votre destination stomp si err! = nil {
               Log.println ("Stomp Send Error:", ERR)
           }
       }
   }
   
   func main () {
       http.handlefunc ("/ ws", wsendpoint)
       Log.println ("Écoute du serveur sur: 8080")
       Log.fatal (http.ListenandServe (": 8080", nil))
   }

   Remarque: Cet exemple nécessite l'installation de github.com/gorilla/websocket et github.com/go-stomp/stomp bibliothèques. Veuillez remplacer l'adresse et la destination du serveur STOMP par votre configuration réelle.

en conclusion

Bien que la documentation de la bibliothèque go-stomp puisse être insuffisante, via l'analyse de code et combinée avec d'autres bibliothèques Golang matures, nous pouvons créer avec succès un stomp entièrement fonctionnel sur WebSocket Server. Sélectionnez la bonne bibliothèque et reportez-vous à l'exemple de code fourni pour activer facilement votre application de communication en temps réel.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!