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 までご連絡ください。

go语言有没有缩进Dec 01, 2022 pm 06:54 PM

go语言有缩进。在go语言中，缩进直接使用gofmt工具格式化即可（gofmt使用tab进行缩进）；gofmt工具会以标准样式的缩进和垂直对齐方式对源代码进行格式化，甚至必要情况下注释也会重新格式化。

go语言为什么叫goNov 28, 2022 pm 06:19 PM

go语言叫go的原因：想表达这门语言的运行速度、开发速度、学习速度（develop）都像gopher一样快。gopher是一种生活在加拿大的小动物，go的吉祥物就是这个小动物，它的中文名叫做囊地鼠，它们最大的特点就是挖洞速度特别快，当然可能不止是挖洞啦。

一文详解Go中的并发【20 张动图演示】Sep 08, 2022 am 10:48 AM

Go语言中各种并发模式看起来是怎样的？下面本篇文章就通过20 张动图为你演示 Go 并发，希望对大家有所帮助！

tidb是go语言么Dec 02, 2022 pm 06:24 PM

是，TiDB采用go语言编写。TiDB是一个分布式NewSQL数据库；它支持水平弹性扩展、ACID事务、标准SQL、MySQL语法和MySQL协议，具有数据强一致的高可用特性。TiDB架构中的PD储存了集群的元信息，如key在哪个TiKV节点；PD还负责集群的负载均衡以及数据分片等。PD通过内嵌etcd来支持数据分布和容错；PD采用go语言编写。

go语言能不能编译Dec 09, 2022 pm 06:20 PM

go语言能编译。Go语言是编译型的静态语言，是一门需要编译才能运行的编程语言。对Go语言程序进行编译的命令有两种：1、“go build”命令，可以将Go语言程序代码编译成二进制的可执行文件，但该二进制文件需要手动运行；2、“go run”命令，会在编译后直接运行Go语言程序，编译过程中会产生一个临时文件，但不会生成可执行文件。

【整理分享】一些GO面试题（附答案解析）Oct 25, 2022 am 10:45 AM

本篇文章给大家整理分享一些GO面试题集锦快答，希望对大家有所帮助！

go语言是否需要编译Dec 01, 2022 pm 07:06 PM

go语言需要编译。Go语言是编译型的静态语言，是一门需要编译才能运行的编程语言，也就说Go语言程序在运行之前需要通过编译器生成二进制机器码（二进制的可执行文件），随后二进制文件才能在目标机器上运行。

golang map怎么删除元素Dec 08, 2022 pm 06:26 PM

删除map元素的两种方法：1、使用delete()函数从map中删除指定键值对，语法“delete(map, 键名)”；2、重新创建一个新的map对象，可以清空map中的所有元素，语法“var mapname map[keytype]valuetype”。

See all articles

ホットAIツール

ホットツール

Safe Exam Browser

Safe Exam Browser は、オンライン試験を安全に受験するための安全なブラウザ環境です。このソフトウェアは、あらゆるコンピュータを安全なワークステーションに変えます。あらゆるユーティリティへのアクセスを制御し、学生が無許可のリソースを使用するのを防ぎます。

Damn Vulnerable Web App (DVWA) は、非常に脆弱な PHP/MySQL Web アプリケーションです。その主な目的は、セキュリティ専門家が法的環境でスキルとツールをテストするのに役立ち、Web 開発者が Web アプリケーションを保護するプロセスをより深く理解できるようにし、教師/生徒が教室環境で Web アプリケーションを教え/学習できるようにすることです。安全。 DVWA の目標は、シンプルでわかりやすいインターフェイスを通じて、さまざまな難易度で最も一般的な Web 脆弱性のいくつかを実践することです。このソフトウェアは、