Bagaimana cara menggunakan Golang untuk membina pelayan WebSocket yang menyokong protokol stomp?

Golang membina stomp melalui panduan pelayan websocket

Gabungan protokol WebSocket dan Stomp digunakan secara meluas dalam komunikasi masa nyata. Artikel ini akan membimbing anda untuk membina pelayan WebSocket yang menyokong Protokol Stomp menggunakan Golang dan meneroka bagaimana untuk mengatasi masalah dokumentasi yang tidak mencukupi dalam perpustakaan go-stomp .

latar belakang

Ramai pemaju telah mendapati bahawa perpustakaan go-stomp tidak mempunyai dokumentasi dan contoh yang maju, yang menimbulkan cabaran kepada pelaksanaan pelayan.

Penyelesaian

Oleh kerana dokumentasi Perpustakaan go-stomp yang tidak mencukupi, kita perlu meneroka kebolehgunaannya dan mempertimbangkan penyelesaian lain.

1. Evaluasi go-stomp : Semak semula kod perpustakaan go-stomp untuk tanda-tanda pelaksanaan sisi pelayan WebSocket, seperti contoh atau kod ujian.

2. Alternatif: Jika go-stomp tidak terpakai, pertimbangkan alternatif berikut:

   • Gorilla WebSocket: Perpustakaan WebSocket yang popular yang boleh digunakan bersamaan dengan sebarang protokol pemesejan, termasuk Stomp.
   • Go-Stomp-Client: Walaupun ia adalah perpustakaan klien, ia boleh diintegrasikan dengan pelayan WebSocket tersuai.
   • Centrifugo: Pelayan pemesejan masa nyata yang matang, menyokong Stomp dan WebSocket.

3. Pelaksanaan Contoh (menggunakan Gorilla WebSocket dan Go-Stomp-client):

   Contoh berikut menunjukkan cara membina pelayan mudah bersempena dengan Gorilla Websocket dan go-stomp-client :

    Pakej utama
   
   import (
       "FMT"
       "Log"
       "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: = Upgrader.Upgrade (W, R, Nil)
       jika err! = nil {
           Log.println ("Ralat Peningkatan WebSocket:", Err)
           Kembali
       }
       menangguhkan conn.close ()
   
       stompConn, err: = stomp.dial ("tcp", "localhost: 61613") // gantikan dengan alamat pelayan stomp anda jika err! = nil {
           log.println ("Ralat sambungan stomp:", err)
           Kembali
       }
       menangguhkan stompConn.disconnect ()
   
       Pergi HandleWebsocketMessages (Conn, stompConn)
   }
   
   Func handleWebsocketMessages (wsconn *WebSocket.conn, stompConn *stomp.conn) {
       untuk {
           _, msg, err: = wsconn.readMessage ()
           jika err! = nil {
               Log.println ("Ralat Baca WebSocket:", Err)
               rehat
           }
           err = stompConn.send ("/giliran/mesej", "", msg) // gantikan dengan destinasi stomp anda jika err! = nil {
               Log.println ("Stomp ERROR Hantar:", Err)
           }
       }
   }
   
   func main () {
       http.handlefunc ("/ws", wsendpoint)
       Log.println ("Mendengarkan pelayan pada: 8080")
       log.fatal (http.listenandserve (": 8080", nil))
   }

   Nota: Contoh ini memerlukan pemasangan github.com/gorilla/websocket dan github.com/go-stomp/stomp . Sila ganti alamat dan destinasi pelayan Stomp dengan konfigurasi sebenar anda.

kesimpulannya

Walaupun dokumentasi untuk perpustakaan go-stomp mungkin tidak mencukupi, melalui analisis kod dan digabungkan dengan perpustakaan golang matang yang lain, kami dapat berjaya membina stomp berfungsi sepenuhnya melalui pelayan WebSocket. Pilih perpustakaan yang betul dan rujuk kod sampel yang disediakan untuk membolehkan aplikasi komunikasi masa nyata anda dengan mudah.

Atas ialah kandungan terperinci Bagaimana cara menggunakan Golang untuk membina pelayan WebSocket yang menyokong protokol stomp?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!