WebSocket + Stomp + RabbitMQ로 채팅 구현

Question

채팅 기능 구현하고 JMeter로 성능 비교하는 과정에서 스프링부트 내장 메시지 브로커를 사용하면 쓰레드 100 기준 오류없이 무난하게 돌아가는데 RabbitMQ 사용하니까 성능도 떨어질 뿐더러 중간중간java.net.SocketException: Connection reset at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(SocketChannelImpl.java:394) ~[na:na] at java.base/sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:426) ~[na:na] at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:255) ~[netty-buffer-4.1.114.Final.jar:4.1.114.Final] at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132) ~[netty-buffer-4.1.114.Final.jar:4.1.114.Final] at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:356) ~[netty-transport-4.1.114.Final.jar:4.1.114.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151) ~[netty-transport-4.1.114.Final.jar:4.1.114.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) ~[netty-transport-4.1.114.Final.jar:4.1.114.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) ~[netty-transport-4.1.114.Final.jar:4.1.114.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) ~[netty-transport-4.1.114.Final.jar:4.1.114.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) ~[netty-transport-4.1.114.Final.jar:4.1.114.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) ~[netty-common-4.1.114.Final.jar:4.1.114.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.114.Final.jar:4.1.114.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.114.Final.jar:4.1.114.Final] at java.base/java.lang.Thread.run(Thread.java:842) ~[na:na]이런 오류가 발생하고 2000개의 메시지가 DB에 저장되어야 하는데 1600개 정도만 저장됩니다... 혹시 이유를 아시는 분 도움을 주세요 ㅠㅠ

개발자가아닌조립자 · Answer

RabbitMQ는 Que기반 이기 때문에 Latency가 발생합니다. 부하 발생으로 오류가 생겼을 가능성이 유추되네요.실시간 채팅인데 왜 RabbitMQ를 사용하셨는지 여쭤봐도될까요? 제가 아는 다른 부분이 있을 수 있으니추가) Redis pub/sub 혹은 그냥 Websocket과 Stomp만 써도 구현에 문제가 없을듯합닏다만..

WebSocket + Stomp + RabbitMQ로 채팅 구현

1개의 답변

#websocket 목록