Netty 예제 분석 - Telnet

Telnet

http://docs.jboss.org/netty/3.2/xref/org/jboss/netty/example/telnet/package-summary.html

 
우선 클라이언트를 살펴보자.
main 함수에서 키보드로 입력한 데이터를 서버에 전송한다. 직접 서버에 데이터를 전송한다. 'bye' 를 칠때 까지 계속 전송한다. 'bye'를 치면 접속을 종료한다.

          // Read commands from the stdin.

          ChannelFuture lastWriteFuture = null;

          BufferedReader in = new BufferedReader(new InputStreamReader(System.in));

          for (;;) {

              String line = in.readLine();

              if (line == null) {

                  break;

              }

  

              // Sends the received line to the server.

              lastWriteFuture = channel.write(line + "\r\n");

  

              // If user typed the 'bye' command, wait until the server closes

              // the connection.

              if (line.toLowerCase().equals("bye")) {

                  channel.getCloseFuture().awaitUninterruptibly();

                  break;

              }

          }

TelnetClientPipelineFactory를 파이프라인 팩토리로 지정하고 있다.

          bootstrap.setPipelineFactory(new TelnetClientPipelineFactory());

Telnet ClientPipelineFactory는 4가지 핸들러를 등록하고있다.

          pipeline.addLast("framer", new DelimiterBasedFrameDecoder(

                  8192, Delimiters.lineDelimiter()));

          pipeline.addLast("decoder", new StringDecoder());

          pipeline.addLast("encoder", new StringEncoder());

  

          // and then business logic.

          pipeline.addLast("handler", new TelnetClientHandler());

DelimeterBasedFrameDecoder: 업스트림
StringDecoder: 업스트림
StringEncoder: 다운스트림
TelentClientHandler: 업스트림

데이터를 수신할 때 다음과 같은 순서로 이벤트를 처리한다.
DelimeterBasedFrameDecoder --> StringDecoder --> TelnetClientHandler

DelimeterBasedFrameDecoder :받은 데이터를 하나이상의 구분자로 짤라주는 디코더이다. 이 예제에서는 lineDelimeter 로 구분해서 짤라주는 역할을 한다.

StringDecoder :ChannelBuffer를 문자열로 변환해준다.

TelnetClientHandler은 서버로 부터 받은 데이터를 화면에 출력한다.

      @Override
      public void messageReceived(
              ChannelHandlerContext ctx, MessageEvent e) {
          // Print out the line received from the server.
          System.err.println(e.getMessage());
      }

자 이제 서버를 살펴보자. 분명 클라이언트측 핸들러들과 대응되는 핸들러들을 가지고 있을듯.

TelnetServierPipelineFactory를 보면 다음과 같다.

          pipeline.addLast("framer", new DelimiterBasedFrameDecoder(
                  8192, Delimiters.lineDelimiter()));
          pipeline.addLast("decoder", new StringDecoder());
          pipeline.addLast("encoder", new StringEncoder());
  
          // and then business logic.
          pipeline.addLast("handler", new TelnetServerHandler());

클라이언트로 부터 데이터를 수신할 때 클라이언트와 유사하게 DelimeterBasedFrameDecoder --> StringDecoder --> TelnetServerHandler 순으로 이벤트가 처리한다.

여기서는 TelnetClientHandler대신 사용된 TelnetServerHandler 를 살펴보면 되겠다.
그냥  요청받은 명령을 클라이언트에게 돌려주거나 bye 명령을 받은 경우 연결을 끊어준다. 

64 public void messageReceived(

              ChannelHandlerContext ctx, MessageEvent e) {
  
          // Cast to a String first.
          // We know it is a String because we put some codec in TelnetPipelineFactory.
          String request = (String) e.getMessage();
  
          // Generate and write a response.
          String response;
          boolean close = false;
          if (request.length() == 0) {
              response = "Please type something.\r\n";
          } else if (request.toLowerCase().equals("bye")) {
              response = "Have a good day!\r\n";
              close = true;
          } else {
              response = "Did you say '" + request + "'?\r\n";
          }
  
          // We do not need to write a ChannelBuffer here.
          // We know the encoder inserted at TelnetPipelineFactory will do the conversion.
          ChannelFuture future = e.getChannel().write(response);
  
          // Close the connection after sending 'Have a good day!'
          // if the client has sent 'bye'.
          if (close) {
              future.addListener(ChannelFutureListener.CLOSE);
          }