[Java NIO] 멀티 스레드 환경에서 Socket 으로 부터 read 한 내용을 Thread로 넘겨주는 방법 좀 알려주세요.
글쓴이: nexusz99 / 작성시간: 목, 2011/12/29 - 1:21오후
언어 : JAVA
환경 : NIO 의 Selector 를 이용하여 Non-blocking Socket 을 구현하였음. ( Client )
< 동작 구성 > 각 Thread 는 서버에게 데이터를 보내고 다시 Request 를 받는다.
< 문제점 > Selector 를 통해 Socket 에서 읽어들인 데이터가 어느 Thread 로 가야하는 데이터인지 판별이 불가능한 상태입니다. 서버는 각 Thread 의 데이터가 어차피 하나의 클라이언트에서 나온 데이터 이기 떄문에 상관이 없는데, 클라이언트에서 서버에서 온 데이터가 어느 Thread 로 전달되어야 하는지 판별할 수 없네요. 어떻게 해야 할까요??
서버로 보내는 데이터 : 각종 명령어
Request 데이터 : 서버에서 명령어를 처리한 후 반환값.
Forums:
NIO에서는...
Java NIO의 성능은 좋지만 처음부터 끝까지 구현하기에는 다소 어려움이 따르죠.
만약, 프로젝트에 적용하신다면 개인적으로는 Apache의 MINA 또는 JBoss의 Netty를 추천 드립니다. 일정과 인수인계 시 정신건강에 좋습니다. :-)
개인적인 생각으로는 두가지 방법이 있을 텐데요..
1. Thread내 Selector
- OP_READ, OP_WRITE를 처리할 수 있게 처리
2. 단일 Selector사용의 경우
- SelectableChannel의 register(Selector, int, Object)와
SelectionKey의 attachment(void)를 활용해보시면 될 것 같습니다.
Reactor pattern을 구현하시고 계시는걸로
Reactor pattern을 구현하시고 계시는걸로 보이네요. 제가 기억하는 바로는,
ACE의 Reactor 구현에서는, socket fd를 key로 하여
binary tree를 구성하고,
읽은 데이터를 dispatch합니다.
어느 Thread로 전달해야하는지 판별할수없다고요?
socket FD를 키로 가지고, session을 value로 가지는 binary-tree structure를 가지시고,
acceptor에서 새로운 연결을 받을 때 마다
그 binary-tree에 accept()된 FD를 키로 삼아, session data structure 추가합니다.
worker-thread는 새로운 session-data가 추가될 때마다, 혹은 이미 존재하는 session에 새로운 데이터가 추가될 때마다,
pthread_cond_wait()혹은 busy-waiting 등등의
synchronization mechanism 을 이용해서, reactor-thread로 부터 notify를 받은후,
해당 작업을 처리합니다.
어느 worker-thread에 notify를 하느냐고 묻으신다면,
session data-structure에 현재 처리하고 있는, 또는 담당하고 있는 worker-thread의 정보를 저장해놓으시면 됩니다.
사실, 위에 설명한 내용만으로 reactor pattern을 바로 이해하기는 힘드실수도 있습니다.
하지만, reactor pattern을 모르시고,
1 * socket I/O thread
m * worker-thread
구조를 만드시려고 하는것 자체가 아이러니 할수 있습니다.
http://en.wikipedia.org/wiki/Reactor_pattern
위 문서를 보시고, reactor pattern에 대해서 좀 더 공부를 하시면
어떻게 대부분의 프로그램들이 select()/poll()/epoll/kqueue 등을 사용하시는지 깨우치실 겁니다.
댓글 달기