Go Academy · Pelajaran

Menyiarkan Pesan

Kirim ke banyak klien

Menyiarkan Pesan adalah pelajaran Go Academy gratis di CoddyKit. Ini adalah pelajaran 3 dari 4. Kamu bisa membaca pelajaran lengkapnya di bawah secara gratis — lalu praktikkan langsung di browser dengan editor kode bawaan dan tutor AI 24/7. Ini adalah bagian dari jalur belajar Go Academy, dan progresmu tersinkronisasi di web dan aplikasi CoddyKit. Kursus Go Academy mencakup 4 pelajaran total.

Mengirim ke Banyak Klien

Ruang obrolan dan umpan langsung perlu mengirim satu pesan kepada setiap klien yang terhubung. Karena setiap WebSocket hanya mengizinkan satu penulis, Anda memerlukan pola koordinasi: pusat.

Pola Pusat

Pusat adalah satu goroutine utama yang memiliki kumpulan klien dan kanal penyiaran. Klien mendaftar, membatalkan pendaftaran, dan pusat menyebarkan pesan kepada semuanya. Tidak ada peta bersama yang diakses secara langsung oleh beberapa goroutine.

Struktur Data Pusat

Pusat menyimpan:

Satu kumpulan klien (map[*Client]bool)
Satu kanal broadcast yang berisi pesan
Kanal register dan unregister

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

Perulangan Run Pusat

Satu goroutine Run memilih di antara kanal-kanal tersebut. Karena hanya goroutine ini yang mengubah peta, mutex tidak diperlukan.

func (h *Hub) Run() {
    for {
        select {
        case c := <-h.register:
            h.clients[c] = true
        case c := <-h.unregister:
            delete(h.clients, c)
            close(c.send)
        case msg := <-h.broadcast:
            for c := range h.clients {
                c.send <- msg
            }
        }
    }
}

Kanal Pengiriman per Klien

Setiap klien memiliki send chan []byte berpenyangga. Pusat menulis ke kanal tersebut; goroutine penulis khusus mengurasnya ke soket. Dengan demikian, aturan satu penulis terpenuhi.

type Client struct {
    conn *websocket.Conn
    send chan []byte
}

Goroutine Penulis

Setiap klien menjalankan writePump yang melakukan iterasi atas send dan menulis ke soket. Jika kanal ditutup, goroutine tersebut mengirimkan bingkai penutupan.

func (c *Client) writePump() {
    for msg := range c.send {
        c.conn.WriteMessage(websocket.TextMessage, msg)
    }
}

Menghindari Klien Lambat

Jika salah satu klien lambat, send berpenyangganya akan penuh. Kebijakan yang umum: jika penyangga penuh, keluarkan klien tersebut daripada membuat seluruh pusat terblokir.

select {
case c.send <- msg:
default:
    close(c.send)
    delete(h.clients, c)
}

Mengapa Kanal, Bukan Mutex

Semboyan Go: "bagikan memori dengan berkomunikasi." Menyalurkan semua perubahan melalui satu goroutine menggunakan kanal menghindari kondisi balapan pada peta klien tanpa penguncian eksplisit.

Menyiarkan Pesan

Handler mana pun dapat menyiarkan pesan dengan mengirimkannya melalui kanal pusat; pusat menyebarkannya kepada setiap klien yang terdaftar.

hub.broadcast <- []byte("server announcement")

Tertarget vs. Siaran

Untuk ruang obrolan atau pesan langsung, simpan klien berdasarkan ID ruang atau pengguna, lalu lakukan iterasi hanya pada subset yang relevan, bukan semua klien. Dengan begitu, obrolan dengan banyak ruang tetap efisien.

Dapat Dijalankan: Penyebaran dengan Kanal

Program mandiri ini memodelkan sebuah pusat yang menyebarkan satu pesan ke beberapa kanal klien hanya menggunakan pustaka standar dan goroutine.

package main

import (
    "fmt"
    "sync"
)

func main() {
    clients := []chan string{make(chan string, 1), make(chan string, 1), make(chan string, 1)}
    msg := "hello all"
    for _, c := range clients {
        c <- msg // fan-out
    }
    var wg sync.WaitGroup
    for i, c := range clients {
        wg.Add(1)
        go func(id int, ch chan string) {
            defer wg.Done()
            fmt.Printf("client %d got: %s\n", id, <-ch)
        }(i, c)
    }
    wg.Wait()
}

Pemeriksaan Singkat

Uji pemahaman Anda tentang penyiaran.

Rangkuman

Anda telah mempelajari cara menyiarkan pesan kepada banyak klien:

Goroutine pusat memiliki kumpulan klien dan kanal penyiaran
Setiap klien memiliki kanal pengiriman berpenyangga yang dikuras oleh goroutine penulis
Hal ini memenuhi aturan satu penulis untuk setiap koneksi
Keluarkan klien yang lambat agar pusat tetap responsif

Pertanyaan yang Sering Diajukan

Apakah pelajaran “Menyiarkan Pesan” gratis?

Ya — teks lengkap “Menyiarkan Pesan” gratis dibaca di sini di web. Untuk praktiknya secara interaktif (editor kode bawaan dan tutor AI 24/7) dan buka sisa kursus Go Academy, upgrade ke CoddyKit PRO. Kursus Go Academy mencakup 4 pelajaran total.

Apa yang akan aku pelajari di “Menyiarkan Pesan”?

Kirim ke banyak klien Kamu berlatih Go Academy dengan kode praktik yang langsung kamu jalankan di browser, dan tutor AI 24/7 menjawab pertanyaanmu saat kamu mengerjakan pelajaran ini.

Apakah aku perlu pengalaman untuk memulai Go Academy?

Tidak diperlukan pengalaman sebelumnya. Go Academy di CoddyKit dirancang untuk pemula hingga pelajar tingkat lanjut, jadi kamu bisa memulai di sini atau dari awal dan belajar sesuai kecepatan kamu sendiri. Ini adalah pelajaran 3 dari 4.

Berapa lama pelajaran “Menyiarkan Pesan” memakan waktu?

Sebagian besar pelajaran CoddyKit memakan waktu sekitar 5–10 menit. Setiap pelajaran ringkas dan interaktif, jadi kamu membuat kemajuan stabil dan melanjutkan dari tempat kamu tinggalkan di web dan aplikasi.

Bisakah aku menulis dan menjalankan kode dalam pelajaran Go Academy ini?

Ya. Setiap pelajaran Go Academy menyertakan editor kode bawaan, jadi kamu menulis dan menjalankan kode nyata langsung di browser dan mendapatkan umpan balik AI instan — tidak diperlukan penyiapan lokal.

Semua pelajaran dalam kursus ini

← Kembali ke Go Academy