인프런 커뮤니티 질문&답변

안녕하세요 질문 남겨주셔서 감사합니다. 일단 우선적으로 제가 현재 소스코드를 날려먹은 상태여서... ㅠㅠ 정확한 부분은 코드를 봐야 알수가 있는 부분인거 같습니다. 혹시라도 제가 답변해 드리는 내용에 대해서 이해가 잘 안되신다면 관련하여 코드도 첨부해 주시면 감사하겠습니다.

해당 질문에 대해서는 먼저 스펙에 대한 기준이 필요할꺼같습니다.

플랫폼을 구성하는데에 있어서 큰 서비스를 운영하는지, 아니면 간단한 서비스인지에 대해서 관점이 달라지는거 같습니다.

큰 서비스를 운영한다면, 기본적으로 메시지 처리를 채널로 하지 않습니다. 데이터 유실에 대해서도 어느정도의 책임을 가지고 있어야하기 떄문에, 보통 저런 구조에서의 채널을 Kafka를 적용하여 관리를 하게 됩니다.

• 물론 내부적으로 코드에서는 채널을 통해 무언가를 처리해도 무방합니다.

이러한 관점이 중요한 부분은 서비스에 대해서 오버 스펙을 굳이 구현 할 필요는 없기 떄문입니다. 회사에서의 비용절감도 어느정도 중요한 부분이기 떄문이에요.

• 그래서 실제로 Kafka를 안써보신 분들도 꽤나 있는걸로 알고 있습니다.

하지만 작은 서비스라면, 사실 어떻게 관리를 하든 무방합니다. 그래서 저는 개인적으로 장단점이 있는거 같아요.

여러개의 고루틴을 관리하는것은 쉽지가 않지면, 병렬적으로 좀 더 가볍게 처리 가능한 장점이 있습니다. 하지만 그에 따라서 개발자가 고생을 많이 하는 형태라고 생각을 합니다.

하나의 루틴을 통해서 관리하는것은 간단하지만 아무래도 데이터의 사이즈가 커지기 떄문에 병목이나 문제가 생길 수 있는 부분이 꽤나 발생할꺼같습니다.

개인적으로는 최적화를 위해서는 병렬적인 처리가 더 좋다고 생각을 해요. 하지만 실무에서는 최적화도 중요하지만, 유지 관리의 가능성도 잘 잡고 있어야 하기 떄문에, 상황에 따라서 달라지는거 같습니다.

• 내가 정말 자신있다고 생각을 한다면 병렬적으로 하시는게 맞다고 생각을 합니다. 하지만 어느정도 팀내의 레거시를 따라야한다거나, 팀 내에서의 코드 작성이 자신이 없다면 하나에서 관리를 해도 무방합니다.

하지만 결론적으로는 최선의 방법은 kafka를 통해서 관리하는것입니다. 이 강의에서 사용한 방법은 Kafka까지 가게 된다면 수강하시는 분들이 너무 어려워하실꺼 같아 다루지는 않았습니다.

혹시 제가 잘못된 답변을 드렸거나 엉뚱한 소리를 했다면 한번 더 질문 남겨주시면 감사하겠습니다.

좋은 주말 보내세요 :)

카프카는 서버와 서버 사이에 존재하는 브로커 아닌가요?

코드가 좀 지저분하게 올라가네요 ㅠㅠ

빠른 답변해주셔서 정말 감사합니다.
제 질문은 유저의 메시지를 받아서 c.Room.Forward <- msg
부분 처럼, Foward채널에 송신하고 RunInit() 고루틴에서 처리하도록 하는 부분이 체계적이고 유지보수성이 높아지는 장점이 있는 반면에, 수천, 수만명의 커넥션으로 발생한 고루틴들이 메시지 채널에 동시 다발적으로 데이터를 송신할 경우 이 메시지 채널을 수신하는 단 하나의 RunInit()고루틴이 감당 가능한가에 대한 질문이었습니다. 물론 소규모 서비스에서는 동시 요청 수가 적어서 괜찮겠지만, 스트레스 테스트를 진행한다면, 분명 저부분이 병목 포인트일 거라 생각했습니다. 이러한 구조를 사용하는 것을 강사님 소스코드 포함해서 여러번 봤기 때문에, 왜 굳이 Read()에서 각 요청을 담당하는 고루틴이 직접 처리하면되지 c.Room.Forward <- msg과 같이 채널에 넘기는 걸까?라는 의문이 생겼던 겁니다. 제 질문을 좀더 명확히 하기 위해 소스코드를 첨부드립니다.


func (c client) Read() { // 클라이언트가 들어오는 메시지를 읽는 함수 defer c.Socket.Close() for { var msg message err := c.Socket.ReadJSON(&msg) if err != nil { if !websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway) { break } else { panic(err) } } else { log.Println("READ : ", msg, "client", c.Name) log.Println() msg.Time = time.Now().Unix() msg.Name = c.Name c.Room.Forward <- msg } } }

func (r *Room) RunInit() { // Room에 있는 모든 체널값을을 받는 역할 for { select { case client := <-r.Join: r.Clients[client] = true case client := <-r.Leave: r.Clients[client] = false close(client.Send) delete(r.Clients, client) case msg := <-r.Forward: for client := range r.Clients { client.Send <- msg } } } }

안녕하세요, 인프런 AI 인턴입니다.

김영민님의 질문에 대해 유사한 기존의 답변을 찾아보니, 웹소켓 서버 설계와 관련하여 고루틴, 메시지 채널 관리의 효율적인 사용에 대한 논의가 존재합니다. 이에 대한 구체적인 답변을 드리겠습니다.

웹소켓 서버에서 대량의 트래픽을 처리하기 위해서는 효율적인 메시지 채널 관리가 중요합니다. RunInit() 같은 고루틴을 통해 메시지 채널을 관리하는 것은 일반적인 패턴인데, 이는 병목 현상을 완화하고 코드 구조를 명료하게 만들어 줍니다. 그러나, 트래픽의 양에 따라 고루틴 수를 조절하여 병목을 줄일 필요가 있습니다. 병목이 우려되는 상황이라면, RunInit()을 여러 고루틴으로 분산시키는 방법을 고려해 볼 수 있습니다.

관련하여 더 나은 이해를 돕기 위해 참고할 만한 답변 URL이 있습니다:

1. 몇천명이 Room 에 동시접속할 수 있도록 설계하려면 어떤 것들이 필요할까요?: 이 질문에서는 대규모 트래픽 처리에 적합한 서버 확장 및 관리 전략에 대해 설명합니다.
   
2. 소켓 서버의 수평적 확장 및 무중단 배포에 대해 질문드립니다!: 소켓 서버 스케일링 및 효율적인 서비스 운영에 대한 부분에 대해 심층적으로 논의합니다.
   

이 자료들을 통해 김영민님의 질문에 대한 해답을 얻을 수 있을 것입니다. 추가적으로 궁금한 점이 있으시면, 이어서 질문을 주시면 강사님께서도 구체적인 내용을 답변해 주실 것입니다.

저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다.
현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏
추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.