[WSS] BroadCast 구현 방법

[j1mmyson]

어떻게 구현할지 고민중..

방법 A (일단 요 방법으로 진행중)

▷ 싱글톤 객체를 통해 브로드 캐스팅을 구현하는 방법

• 쉬운 이해를 위해 아래 그림처럼 표현을 하였지만 결국 각 유저에게 브로드 캐스팅을 할때는 결국 그 유저의 커넥션을 통해 메시지를 전달함..
• 결국 커넥션을 통해 메시지를 전달하는 행위 (conn.WriteMessage())를 자기 자신 커넥션에서 수행하느냐 아니냐의 차이

• 여러개의 웹소켓 커넥션에서 공통적으로 사용할 수 있는 Subscriber 싱글톤 객체에 구독 정보 저장.

  type Subscriber struct {
  ChannelMap map[string][]*websocket.Conn
  }

• 여러개의 커넥션 중 하나의 커넥션에서 메시지를 수신하면 같은 페이퍼를 구독중인 유저들 커넥션을 통해 메시지 브로드 캐스팅

  func (s *Subscribe) Broadcast(channelID string, message []byte) {
  conns := s.ChannelMap[channelID]
  for _, conn := range conns {
    conn.WriteMessage(websocket.TextMessage, message)
  }
  }

방법 B

▷ 커넥션 마다 채널을 생성하여 채널을 통해 브로드 캐스팅을 구현하는 방법

• 이 방법을 쓰게되면 map[string] []*Conn이 아니라 map[string] []chan 타입.
• chan vs websocket.Conn 메모리 사용량 비교해봐야 할 듯? *Conn이 포인터라 더 적을 듯..?