기존 C/S 통신을 WebSocket 통신으로 변경하려고 합니다.

[미세먼지]

안녕하세요. 처음 글부터 복잡해서 죄송합니다.

Netty는 [자바 네트워크 소녀 Netty] 책으로 입문했지만 WebSocket 쪽은 다루지 않아서 몇주째 시행착오를 되풀이하고 있습니다. 더 이상은 Netty 소스를 봐서도 잘 파악되지 않아 도움을 부탁드립니다.

기존 C/S 통신에서는 Java VO를 Json을 이용해서 Encode/Decode 했습니다.

기존 C/S 통신 관련 소스입니다.

우선 부트스트랩 관련 함수입니다 :

  private ChannelFuture bindServerBootstrap(final ServerBootstrap sb, final EventLoopGroup parentGroup,

          final EventLoopGroup childGroup, final int timeOut, final int port) throws Exception {

    sb.group(parentGroup, childGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG, 100)

            .childOption(ChannelOption.SO_KEEPALIVE, true).handler(new LoggingHandler(LogLevel.INFO))

            .childHandler(new ChannelInitializer<SocketChannel>() {

              @Override

              protected void initChannel(SocketChannel sc) throws Exception {

                ChannelPipeline cp = sc.pipeline();

                cp.addLast("idleStateHandler_1", new IdleStateHandler(0, timeOut, timeOut, TimeUnit.SECONDS));

                cp.addLast("idleStateHandler_2", new NettyIdleStateHandler());

                cp.addLast("encoder", new JsonObjectEncoder());

                cp.addLast("decoder", new JsonObjectDecoder());

                cp.addLast("inbound_1", heartBeatHandler);

                cp.addLast("inbound_2", loginHandler);

                cp.addLast("inbound_3", requestHandler);

              }

            });

    final ChannelFuture cf = sb.bind(port);

    final Channelfuture cfSync = cf.sync();

    final io.netty.channel.Channel ch = cfSync.channel();

    final ChannelFuture chClose = ch.closeFuture();

    return chCloseFuture;

  }

여기서 JsonObjectEncoder/Decoder는 

Java VO <-> Class Name | Json String 으로 Encode/Decode하도록 되어 있고요.

(다른 분이 개발하신 것을 물려받았습니다.)

그래서 loginHandler 등 Channel Inbound Handler (모두 ChannelInboundHandlerAdapter 상속) 들에서는 public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception 메소드의 msg 인자로 Java VO 가 옵니다.

이번에 C/S 대신 클라이언트만 웹으로 바꾸면서 WebSocket 기반으로 통신을 변경하려고 하는데요.

일단 부트스트랩쪽 함수를 이렇게 바꿨습니다 :

  private ChannelFuture bindServerBootstrapWS(final ServerBootstrap sb, final EventLoopGroup parentGroup,

          final EventLoopGroup childGroup, final int timeOut, final int port) throws Exception {

    sb.group(parentGroup, childGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG, 100)

            .childOption(ChannelOption.SO_KEEPALIVE, true).handler(new LoggingHandler(LogLevel.INFO))

            .childHandler(new ChannelInitializer<SocketChannel>() {

              @Override

              protected void initChannel(SocketChannel sc) throws Exception {

                ChannelPipeline cp = sc.pipeline();

                //  cp.addLast("codec", new HttpServerCodec()); // HttpClientCodec과 차이가 무엇인지

                cp.addLast("decoder", new JsonHttpRequestDecoder());

                cp.addLast("aggregator", new HttpObjectAggregator(64*1024));

                cp.addLast("encoder", new JsonHttpResponseEncoder());

                cp.addLast("chunked", new ChunkedWriteHandler());

                cp.addLast("decompressor", new HttpContentDecompressor());

                cp.addLast("websocket", new WebSocketServerProtocolHandler("/ws"));

                cp.addLast("inbound_1", testHandler); // idleHandler는 일단 제외했습니다

              }

            });

    final ChannelFuture cf = sb.bind(port);

    final Channelfuture cfSync = cf.sync();

    final io.netty.channel.Channel ch = cfSync.channel();

    final ChannelFuture chClose = ch.closeFuture();

    return chCloseFuture;

  }

JsonHttpRequestDecoder / JsonHttpResponseEncoder 는 각각 HttpRequestDecoder / HttpResponseEncoder 를 상속받아서 만든 클래스입니다.

이렇게 해놓고 보니 testHandler의 public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception 메소드의 msg 인자로 TextWebSocketFrame 이 오더라고요.

testHandler (NettyTestHandler 클래스) 에서 Echo 를 보내게 해서 Web Broswer에서 제대로 나오는 것까지는 확인을 했는데요.

실제로 메시지는 Java VO -> Class Name | Json String 로 만들어서 보낼 것이라서, 기존의 JsonObjectEncoder/Decoder 처럼 JsonHttpRequestDecoder / JsonHttpResponseEncoder 에서 Class Name과 Json 까지 처리하려고 했습니다.

그런데 이게 HttpRequestDecoder / HttpResponseEncoder 를 상속받아서는 그렇게 구현을 할 수가 없는 것 같아, 방법을 문의드립니다.

기존 C/S의 JsonObjectDecoder는 LengthFieldBasedFrameDecoder 를 상속받고 

protected Object decode(ChannelHandlerContext ctx, ByteBuf in) throws Exception 메소드에서 Java VO를 리턴하면 이것이 그대로 Inbound Handler의 channelRead 인자로 전달되었는데요.

WebSocket 쪽에서는 JsonHttpRequestDecoder 가 HttpRequestDecoder 를 상속받아봤더니, decode 메소드 자체가 protected void decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) throws Exception 로 되어 있어서, 여기서 Java VO를 만들어내도 Inbound Handler에 전달할 방법을 모르겠더군요.

말이 길어져서 죄송합니다.

아무튼 WebSocket 통신으로 변경한 후에도 

메시지는 Class Name | Json String 포맷으로 유지하고,

Channel Inbound Handler에서는 msg를 Java VO 형태로 받게 하는게 목적입니다.

그런데 Decoder/Encoder를 HttpRequestDecoder / HttpResponseEncoder 를 상속받아서는 그렇게 개발할 수가 없는 것 같아서, 방법을 문의드립니다.

미리 감사드립니다.