카프카를 이용한 채팅 서비스 tps에 관해서..

Question

카프카의 비동기, 분산처리로 웹소켓으로만 구현했을 때보다 카프카를 이용하면 tps가 250% 성능 향상이 된다는 글을 보고 시도하게 되었습니다.그래서 spring 의 websocket 을 이용해서 채팅서비스를 구현하고 메세지가 들어오면 카프카에 보내서 컨슘에 들어오면 로직을 처리하게 만들었습니다. 카프카는 파티션 3개로 나누었습니다.그리고 jmeter로 200명 유저가 1초동안 20번 메세지를 발행하는 것으로 부하테스트를 해보았는데, 웹소켓으로만 사용했을 때 185/s 카프카를 사용했을 때 180/s 결과가 나왔습니다.m2 16g 를 사용하는데, 서버 스펙이 낮기 때문에 이러한 결과가 나오는 것인지. 카프카를 이용하던 말던 어차피 로직을 처리하는 것은 스프링의 동기 처리방식이라 그런건지. 제가 잘못 이해하고 구현한것이지 궁금합니다 !!

집킨 · Answer

기존에 어떻게 구현했었는지에 따라 다릅니다추측해보면 메세지를 따로 보관해두진 않았던거 같은데 그러면 성능 관점에서 카프카라는 성능 병목이 생긴겁니다그 글 내용의 맥락이 궁금한데 링크공유가능할까요?

캐티 · Answer

카프카를 사용하지 않지만 결과적으로 프로토콜과 파이프라인을 잘 이해하고 이어야 하지 않겠나요.tcp 제어나 웹소켓 방식은 빠른데요. 현재는 더 빠른 udp기반에 quic이 대안으로 나와있어요.이것과 별개로 최종 자바인지 스프링인지 이 서버에서 응답을 빠르게 처리하여야 해요. 스프링에서 하였다면 http 메세지를 해독하는 과정이 지연 이유가 될 수 있을 것 같습니다. 원래는 연결을 업그래이드하여 다른 프로토콜로 처리하거나 가벼운 프로토콜을 사용하여야 하겠쩌. 이렇고 분산하는 것은 애초부터 독립되었거나 논리적으로 나누어진 시스템으로 구축하지 않나요.

MuDaeng · Answer

구현해봤다에서 이미 잘하고있네요

카프카를 이용한 채팅 서비스 tps에 관해서..

3개의 답변

#tps 목록