[netty] bootstrap.connect() 후 처리 관련.

현재 netty3.8.0_final을 사용 중에 있는데,

netty에서 Bootstrap 생성, 설정 한 후, connect() 를 하고 동기식으로 다음 로직을 실행할 때

원래는 외부에 connect()의 결과를 리턴 해 주기 위해 아래처럼 await 관련 메소드를 썼었는데, 이럴 경우, 하나의 프로그램에서 여러 netty클라이언트를 사용해서 처리할 경우, dead lock이 걸릴 수도 있다는 예외(?)를 netty가 친절(?)하게 알려 준다. ㅜㅜ;

// Wait until the connection attempt succeeds or fails.

ChannelFuture future = bootstrap.connect(new InetSocketAddress(host, port));

channel = future.awaitUninterruptibly().getChannel(); // <-- 여기가 문제임.

if (!future.isSuccess()) {

    future.getCause().printStackTrace();

    bootstrap.releaseExternalResources();

    logger.info("Failed connect to Server. channel["+ channel +"]");

    return false;

}else {

    logger.info("Success connect to Server. channel["+ channel +"]");

    return true;

}

예외 메세지는 요렇다.

java.lang.IllegalStateException: await*() in I/O thread causes a dead lock or sudden performance drop. Use addListener() instead or call await*() from a different thread.

어쩌구저쩌구...

반드시 동기식으로 진행되어야 하는 상황이 아니라면 아래처럼 리스너를 등록해서 netty가 던져주는 이벤트를 받아서 처리해 주도록 한다.

ChannelFuture future = bootstrap.connect(new InetSocketAddress(host, port));

future.addListener(new ChannelFutureListener() {

    @Override

    public void operationComplete(ChannelFuture future) throws Exception {

        if (!future.isSuccess()) {

            future.getCause().printStackTrace();

            bootstrap.releaseExternalResources();

    logger.info("Failed connect to Server.");

        }else {

    channel = future.getChannel();

   Client.this.listener.connectedToServer(); // <-- 연결된 후에 상위에서 뭔가를 처리해야 할 때 이렇게 콜백을 이용할 수도 있다.

    logger.info("Success connect to Server.");

        }

    }

});

좀더 해 보니, connect() 뿐만 아니라 close() 와 bootstrap.releaseExternalResources() 도 임의로 호출하면 안되고 리스너를 통해서 호출이 되도록 해야 예외발생이 안 된다.~!!!

그리하야~ close() 와 관련된 리스너는 아래와 같이 했다.

if( channel != null ) {

    ChannelFuture future = channel.close();

    future.addListener(new ChannelFutureListener() {

        @Override

        public void operationComplete(ChannelFuture chFuture) throws Exception {

    if( !chFuture.isSuccess() ) {

        chFuture.getCause().printStackTrace();

                bootstrap.releaseExternalResources();

                logger.error("Failed close to Server");

            }else {

        Client.this.listener.closedToServer(); // <-- 역시나 종료 후 상위에서 뭔가를 처리해야 할 때 콜백 사용~

                logger.debug("Success close to Server.");

                // Shut down all thread pools to exit.

                if( bootstrap != null ) {

                bootstrap.releaseExternalResources();

        bootstrap = null;

             }

                logger.debug("Success bootstrap.releaseExternalResources().");

            }

        }

    });

}

정말 멀고도 험한 네트워킹의 길.. 정말 강호의 고수님들에게 경의를 표한다. :)