Gabungan golang WebSocket dan JSON: merealisasikan penghantaran dan penghuraian data

Gabungan golang WebSocket dan JSON: merealisasikan penghantaran dan penghuraian data

Dalam pembangunan web moden, penghantaran data masa nyata menjadi semakin penting. WebSocket ialah protokol yang digunakan untuk mencapai komunikasi dua hala Tidak seperti model respons permintaan HTTP tradisional, WebSocket membenarkan pelayan untuk menolak data secara aktif kepada klien. JSON (JavaScript Object Notation) ialah format ringan untuk pertukaran data yang ringkas, mudah dibaca dan mudah dihuraikan antara bahasa pengaturcaraan yang berbeza.

Artikel ini akan memperkenalkan cara menggunakan Golang untuk menggabungkan WebSocket dan JSON untuk mencapai penghantaran dan penghuraian data. Kami akan menggunakan pakej terbina dalam Golang net/http dan github.com/gorilla/websocket untuk mengendalikan sambungan WebSocket dan encoding/json untuk Menghuraikan dan menjana data JSON. net/http和github.com/gorilla/websocket来处理WebSocket连接，并使用encoding/json来解析和生成JSON数据。

首先，我们需要安装gorilla/websocket包。你可以使用以下命令来安装：

go get github.com/gorilla/websocket

接下来，我们可以开始编写代码了。

package main

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

type Message struct {
    Content string `json:"content"`
}

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
}

func echoHandler(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println(err)
        return
    }
    defer conn.Close()

    for {
        // 读取客户端发送的消息
        _, message, err := conn.ReadMessage()
        if err != nil {
            log.Println(err)
            break
        }

        // 解析JSON数据
        var msg Message
        err = json.Unmarshal(message, &msg)
        if err != nil {
            log.Println(err)
            break
        }

        // 输出收到的消息
        fmt.Println("收到消息:", msg.Content)

        // 发送响应消息
        response := Message{
            Content: "你发送的消息是：" + msg.Content,
        }

        // 将响应转换为JSON格式
        jsonResponse, err := json.Marshal(response)
        if err != nil {
            log.Println(err)
            break
        }

        // 发送JSON响应
        err = conn.WriteMessage(websocket.TextMessage, jsonResponse)
        if err != nil {
            log.Println(err)
            break
        }
    }
}

func main() {
    http.HandleFunc("/ws", echoHandler)
    log.Fatal(http.ListenAndServe(":8080", nil))
}

上述代码包含了一个WebSocket处理函数echoHandler，它接收客户端的WebSocket连接并处理消息的收发。在函数内部，我们首先读取客户端发送的消息，并解析为Message结构体。然后，我们输出收到的消息，生成响应消息，并将响应转换为JSON格式。最后，我们使用conn.WriteMessage将JSON响应发送给客户端。

在主函数中，我们将WebSocket处理函数echoHandler注册到/ws

Mula-mula, kita perlu memasang pakej gorila/websocket. Anda boleh memasangnya menggunakan arahan berikut:

var socket = new WebSocket("ws://localhost:8080/ws");
socket.onopen = function () {
    console.log('连接已打开');
    var message = {
        content: 'Hello Server!'
    };
    socket.send(JSON.stringify(message));
};
socket.onmessage = function (event) {
    console.log('收到服务器的响应：', JSON.parse(event.data));
    socket.close();
};
socket.onclose = function () {
    console.log('连接已关闭');
};

Seterusnya, kita boleh mula menulis kod.

rrreee

Kod di atas mengandungi fungsi pemprosesan WebSocket echoHandler, yang menerima sambungan WebSocket pelanggan dan memproses penghantaran dan penerimaan mesej. Di dalam fungsi, kami mula-mula membaca mesej yang dihantar oleh klien dan menghuraikannya ke dalam struktur Mesej. Kami kemudian mengeluarkan mesej yang diterima, menjana mesej respons dan menukar respons kepada format JSON. Akhir sekali, kami menggunakan conn.WriteMessage untuk menghantar respons JSON kepada klien.

Dalam fungsi utama, kami mendaftarkan fungsi pemprosesan WebSocket echoHandler ke laluan /ws dan mendengar port 8080 tempatan. 🎜🎜Selepas menyusun dan menjalankan program, buka sambungan WebSocket dalam penyemak imbas, dan anda boleh menghantar serta menerima data JSON melalui objek WebSocket JavaScript. Berikut ialah contoh kod JavaScript yang mudah: 🎜rrreee🎜 Dalam kod JavaScript di atas, kami mencipta sambungan WebSocket dan menghantar data JSON yang mengandungi kandungan mesej apabila sambungan dibuka. Apabila respons daripada pelayan diterima, kami menghuraikan dan mencetak mesej respons, dan menutup sambungan WebSocket. 🎜🎜Di atas ialah beberapa contoh kod untuk menggunakan Golang digabungkan dengan WebSocket dan JSON untuk merealisasikan penghantaran dan penghuraian data. Dengan menggunakan WebSocket dan JSON, kami boleh memindahkan dan menghuraikan data berstruktur dengan mudah antara pelanggan dan pelayan, membolehkan interaksi data masa nyata. Apabila menulis kod yang berfungsi untuk kes penggunaan khusus anda, ingat untuk memasukkan pengendalian ralat dan pengesahan data yang diperlukan. Harap artikel ini membantu anda! 🎜

Atas ialah kandungan terperinci Gabungan golang WebSocket dan JSON: merealisasikan penghantaran dan penghuraian data. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!