[java] 자바 네티 (Java Netty)에서 UDP 통신을 구현하는 방법은?

15 Nov 2023

java

Netty는 Java로 구현된 고성능 네트워크 프레임워크로, TCP 및 UDP와 같은 다양한 프로토콜의 통신을 구현할 수 있습니다. UDP(Universal Datagram Protocol)는 비연결형 프로토콜로, 데이터그램을 사용하여 통신을 수행합니다.

자바 네티에서 UDP 통신을 구현하려면 다음 단계를 따를 수 있습니다.

단계 1: Maven 종속성 추가

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.66.Final</version>
</dependency>

위의 Maven 종속성을 프로젝트의 pom.xml 파일에 추가하여 Netty를 사용할 수 있도록 해야 합니다.

단계 2: UDP 서버 구현

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.DatagramChannel;
import io.netty.channel.socket.nio.NioDatagramChannel;

public class UDPServer {
    public static void main(String[] args) throws InterruptedException {
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            Bootstrap bootstrap = new Bootstrap();
            bootstrap.group(group)
                    .channel(NioDatagramChannel.class)
                    .option(ChannelOption.SO_BROADCAST, true)
                    .handler(new ChannelInitializer<DatagramChannel>() {
                        @Override
                        protected void initChannel(DatagramChannel ch) throws Exception {
                            ch.pipeline().addLast(new UDPChannelHandler());
                        }
                    });

            bootstrap.bind(8888).sync().channel().closeFuture().sync();
        } finally {
            group.shutdownGracefully();
        }
    }

    private static class UDPChannelHandler extends ChannelInboundHandlerAdapter {
        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            // 클라이언트로부터 수신된 데이터 처리
            ctx.writeAndFlush(msg);
        }
    }
}

위의 예제 코드는 UDP 서버를 구현하는 방법을 보여줍니다. channelRead 메소드에서 클라이언트로부터 수신된 데이터를 처리할 수 있습니다. 이 예제에서는 수신된 데이터를 그대로 클라이언트에게 다시 전송하도록 구현되어 있습니다.

단계 3: UDP 클라이언트 구현

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.DatagramChannel;
import io.netty.channel.socket.nio.NioDatagramChannel;
import io.netty.util.CharsetUtil;

public class UDPClient {
    public static void main(String[] args) throws InterruptedException {
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            Bootstrap bootstrap = new Bootstrap();
            bootstrap.group(group)
                    .channel(NioDatagramChannel.class)
                    .option(ChannelOption.SO_BROADCAST, true)
                    .handler(new ChannelInitializer<DatagramChannel>() {
                        @Override
                        protected void initChannel(DatagramChannel ch) throws Exception {
                            ch.pipeline().addLast(new UDPChannelHandler());
                        }
                    });

            ChannelFuture future = bootstrap.bind(0).sync();
            future.channel().writeAndFlush("Hello, UDP Server!".getBytes(CharsetUtil.UTF_8));
            future.channel().closeFuture().sync();
        } finally {
            group.shutdownGracefully();
        }
    }

    private static class UDPChannelHandler extends ChannelInboundHandlerAdapter {
        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            // 서버로부터 수신된 데이터 처리
            String response = new String(((ByteBuf) msg).array(), CharsetUtil.UTF_8);
            System.out.println("서버 응답: " + response);
        }
    }
}

위의 예제 코드는 UDP 클라이언트를 구현하는 방법을 보여줍니다. 클라이언트에서는 서버로 데이터를 전송하고, 서버로부터 수신된 데이터를 처리하여 출력합니다.

이제 Netty를 사용하여 자바로 UDP 통신을 구현하는 방법을 알게 되었습니다. 자신의 요구에 맞게 코드를 수정하고, 추가적인 기능을 구현할 수 있습니다.

참고 자료: