netty기초 질문.

Question

안녕하세요.netty 를 공부하고 있습니다.nio 에코 서버 & 클라이언트를 생성하여 테스트를 하다가 이상한 점이 있어서 질문올립니다. 현재상황은 이렇습니다.클라이언트에서는 쓰레드 2개가 루프를 돌며, 서버로 문자열을 전송(writeAndFlush)합니다.1번쓰레드는 &#34;1&#34;2번쓰레드는 &#34;2&#34; 라는 문자열을 전송합니다. 서버에서는 클라이언트가 보낸 문자열을 print 합니다.그런데 이상한점은 1,2번 쓰레드가 동시에 전송(writeAndFlush) 를 했을때&#34;21&#34; 또는 &#34;12&#34; 라는 문자열로 돼 버리더군요. 서로다른 패킷을 동시에 보내게되면 합쳐져서 하나의 패킷로 처리 됐다는 얘긴데;;그렇다면 서버에서는 어떻게 구분해서 써야하나요..?;

앙앙이 · Answer

소켓은 싱글 쓰레드가 기본입니다.소켓을 공유하여 사용하는 멀티 쓰레드는 각오 단단히 하셔야 합니다. int thread-id &#61; 쓰레드 생성 순서; synchronized(socket) { write thread-id write 데이터 길이 write 데이터 } ----------- read thread-id read 데이터 길이 read 데이터 공부할때에는 우선적으로 소켓을 공유하지 않는 구조로 설계를 바꾸어서 시작해 보시기 권장해 드립니다.

taeWoo · Answer

가장 쉬운방법은 네티에 이니셜라이즈 클래스인가? 그부분에 개행문자 기준으로 메시지를 잘라서 받을 수 있게 하는 기능을 쓸 수 있어요.쓴지 오래되서 정확히 뭔진 기억이 안나는데 검색하면 금방나올꺼예요.

syapp · Answer

아.. 제가 서버 소켓쓰레드 를 멀티로 잡아둔모양이군요...하나의 소켓을 싱글쓰레드로 설정하는법 알아보도록하겠습니다두분다 답변 너무감사합니다

앙앙이 · Answer

// 자바라제 추정이지만 클라이언트에서 하나의 소켓을 멀티 스레드에서 사용하고 있어 생긴 문제 같습니다.

syapp · Answer

// 앙앙이네,앙앙님 말씀대로 한개의 소켓을 멀티쓰레드에서 사용하고 있긴합니다.그런데 대부분의 응용프로그램들이 한개소캣을 멀티쓰레드에서 써야하지 않나요?예를 들어..핑보내는 쓰레드나 주기적으로 서버에 어떤 request를 해야하는 경우에는 말이죠..그러다보면 언젠가는 동시에 보내는 부분이 겹칠거 같은데 ㅠ

nathak · Answer

1. 하나의 소켓으로 2개의 쓰레드가 공유하는 구조 2. 두개의 소켓으로 각각의 쓰레드가 사용하는 구조\ 님의 작성하신거는 1번의 경우인데요 특별한 상황이 아니라면 2번으로 해서 사용하세요..;

syapp · Answer

//nathak2번 방식으로 테스트 해보았습니다.ㅎ1:1(소켓) : (쓰레드)형태로 되어있구요.한개의 쓰레드에서 for문 돌면서 'a' 라는 문자열을 천번 보냈는데&#34;aa&#34; 라는 문자열이 간혹 발생하더라구요. 이건 netty 문제라기 보단, 소켓 프로그래밍에서 바이트스트림?에 있는 데이터를 어떤식으로 자를까의 문제라고 생각이 드는데요.혹시 이런 현상을 공부하거나 검색해 볼 수 있는 키워드나 링크 좀 걸어주시면 감사하겠습니다.

nathak · Answer

말씀하신 상황을 안나오게 하려면 가장 간편한 방법은 메시지 앞뒤로 구분자를 둬서 보내는거죠 socket STX, ETX 로 검색 한번 해보세요

syapp · Answer

//nathak감사합니다. ㅎ공부 후에 늦더라도 결과 올리도록 하겠습니다.

syapp · Answer

결과 올리겠습니다. ㅎ netty 의 코덱을 이용하였습니다.기존에는 netty에서 디폴트 디코더, ByteArrayDecoder를 사용했었는데.이번에는 ByteToMessageDecoder를 상속받아서 사용자 디코더를 만들었습니다.코드는 이렇습니다. import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelHandlerContext; import io.netty.handler.codec.ByteToMessageDecoder; import java.util.List; public class MessageDecoder extends ByteToMessageDecoder{ int headerSize &#61; 10; int bodySize &#61; 20; protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception { //아직 버퍼에 데이터가 충분하지 않다면 return if (byteBuf.readableBytes() < headerSize &#43; bodySize) { return; } byteBuf.markReaderIndex(); ByteBuf headerBuffer &#61; byteBuf.readBytes(headerSize); ByteBuf byteBuffer &#61; byteBuf.readBytes(bodySize); MessageObject obj &#61; new MessageObject(); obj.setHeader(headerBuffer.array()); obj.setBody(byteBuffer.array()); list.add(obj); } } 위와 같이 MessageObject 라는 객체단위로 끊어서 읽으니 바이트가 겹쳐서 오는 현상을 막을 수 있었습니다.답변해주신 모든분들 감사합니다^^

netty기초 질문.

10개의 답변

Q&A 목록