Comment Go WebSocket s'intègre-t-il aux bases de données ?

Comment intégrer Go WebSocket à une base de données : Configurer une connexion à la base de données : Utilisez le package database/sql pour vous connecter à la base de données. Stockage des messages WebSocket dans la base de données : utilisez l'instruction INSERT pour insérer le message dans la base de données. Récupérer les messages WebSocket de la base de données : utilisez une instruction SELECT pour récupérer les messages de la base de données.

Comment Go WebSocket s'intègre à la base de données

Dans les applications WebSocket basées sur le langage Go, la communication des données en temps réel est cruciale. Pour parvenir à la persistance, nous devons intégrer les données WebSocket à la base de données. Cet article vous expliquera comment intégrer une base de données dans une application Go WebSocket et fournira des exemples pratiques.

Configurer la connexion à la base de données

Tout d'abord, vous devez configurer la connexion à la base de données. Voici comment vous connecter à une base de données MySQL à l'aide du package database/sql de 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)
}

Stockage des messages WebSocket dans une base de données

rrreee

Récupérer les messages WebSocket de la base de données
2. Pour récupérer les messages WebSocket de la base de données, vous pouvez utiliser l'instruction SELECT. Voici comment récupérer tous les messages :
rrreee
3. Un exemple concret : application de chat en direct

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!