Bagaimana untuk melaksanakan websocket dalam golang

Dalam era apabila bahagian hadapan moden memberi lebih banyak perhatian kepada masa nyata dan interaktiviti, protokol komunikasi rangkaian telah menjadi lebih popular, ia adalah WebSocket. Dalam penggunaan, WebSocket dan HTTP mempunyai persamaan tertentu, tetapi tidak seperti permintaan HTTP tradisional, WebSocket boleh mengekalkan sambungan untuk masa yang lama. Jika anda sedang mempertimbangkan untuk menggunakan WebSocket untuk membina aplikasi web, maka anda mungkin perlu menggunakan beberapa bahasa pengaturcaraan untuk melaksanakannya. Antaranya, Golang adalah salah satu bahasa pengaturcaraan yang sangat popular Mari kita belajar bagaimana untuk melaksanakan WebSocket di Golang.

1. Apakah itu WebSocket?

WebSocket ialah protokol rangkaian yang menyediakan komunikasi dua hala melalui satu sambungan TCP. Dalam protokol HTTP tradisional, permintaan dihantar dari penyemak imbas ke pelayan, dan pelayan memprosesnya dan mengembalikan hasilnya kepada penyemak imbas Proses ini adalah satu proses selepas pemprosesan permintaan selesai, sambungan akan tertutup. Protokol WebSocket adalah berbeza Apabila pelayar membuat sambungan dengan pelayan, sambungan akan dikekalkan sehingga pengguna atau pelayan memutuskan untuk menutup sambungan. Ini bermakna pelayan boleh menghantar maklumat kepada klien pada bila-bila masa sementara sambungan dikekalkan tanpa menunggu pelayar membuat permintaan.

2. Golang melaksanakan WebSocket

Golang ialah bahasa pengaturcaraan yang menyokong pengaturcaraan serentak Ia pada asalnya dibangunkan oleh Google Kelebihannya terletak pada kecekapan operasi dan penggunaan memori yang sangat rendah. Di bawah ini kami akan memperkenalkan cara melaksanakan WebSocket menggunakan Golang.

1. Pasang perpustakaan Gorilla WebSocket
   Gorilla WebSocket ialah perpustakaan WebSocket popular yang menyediakan API yang ringkas dan mudah digunakan untuk mencipta dan mengendalikan sambungan WebSocket. Sebelum memasang perpustakaan Gorilla WebSocket, anda perlu memasang persekitaran Go terlebih dahulu Selepas pemasangan Go selesai, gunakan arahan berikut untuk memasang perpustakaan Gorilla WebSocket:

   go get github.com/gorilla/websocket

   Salin selepas log masuk
2. Tulis kod

package main

import (
    "fmt"
    "log"
    "net/http"
    "github.com/gorilla/websocket"
)

var clients = make(map[*websocket.Conn]bool)
var broadcast = make(chan Message)
var upgrader = websocket.Upgrader{}

// Message struct
type Message struct {
    Username string `json:"username"`
    Body     string `json:"body"`
}

func main() {
    // Configure websocket route
    http.HandleFunc("/ws", handleConnections)

    // Start listening for incoming chat messages
    go handleMessages()

    // Start the server on localhost port 8080 and log any errors
    err := http.ListenAndServe(":8080", nil)
    if err != nil {
        log.Fatal("ListenAndServe: ", err)
    }
}

func handleConnections(w http.ResponseWriter, r *http.Request) {
    // Upgrade initial GET request to a websocket
    ws, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Fatal(err)
    }
    // Make sure we close the connection when the function returns
    defer ws.Close()

    // Register our new client
    clients[ws] = true

    for {
        var msg Message
        // Read in a new message as JSON and map it to a Message object
        err := ws.ReadJSON(&msg)
        if err != nil {
            log.Printf("error: %v", err)
            delete(clients, ws)
            break
        }
        // Send the newly received message to the broadcast channel
        broadcast <- msg
    }
}

func handleMessages() {
    for {
        // Grab the next message from the broadcast channel
        msg := <-broadcast
        // Send it out to every client that is currently connected
        for client := range clients {
            err := client.WriteJSON(msg)
            if err != nil {
                log.Printf("error: %v", err)
                client.Close()
                delete(clients, client)
            }
        }
    }
}

, sebarang mesej akan ditulis ke saluran clients, dan Dihantar kepada semua pelanggan dalam goroutine lain. Setiap sambungan menerima mesej dengan membaca dan memperuntukkan broadcast objek. Kod sampel untuk pelanggan menghantar mesej adalah seperti berikut: Message

let socket = new WebSocket("ws://localhost:8080/ws");

socket.addEventListener("open", function() {
  socket.send(JSON.stringify({
    "username": "John",
    "body": "Hello World!"
  }));
});

socket.addEventListener("message", function(event) {
  console.log("Received: " + event.data);
});

dalam kod JavaScript pelanggan dan mengendalikannya apabila mesej diterima. message

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan websocket dalam golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!