Rumah > Artikel > pembangunan bahagian belakang > Cara menggunakan WebSocket dalam golang untuk kemas kini data masa nyata

Cara menggunakan WebSocket dalam golang untuk kemas kini data masa nyata

WBOYasal: 2023-12-18 09:06:451168semak imbas

Cara menggunakan WebSocket di Golang untuk kemas kini data masa nyata

Ikhtisar:
WebSocket ialah teknologi komunikasi yang direka untuk komunikasi dupleks penuh antara penyemak imbas web dan pelayan. Di Golang, kita boleh menggunakan net/http dan github.com/gorilla/websocket dalam perpustakaan standard untuk melaksanakan kefungsian WebSocket. Artikel ini akan memperkenalkan cara menggunakan WebSocket di Golang untuk kemas kini data masa nyata dan memberikan beberapa contoh kod. net/http和github.com/gorilla/websocket来实现WebSocket功能。本文将介绍如何在Golang中使用WebSocket进行实时数据更新，并提供一些代码示例。

步骤：

第一步：创建HTTP服务器
首先，我们需要创建一个HTTP服务器来处理WebSocket连接请求。下面是一个简单的示例代码：

package main

import (
    "log"
    "net/http"
)

func main() {
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        http.ServeFile(w, r, "index.html")
    })

    log.Println("HTTP server is starting at http://localhost:8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}

这段代码创建了一个简单的HTTP服务器，它会将根路径（"/"）映射到一个名为index.html的静态文件。

第二步：处理WebSocket连接
接下来，我们需要修改HTTP服务器的代码，以便能够处理WebSocket连接请求。我们可以使用github.com/gorilla/websocket库来处理WebSocket连接。下面是修改后的示例代码：

package main

import (
    "log"
    "net/http"

    "github.com/gorilla/websocket"
)

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

    clients = make(map[*websocket.Conn]bool)
)

func main() {
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        http.ServeFile(w, r, "index.html")
    })

    http.HandleFunc("/ws", func(w http.ResponseWriter, r *http.Request) {
        conn, err := upgrader.Upgrade(w, r, nil)
        if err != nil {
            log.Println("Failed to upgrade connection:", err)
            return
        }
        clients[conn] = true

        for {
            _, msg, err := conn.ReadMessage()
            if err != nil {
                log.Println("Failed to read message from client:", err)
                delete(clients, conn)
                break
            }

            for client := range clients {
                err := client.WriteMessage(websocket.TextMessage, msg)
                if err != nil {
                    log.Println("Failed to write message to client:", err)
                    client.Close()
                    delete(clients, conn)
                }
            }
        }
    })

    log.Println("WebSocket server is starting at ws://localhost:8080/ws")
    log.Fatal(http.ListenAndServe(":8080", nil))
}

在这段代码中，我们创建了一个upgrader对象，并定义了一个clients变量来保存所有连接的客户端。当有新的WebSocket请求时，我们会将连接升级为WebSocket连接，并将其添加到clients变量中。然后，我们通过循环读取客户端发来的消息，并把消息发送给所有已连接的客户端。

第三步：创建前端页面
最后，我们需要创建一个前端页面来连接WebSocket服务器，并展示实时数据更新。下面是一个简单的HTML页面示例（index.html）：

<!DOCTYPE html>
<html>

<head>
    <title>WebSocket Demo</title>
</head>

<body>
    <h1>WebSocket Demo</h1>

    <input type="text" id="message-input">
    <button onclick="send()">Send</button>

    <ul id="message-list"></ul>

    <script>
        var socket = new WebSocket("ws://localhost:8080/ws");

        socket.onmessage = function(event) {
            var message = document.createElement("li");
            message.textContent = event.data;
            document.getElementById("message-list").appendChild(message);
        };

        function send() {
            var input = document.getElementById("message-input");
            var message = input.value;
            input.value = "";

            socket.send(message);
        }
    </script>
</body>

</html>

这段代码创建了一个WebSocket连接并监听onmessage事件，当有消息到达时，将消息添加到一个ul

Langkah:

Langkah Pertama: Cipta Pelayan HTTP

Pertama, kita perlu mencipta pelayan HTTP untuk mengendalikan permintaan sambungan WebSocket. Berikut ialah kod contoh mudah: 🎜rrreee🎜Kod ini mencipta pelayan HTTP ringkas yang memetakan laluan akar ("/") kepada fail statik yang dipanggil index.html . 🎜🎜Langkah 2: Mengendalikan sambungan WebSocket🎜Seterusnya, kita perlu mengubah suai kod pelayan HTTP untuk dapat mengendalikan permintaan sambungan WebSocket. Kita boleh menggunakan pustaka github.com/gorilla/websocket untuk mengendalikan sambungan WebSocket. Berikut ialah kod sampel yang diubah suai: 🎜rrreee🎜 Dalam kod ini, kami mencipta objek upgrade dan mentakrifkan pembolehubah clients untuk menahan semua pelanggan yang disambungkan berakhir. Apabila terdapat permintaan WebSocket baharu, kami menaik taraf sambungan kepada sambungan WebSocket dan menambahkannya pada pembolehubah clients. Kemudian, kami membaca mesej daripada klien melalui gelung dan menghantar mesej kepada semua pelanggan yang bersambung. 🎜🎜Langkah 3: Buat halaman hadapan🎜Akhir sekali, kita perlu mencipta halaman hadapan untuk menyambung ke pelayan WebSocket dan memaparkan kemas kini data masa nyata. Berikut ialah contoh halaman HTML ringkas (index.html): 🎜rrreee🎜Kod ini mencipta sambungan WebSocket dan mendengar acara onmessage Apabila mesej tiba, Tambah mesej kepada elemen ul untuk paparan. Selain itu, kotak input dan butang hantar disediakan supaya pengguna boleh memasukkan mesej dan menghantarnya ke pelayan melalui WebSocket. 🎜🎜Ringkasan: 🎜Melalui langkah di atas, kita boleh menggunakan WebSocket dalam Golang untuk kemas kini data masa nyata. Dengan mencipta pelayan HTTP, mengendalikan sambungan WebSocket dan berinteraksi dengan halaman hadapan, kami boleh mencapai komunikasi data masa nyata dalam aplikasi web. Sudah tentu, ini hanyalah contoh mudah dan mungkin perlu dikembangkan dan diubah suai mengikut keperluan khusus semasa penggunaan sebenar. Saya harap artikel ini membantu dan saya doakan anda berjaya apabila menggunakan WebSocket! 🎜

Atas ialah kandungan terperinci Cara menggunakan WebSocket dalam golang untuk kemas kini data masa nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

golang html 循环对象事件 ul github http websocket

Kenyataan：

Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn

Artikel sebelumnya：Cara menggunakan Websocket golang untuk membangunkan fungsi ramalan cuaca masa nyataArtikel seterusnya：Cara menggunakan Websocket golang untuk membangunkan fungsi ramalan cuaca masa nyata

Artikel berkaitan

Lihat lagi