Broadcasting af beskeder
Send til mange klienter
Broadcasting af beskeder er en gratis Go Academy-lektion på CoddyKit. Dette er lektion 3 af 4. Du kan læse alle 3 lektioner i dette læringsspor gratis i deres fulde længde — derefter låser CoddyKit PRO alle lektioner op samt praktiske øvelser med en indbygget kodeeditor og en AI-underviser døgnet rundt. Den er en del af læringsforløbet i Go Academy, og dine fremskridt synkroniseres på tværs af nettet og CoddyKit-appen. Go Academy-kurset indeholder 4 lektioner i alt.
Send til mange klienter
Chatrum og livefeeds skal kunne sende én meddelelse til hver forbundet klient. Da hver WebSocket kun tillader én skriver, har du brug for et samordningsmønster: hubben.
Hub-mønsteret
En hub er en central goroutine, der ejer mængden af klienter og en kanal til udsendelser. Klienter registreres og afregistreres, og hubben spreder meddelelserne. Ingen delt map ændres direkte af flere goroutiner.
Hubbens datastrukturer
Hubben indeholder:
- Et sæt klienter (
map[*Client]bool) - En
broadcast-kanal med meddelelser - Kanalerne
registerogunregister
type Hub struct {
clients map[*Client]bool
broadcast chan []byte
register chan *Client
unregister chan *Client
}Hubbens kørselssløjfe
En enkelt Run-goroutine vælger mellem kanalerne. Da kun denne goroutine ændrer mappet, er der ikke brug for en mutex.
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
}
}
}
}Sende kanal pr. klient
Hver klient har en bufret send chan []byte. Hubben skriver til den, og en dedikeret skriver-goroutine tømmer den til forbindelsen. Det overholder reglen om én skriver.
type Client struct {
conn *websocket.Conn
send chan []byte
}Skriver-goroutinen
Hver klient kører en writePump, der gennemløber send og skriver til forbindelsen. Hvis kanalen lukkes, sender den en lukkeramme.
func (c *Client) writePump() {
for msg := range c.send {
c.conn.WriteMessage(websocket.TextMessage, msg)
}
}Undgå langsomme klienter
Hvis én klient er langsom, bliver dens bufrede send fyldt op. En almindelig politik er at afbryde klienten, hvis bufferen er fuld, i stedet for at blokere hele hubben.
select {
case c.send <- msg:
default:
close(c.send)
delete(h.clients, c)
}Hvorfor kanaler frem for mutexer
Gos motto er: "del hukommelse ved at kommunikere". Når alle ændringer sendes gennem én goroutine via kanaler, undgår du kapløbsbetingelser i klientmappet uden eksplicit låsning.
Udsendelse af en meddelelse
Enhver handler kan udsende en meddelelse ved at sende på hubbens kanal; hubben spreder den til hver registreret klient.
hub.broadcast <- []byte("server announcement")Målrettet udsendelse kontra udsendelse
Til rum eller direkte meddelelser kan du gemme klienter med rumnøgle eller bruger-id og kun gennemløbe den relevante delmængde i stedet for alle klienter. Det holder en chat med mange rum effektiv.
Kørbar: Udsendelse med kanaler
Dette selvstændige program modellerer, hvordan en hub spreder én meddelelse til flere klientkanaler, udelukkende ved hjælp af standardbiblioteket og goroutiner.
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()
}Hurtig kontrol
Kontrollér din forståelse af udsendelser.
Opsummering
Du har lært at sende til mange klienter:
- Hub-goroutinen ejer klientmængden og en kanal til udsendelser
- Hver klient har en bufret sende-kanal, som tømmes af en skriver-goroutine
- Det overholder reglen om én skriver pr. forbindelse
- Afbryd langsomme klienter for at holde hubben responsiv
Lær Go med en AI-underviser — gratis
Skriv og kør rigtig kode i din browser, få øjeblikkelig hjælp fra en AI-underviser døgnet rundt, og fortsæt, hvor du slap, på web eller i appen.
- Kurser
- 51
- Lektioner
- 203
Ofte stillede spørgsmål
Er lektionen “Broadcasting af beskeder” gratis?
Ja — alle 3 lektioner i læringssporet Go Academy, inklusive “Broadcasting af beskeder”, kan læses gratis i deres fulde længde her på webstedet. Derefter låser CoddyKit PRO alle lektioner op samt interaktive øvelser med en indbygget kodeeditor og en AI-underviser døgnet rundt. Go Academy-kurset indeholder 4 lektioner i alt.
Hvad lærer jeg i “Broadcasting af beskeder”?
Send til mange klienter Du øver dig i Go Academy med praktisk kode, som du kører direkte i browseren, og en AI-vejleder døgnet rundt besvarer dine spørgsmål, mens du arbejder dig gennem lektionen.
Skal jeg have erfaring for at begynde på Go Academy?
Der kræves ingen tidligere erfaring. Go Academy på CoddyKit er tilrettelagt for både begyndere og øvede, så du kan starte her eller fra begyndelsen og lære i dit eget tempo. Dette er lektion 3 af 4.
Hvor lang tid tager lektionen “Broadcasting af beskeder”?
De fleste CoddyKit-lektioner tager cirka 5–10 minutter. Hver lektion er kort og interaktiv, så du gør løbende fremskridt og kan fortsætte, hvor du slap – på både web og app.
Kan jeg skrive og køre kode i denne Go Academy-lektion?
Ja. Alle Go Academy-lektioner har en indbygget kodeeditor, så du kan skrive og køre rigtig kode direkte i din browser og få øjeblikkelig feedback fra AI – uden lokal opsætning.
Alle lektioner i dette kursus
- Grundlæggende om WebSocket
- Brug af gorilla/websocket
- Broadcasting af beskeder
- Forbindelseshåndtering