Bagaimanakah Go WebSocket berintegrasi dengan pangkalan data?

Cara untuk mengintegrasikan Go WebSocket dengan pangkalan data: Sediakan sambungan pangkalan data: Gunakan pakej pangkalan data/sql untuk menyambung ke pangkalan data. Menyimpan mesej WebSocket ke pangkalan data: Gunakan pernyataan INSERT untuk memasukkan mesej ke dalam pangkalan data. Dapatkan semula mesej WebSocket daripada pangkalan data: Gunakan pernyataan SELECT untuk mendapatkan semula mesej daripada pangkalan data.

How Go WebSocket disepadukan dengan pangkalan data

Dalam aplikasi WebSocket berdasarkan bahasa Go, komunikasi data masa nyata adalah penting. Untuk mencapai kegigihan, kita perlu menyepadukan data WebSocket dengan pangkalan data. Artikel ini akan membimbing anda cara mengintegrasikan pangkalan data dalam aplikasi Go WebSocket dan memberikan contoh praktikal.

Sediakan sambungan pangkalan data

Pertama, anda perlu menyediakan sambungan ke pangkalan data. Begini cara untuk menyambung ke pangkalan data MySQL menggunakan pakej database/sql Go: database/sql 包连接到 MySQL 数据库：

import (
    "database/sql"
    "fmt"

    _ "github.com/go-sql-driver/mysql" // MySQL 驱动程序
)

func main() {
    db, err := sql.Open("mysql", "user:password@tcp(host:port)/database")
    if err != nil {
        panic(err)
    }
    defer db.Close() // 记得关闭连接

    // ... 执行数据库操作 ...
}

将 WebSocket 消息存储到数据库

要将 WebSocket 消息存储到数据库，你需要使用 INSERT 语句。以下是一个示例：

stmt, err := db.Prepare("INSERT INTO messages (message) VALUES (?)")
if err != nil {
    panic(err)
}

_, err = stmt.Exec(message)
if err != nil {
    panic(err)
}

从数据库检索 WebSocket 消息

要从数据库中检索 WebSocket 消息，你可以使用 SELECT

rows, err := db.Query("SELECT id, message FROM messages")
if err != nil {
    panic(err)
}

defer rows.Close()

for rows.Next() {
    var id int
    var message string
    err := rows.Scan(&id, &message)
    if err != nil {
        panic(err)
    }
    fmt.Printf("Message ID: %d, Message: %s\n", id, message)
}

Menyimpan mesej WebSocket ke pangkalan data

rrreee

Dapatkan semula mesej WebSocket daripada pangkalan data
2. Untuk mendapatkan semula mesej WebSocket daripada pangkalan data, anda boleh menggunakan pernyataan SELECT. Begini cara untuk mendapatkan semula semua mesej:
rrreee
3. Contoh kehidupan sebenar: Aplikasi sembang langsung

Atas ialah kandungan terperinci Bagaimanakah Go WebSocket berintegrasi dengan pangkalan data?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!