Go言語を使用してWebsocketベースのリアルタイムデータ送信システムを開発する方法-Golang-php.cn

ホームページ

バックエンド開発

Golang

Go言語を使用してWebsocketベースのリアルタイムデータ送信システムを開発する方法

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Dec 18, 2023 pm 06:39 PM

言語を移動websocketリアルタイムのデータ送信

Go言語を使用してWebsocketベースのリアルタイムデータ送信システムを開発する方法

Go言語を使用してWebsocketベースのリアルタイムデータ送信システムを開発する方法，需要具体代码示例

Websocket是一种全双工协议，它可以在不刷新页面的情况下实现实时数据传输。在现代Web应用程序中，实时数据传输是至关重要的一部分。本文将介绍Go言語を使用してWebsocketベースのリアルタイムデータ送信システムを開発する方法，包括如何实现服务器端和客户端的代码，并提供具体的代码示例。

创建WebSocket服务器

要创建基于Websocket的实时数据传输系统，首先需要创建一个Websocket服务器。在Go中，可以使用gorilla/websocket库来创建Websocket服务器。

以下是一个简单的Websocket服务器的示例代码：

package main

import (
    "fmt"
    "net/http"

    "github.com/gorilla/websocket"
)

// 定义升级器
var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
}

func serveWs(w http.ResponseWriter, r *http.Request) {
    // 升级请求为Websocket
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        fmt.Println(err)
        return
    }

    // 读取Websocket消息
    for {
        messageType, p, err := conn.ReadMessage()
        if err != nil {
            fmt.Println(err)
            return
        }

        // 处理消息
        fmt.Println(string(p))

        // 回复消息
        err = conn.WriteMessage(messageType, p)
        if err != nil {
            fmt.Println(err)
            return
        }
    }
}

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

在这个示例中，我们首先定义了一个升级器(upgrader)，该升级器用于将HTTP连接升级为Websocket连接。然后，我们定义了一个函数serveWs，该函数接收一个HTTP响应写入器(w)和HTTP请求(r)，并将HTTP连接升级为Websocket连接。

在serveWs函数中，我们首先升级HTTP连接为Websocket连接。然后，我们使用一个循环来读取Websocket消息。一旦我们读取到了消息，我们就处理它并将相同的消息发送回客户端。

最后，在main函数中，我们将serveWs函数与路径/ws关联起来，并在端口8080上启动HTTP服务器。

创建Websocket客户端

在创建Websocket客户端之前，我们需要先创建一个HTML页面，该页面将通过Websocket与服务器通信。以下是一个基本的HTML页面的示例代码：

<!DOCTYPE html>
<html>
<head>
    <title>Websocket Example</title>
</head>
<body>

    <textarea id="message"></textarea>
    <button onclick="send()">Send</button>

    <script>
    // 创建Websocket对象
    var ws = new WebSocket("ws://localhost:8080/ws");

    // 接收来自服务器的消息
    ws.onmessage = function(event) {
        console.log(event.data);
    };

    // 发送消息到服务器
    function send() {
        var input = document.getElementById("message");
        ws.send(input.value);
        input.value = "";
    }
    </script>

</body>
</html>

在这个示例中，我们创建了一个文本区域(message)和一个按钮(send)。当用户单击发送按钮时，我们将输入的文本通过Websocket发送到服务器。

在JavaScript中，我们使用WebSocket对象来创建一个Websocket客户端。在我们的示例中，Websocket客户端将连接到/ws路径，并在接收到来自服务器的消息时将它们输出到控制台中。

运行Websocket服务器和客户端

要运行Websocket服务器和客户端，请执行以下步骤：

在终端中，使用命令行切换到包含示例服务器代码的目录。
输入以下命令启动服务器：

go run main.go

在浏览器中，打开以下URL来加载示例HTML页面：

http://localhost:8080/

在文本区域中输入一些文本，并单击发送按钮。您应该看到消息被发送到服务器，并从服务器返回，并在浏览器控制台中输出。
实现实时数据传输

现在，我们已经成功创建了一个简单的Websocket服务器和客户端，但是这仅仅是开始。要实现实时数据传输，我们需要修改服务器端和客户端代码，并在服务器端使用goroutine来处理多个Websocket连接。

以下是一个实现了实时数据传输的示例代码：

package main

import (
    "fmt"
    "net/http"
    "time"

    "github.com/gorilla/websocket"
)

// 定义升级器
var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
}

// 定义客户端
type Client struct {
    conn *websocket.Conn
    send chan []byte
}

// 处理客户端消息
func (c *Client) read() {
    defer func() {
        c.conn.Close()
    }()
    for {
        messageType, p, err := c.conn.ReadMessage()
        if err != nil {
            fmt.Println(err)
            return
        }
        // 处理消息
        fmt.Printf("Received: %s
", p)
    }
}

// 发送消息到客户端
func (c *Client) write() {
    defer func() {
        c.conn.Close()
    }()
    for {
        select {
        case message, ok := <-c.send:
            if !ok {
                c.conn.WriteMessage(websocket.CloseMessage, []byte{})
                return
            }
            writer, err := c.conn.NextWriter(websocket.TextMessage)
            if err != nil {
                return
            }
            writer.Write(message)
            if err := writer.Close(); err != nil {
                return
            }
        }
    }
}

// 定义Hub
type Hub struct {
    clients map[*Client]bool
    broadcast chan []byte
    register chan *Client
    unregister chan *Client
}

// 创建Hub
func newHub() *Hub {
    return &Hub{
        clients:    make(map[*Client]bool),
        broadcast:  make(chan []byte),
        register:   make(chan *Client),
        unregister: make(chan *Client),
    }
}

// 运行Hub
func (h *Hub) run() {
    for {
        select {
        case client := <-h.register:
            h.clients[client] = true
            fmt.Println("Client registered")
        case client := <-h.unregister:
            if _, ok := h.clients[client]; ok {
                delete(h.clients, client)
                close(client.send)
                fmt.Println("Client unregistered")
            }
        case message := <-h.broadcast:
            for client := range h.clients {
                select {
                case client.send <- message:
                    fmt.Printf("Sent: %s
", message)
                default:
                    close(client.send)
                    delete(h.clients, client)
                }
            }
        }
    }
}

func serveWs(hub *Hub, w http.ResponseWriter, r *http.Request) {
    // 升级请求为Websocket
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        fmt.Println(err)
        return
    }

    // 创建客户端
    client := &Client{
        conn: conn,
        send: make(chan []byte),
    }

    // 注册客户端
    hub.register <- client

    // 读取Websocket消息
    go client.read()

    // 发送Websocket消息
    go client.write()
}

func main() {
    // 创建Hub
    hub := newHub()

    // 运行Hub
    go hub.run()

    // 定期广播消息
    go func() {
        for {
            hub.broadcast <- []byte(fmt.Sprintf("Server Time: %s", time.Now().Format("2006-01-02 15:04:05")))
            time.Sleep(1 * time.Second)
        }
    }()

    // 启动HTTP服务器
    http.HandleFunc("/ws", func(w http.ResponseWriter, r *http.Request) {
        serveWs(hub, w, r)
    })
    http.Handle("/", http.FileServer(http.Dir(".")))
    err := http.ListenAndServe(":8080", nil)
    if err != nil {
        panic(err)
    }
}

在这个示例中，我们定义了一个Hub，它管理多个Websocket客户端。每个客户端都有一个读(receive)goroutine和一个写(send)goroutine，它们分别处理从客户端读取的消息和向客户端发送的消息。

除了处理客户端消息之外，Hub还包含一个广播(broadcast)通道，用于将消息广播到所有客户端。在我们的示例中，Hub会定期广播当前日期和时间。

结论

通过本文的代码示例，我们了解了如何使用Go语言创建一个基于Websocket的实时数据传输系统。我们了解了如何使用gorilla/websocket库来创建Websocket服务器和客户端，并实现了如何处理客户端的输入，如何向客户端发送消息，并实现了一个管理多个Websocket客户端的Hub，并在其中实现了广播消息的逻辑。

以上がGo言語を使用してWebsocketベースのリアルタイムデータ送信システムを開発する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明

この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

GolangとPythonの選択：プロジェクトに適していますApr 19, 2025 am 12:21 AM

golangisidealforporformance-criticalapplicationsandconcurrentprogramming、whilepythonexcelsindatascience、rapyプロトタイプ、およびandversitielity.1）for-high-duetoitsefficiency and concurrencyfeatures.2

Golang：並行性と行動のパフォーマンスApr 19, 2025 am 12:20 AM

GolangはGoroutineとChannelを通じて効率的な並行性を実現します。1。Goroutineは、Goキーワードで始まる軽量のスレッドです。 2.チャンネルは、ゴルチン間の安全な通信に使用され、人種の状態を避けます。 3.使用例は、基本的および高度な使用法を示しています。 4.一般的なエラーには、ゴルンレースで検出できるデッドロックとデータ競争が含まれます。 5.パフォーマンスの最適化では、チャネルの使用を削減し、ゴルチンの数を合理的に設定し、Sync.poolを使用してメモリを管理することを示唆しています。

Golang vs. Python：どの言語を学ぶべきですか？Apr 19, 2025 am 12:20 AM

Golangは、システムプログラミングと高い並行性アプリケーションにより適していますが、Pythonはデータサイエンスと迅速な発展により適しています。 1）GolangはGoogleによって開発され、静的にタイピングし、シンプルさと効率を強調しており、高い並行性シナリオに適しています。 2）Pythonは、Guidovan Rossumによって作成され、動的に型付けられた簡潔な構文、幅広いアプリケーション、初心者やデータ処理に適しています。

Golang vs. Python：パフォーマンスとスケーラビリティApr 19, 2025 am 12:18 AM

Golangは、パフォーマンスとスケーラビリティの点でPythonよりも優れています。 1）Golangのコンピレーションタイプの特性と効率的な並行性モデルにより、高い並行性シナリオでうまく機能します。 2）Pythonは解釈された言語として、ゆっくりと実行されますが、Cythonなどのツールを介してパフォーマンスを最適化できます。

Golang vs.その他の言語：比較Apr 19, 2025 am 12:11 AM

GO言語は、同時プログラミング、パフォーマンス、学習曲線などにユニークな利点を持っています。1。GoroutineとChannelを通じて同時プログラミングが実現されます。これは軽量で効率的です。 2。コンピレーション速度は高速で、操作性能はC言語のパフォーマンスに近いです。 3.文法は簡潔で、学習曲線は滑らかで、生態系は豊富です。

Golang and Python：違いを理解するApr 18, 2025 am 12:21 AM

GolangとPythonの主な違いは、並行性モデル、タイプシステム、パフォーマンス、実行速度です。 1. GolangはCSPモデルを使用します。これは、同時タスクの高いタスクに適しています。 Pythonは、I/O集約型タスクに適したマルチスレッドとGILに依存しています。 2。Golangは静的なタイプで、Pythonは動的なタイプです。 3.ゴーランコンパイルされた言語実行速度は高速であり、Python解釈言語開発は高速です。

Golang vs. C：速度差の評価Apr 18, 2025 am 12:20 AM

Golangは通常Cよりも遅くなりますが、Golangはプログラミングと開発効率の同時により多くの利点があります。1）Golangのゴミ収集と並行性モデルにより、同時性の高いシナリオではうまく機能します。 2）Cは、手動のメモリ管理とハードウェアの最適化により、より高いパフォーマンスを取得しますが、開発の複雑さが高くなります。

Golang：クラウドコンピューティングとDevOpsのキー言語Apr 18, 2025 am 12:18 AM

GolangはクラウドコンピューティングとDevOpsで広く使用されており、その利点はシンプルさ、効率性、および同時プログラミング機能にあります。 1）クラウドコンピューティングでは、GolangはGoroutineおよびチャネルメカニズムを介して同時リクエストを効率的に処理します。 2）DevOpsでは、Golangの高速コンピレーションとクロスプラットフォーム機能により、自動化ツールの最初の選択肢になります。

See all articles

ホットAIツール

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

脱衣画像を無料で

Clothoff.io

AI衣類リムーバー

AI Hentai Generator

AIヘンタイを無料で生成します。

ホットツール

SublimeText3 中国語版

中国語版、とても使いやすい

Dreamweaver Mac版

ビジュアル Web 開発ツール

AtomエディタMac版ダウンロード

最も人気のあるオープンソースエディター

SublimeText3 Mac版

神レベルのコード編集ソフト（SublimeText3）

MinGW - Minimalist GNU for Windows

このプロジェクトは osdn.net/projects/mingw に移行中です。引き続きそこでフォローしていただけます。 MinGW: GNU Compiler Collection (GCC) のネイティブ Windows ポートであり、ネイティブ Windows アプリケーションを構築するための自由に配布可能なインポートライブラリとヘッダーファイルであり、C99 機能をサポートする MSVC ランタイムの拡張機能が含まれています。すべての MinGW ソフトウェアは 64 ビット Windows プラットフォームで実行できます。