따라하면 되는 Netty 기반 EchoServer 예제

💡 비동기 이벤트 기반 네트워크 애플리케이션 프레임워크인 Netty를 학습하며 EchoServer를 구축할 수 있다.

 

📌 Netty import 세팅

방법 1. Maven dependency를 추가해주는 방법 (링크)

방법 2. Java Build path > Libraries > Add External JARs, 라이브러리 등록하는 방법 (링크)

netty-all-4.1.6.Final.jar

3.37MB

 

 

파일 구성

- EchoServer.java

- EchoServerHandler.java

 

📌 EchoServer.java

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.logging.LogLevel;
import io.netty.handler.logging.LoggingHandler;
import io.netty.handler.ssl.SslContext;
import io.netty.handler.ssl.SslContextBuilder;
import io.netty.handler.ssl.util.SelfSignedCertificate;
public final class EchoServer {

    static final boolean SSL = System.getProperty("ssl") != null;
    static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));

    public static void main(String[] args) throws Exception {
        // Configure SSL.
        final SslContext sslCtx;
        if (SSL) {
            SelfSignedCertificate ssc = new SelfSignedCertificate();
            sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();
        } else {
            sslCtx = null;
        }

        // Configure the server.
        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        final EchoServerHandler serverHandler = new EchoServerHandler();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .option(ChannelOption.SO_BACKLOG, 100)
             .handler(new LoggingHandler(LogLevel.INFO))
             .childHandler(new ChannelInitializer() {
                 @Override
                 public void initChannel(SocketChannel ch) throws Exception {
                     ChannelPipeline p = ch.pipeline();
                     if (sslCtx != null) {
                         p.addLast(sslCtx.newHandler(ch.alloc()));
                     }
                     //p.addLast(new LoggingHandler(LogLevel.INFO));
                     p.addLast(serverHandler);
                 }
             });

            // Start the server.
            ChannelFuture f = b.bind(PORT).sync();

            // Wait until the server socket is closed.
            f.channel().closeFuture().sync();
        } finally {
            // Shut down all event loops to terminate all threads.
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
}

 

📌 EchoServerHandler.java

import java.nio.charset.Charset;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandler.Sharable;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

/**
 * Handler implementation for the echo server.
 */

@Sharable
public class EchoServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
    	String message = ((ByteBuf) msg).toString(Charset.defaultCharset());
    	System.out.println("Server 수신한 문자열: " + message);
    	
        ctx.write(msg);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        ctx.flush();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        // Close the connection when an exception is raised.
        cause.printStackTrace();
        ctx.close();
    }
}

 

📌 Telnet 클라이언트 기능 켜기

윈도우 검색 > windows 입력 > windows 기능 켜기/끄기 

> 텔넷 클라이언트 체크 표시

 

EchoServer.java에서 Run을 합니다.

 

명령 프롬프트를 실행시키고 telnet localhost 8007 입력

Telnet localhost로 접속했음을 확인할 수 있다.

hello 입력

입력한 문자열을 Echo하는 것을 확인할 수 있다.

수신한 문자열이 이클립스 콘솔에 찍힌다.

EchoServer Console

ctrl + ] 를 입력하면 다음과 같은 상태가 된다.

q를 입력해 텔넷 세션에서 빠져나올 수 있다.

 

 

 

 

📌 개선 EchoServerHandler.java

+) 엔터를 입력해 한 줄의 문자열을 수신하는 코드로 개선할 수 있다.

@Sharable
public class EchoServerHandler extends ChannelInboundHandlerAdapter {
	StringBuilder builder = new StringBuilder();
	
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
    	String message = ((ByteBuf) msg).toString(Charset.defaultCharset());
    	builder.append(message);
    	
    	int command = message.toLowerCase().charAt(0) - 'a';
    	if(command == -84) {
        	System.out.println("Server 수신한 문자열: " + builder.toString());
        	builder = new StringBuilder();
    	}
    	
		ctx.write(msg);
    }
    ...
}

문자열 입력 후 엔터 입력 시 문자열을 수신한다.

EchoServer Console

 

(책 『자바네트워크 소녀 네티』의 예제)

GitHub - krisjey/netty.book.kor: 자바 네트워크 소녀 네티 예제