메시지 브로드캐스트

여러 클라이언트에 보내기

허브 패턴

허브 데이터 구조

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

허브 실행 반복

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
            }
        }
    }
}

클라이언트별 전송 채널

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

쓰기 고루틴

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

느린 클라이언트 방지

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

뮤텍스보다 채널을 사용하는 이유

메시지 브로드캐스팅

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

대상 지정과 브로드캐스트

실행 가능: 채널을 사용한 분배

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()
}

빠른 확인

복습