Tutorial golang Websocket: Bagaimana untuk membangunkan fungsi soal jawab dalam talian

Tutorial Soket Web golang: Bagaimana untuk membangunkan fungsi Soal Jawab dalam talian, contoh kod khusus diperlukan

Dalam era Internet yang dibangunkan hari ini, platform Soal Jawab dalam talian telah menjadi cara penting untuk orang ramai memperoleh pengetahuan, berkongsi pengalaman dan menyelesaikan masalah. Untuk memenuhi keperluan pengguna untuk kedekatan dan interaktiviti, adalah pilihan yang baik untuk menggunakan teknologi Websocket untuk melaksanakan fungsi soal jawab dalam talian. Artikel ini akan memperkenalkan cara menggunakan Golang untuk membangunkan fungsi soal jawab dalam talian berdasarkan Websocket, dan memberikan contoh kod khusus.

1. Penyediaan Projek
Sebelum memulakan tutorial kami, kami perlu melakukan beberapa persediaan:

1. Pasang Golang: Pertama, pastikan komputer anda telah memasang Golang. Sila ke laman web rasmi Golang untuk memuat turun dan memasangnya.
2. Pasang perpustakaan yang diperlukan: Kami akan menggunakan perpustakaan gorila/soket web Golang untuk melaksanakan fungsi Websocket. Anda boleh memasangnya dengan arahan berikut:
   pergi dapatkan github.com/gorilla/websocket
3. Buat struktur direktori projek: Cipta folder baharu dalam laluan kerja anda untuk menyimpan fail projek kami.

2 Cipta pelayan Websocket
Kita perlu mencipta pelayan Websocket untuk mengendalikan sambungan pelanggan dan penghantaran mesej. Cipta fail bernama server.go dalam direktori projek dan tambahkan kod berikut:

package main

import (
    "log"
    "net/http"

    "github.com/gorilla/websocket"
)

// 定义全局变量用于存储连接的客户端
var clients = make(map[*websocket.Conn]bool)

// 定义通道用于传递消息
var broadcast = make(chan Message)

// 定义消息结构体
type Message struct {
    Username string `json:"username"`
    Content  string `json:"content"`
}

// 定义升级HTTP请求为Websocket的方法
var upgrader = websocket.Upgrader{
    CheckOrigin: func(r *http.Request) bool {
        return true
    },
}

// 处理Websocket连接
func handleConnections(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()

    // 将连接的客户端添加到全局变量中
    clients[conn] = true

    for {
        var msg Message
        err := conn.ReadJSON(&msg)
        if err != nil {
            log.Printf("error: %v", err)
            delete(clients, conn)
            break
        }
        broadcast <- msg
    }
}

// 处理广播消息
func handleMessages() {
    for {
        msg := <-broadcast
        for client := range clients {
            err := client.WriteJSON(msg)
            if err != nil {
                log.Printf("error: %v", err)
                client.Close()
                delete(clients, client)
            }
        }
    }
}

func main() {
    http.HandleFunc("/ws", handleConnections)
    go handleMessages()
    log.Println("Server start on http://localhost:8000")
    log.Fatal(http.ListenAndServe(":8000", nil))
}

Kod di atas melaksanakan pelayan Websocket mudah yang menyiarkan mesej pelanggan kepada semua pelanggan yang disambungkan.

3 Buat klien Websocket
Seterusnya, kita perlu mencipta klien Websocket untuk pengguna menghantar dan menerima mesej di halaman hujung hadapan. Cipta fail bernama client.go dalam direktori projek dan tambah kod berikut:

package main

import (
    "log"
    "net/url"
    "os"
    "os/signal"
    "time"

    "github.com/gorilla/websocket"
)

// 定义消息结构体
type Message struct {
    Username string
    Content  string
}

func main() {
    // 创建WebSocket连接
    u := url.URL{Scheme: "ws", Host: "localhost:8000", Path: "/ws"}
    c, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
    if err != nil {
        log.Fatal("dial:", err)
    }
    defer c.Close()

    // 监听系统信号
    interrupt := make(chan os.Signal, 1)
    signal.Notify(interrupt, os.Interrupt)

    // 创建一个通道用于接收消息
    done := make(chan struct{})

    // 创建一个协程来监听用户输入并发送消息
    go func() {
        for {
            var msg Message
            err := c.ReadJSON(&msg)
            if err != nil {
                log.Println("read:", err)
                close(done)
                return
            }
            log.Printf("received: %v", msg)
        }
    }()

    // 创建一个协程来发送消息给服务器
    go func() {
        ticker := time.NewTicker(time.Second)
        defer ticker.Stop()

        for {
            select {
            case <-done:
                return
            case t := <-ticker.C:
                err := c.WriteJSON(Message{Username: "Alice", Content: "Hello, World!"})
                if err != nil {
                    log.Println("write:", err)
                    return
                }
                log.Printf("sent: %v", t.String())
            }
        }
    }()

    // 等待系统信号
    <-interrupt
    log.Println("interrupt")

    // 关闭连接
    err = c.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))
    if err != nil {
        log.Println("write close:", err)
    }
    select {
    case <-done:
    case <-time.After(time.Second):
    }
    log.Println("server closed")
}

Kod di atas mencipta klien Websocket, yang akan menghantar mesej kepada pelayan setiap saat dan mencetak mesej yang diterima.

4. Susun dan jalankan
Buka terminal dalam direktori projek dan laksanakan arahan berikut untuk menyusun dan menjalankan projek:

1. Kompilasi pelayan
   go bina server.go
2. Jalankan pelayan
   ./server
3. 
   go build client.go
4. Jalankan klien
   ./client

5 Fungsi Ujian
Lawati http://localhost:8000 dalam penyemak imbas dan buka konsol, anda akan melihat mesej yang dihantar oleh klien dan Siaran. mesej kepada pelanggan lain. Cuba taip mesej ke dalam konsol dan tekan enter, mesej akan disiarkan kepada semua pelanggan yang disambungkan.

6. Ringkasan
Tutorial ini memperkenalkan anda cara menggunakan teknologi Golang dan Websocket untuk membangunkan fungsi soal jawab dalam talian yang mudah. Dengan mempelajari tutorial ini, anda seharusnya dapat memahami cara membuat pelayan dan klien Websocket, dan boleh menggunakan teknologi berkaitan dalam projek anda. Saya harap tutorial ini dapat membantu anda, dan saya ucapkan selamat belajar pengaturcaraan!

Atas ialah kandungan terperinci Tutorial golang Websocket: Bagaimana untuk membangunkan fungsi soal jawab dalam talian. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!