[Netty] Start Netty Programming 2 - Event Handler

public interface ChannelInboundHandler extends ChannelHandler {

    /**
     * 1) 서버 기준으로 처음 서버소켓 채널이 생성될 때
     * 2) 새로운 클라이언트가 서버에 접속하여 클라이언트 소켓 채널이 생성될때 이벤트가 발생한다.
     */
    void channelRegistered(ChannelHandlerContext ctx) throws Exception;

    /**
     * 이벤트 루프에서 채널이 제거되었을 때 발생하는 이벤트
     */
    void channelUnregistered(ChannelHandlerContext ctx) throws Exception;

    /**
     * channelRegistered() 이벤트 후에 발생한다.
     * 채널이 생성되어 이벤트 루프에 등록된 이후에 네티 API를 사용하여 채널 입출력을 수행할 상태가 되었다를 알려준다.
     *
     * ex) 서버 어플에 연결된 클라이언트의 연결 세기, 최초 연결메시지 전달 
     */
    void channelActive(ChannelHandlerContext ctx) throws Exception;

    /**
     * 채널이 비활성화 되었을때 발생하는 이벤트
     * channelInactive 가 발생한 이후에는 채널에 대한 입출력 작업을 수행할 수 없다.
     */
    void channelInactive(ChannelHandlerContext ctx) throws Exception;

    /**
     * 데이터가 수신되었음을 알려준다.
     * 수신된 데이터는 네티의 ByteBuf 객체에 저장되어 있으며 이벤트 메서드의 두번째 인자인 msg를 통해서 접근할 수 있다. 
     * 
     */
    void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception;

    /**
     * channelRead 이벤트는 채널에 데이터가 있을 때 발생하고 
     * 채널의 데이터를 다 읽어서 더 이상 데이타가 없을 때 channelReadComplete 이벤트가 발생한다.
     */
    void channelReadComplete(ChannelHandlerContext ctx) throws Exception;

    /**
     * Gets called if an user event was triggered.
     */
    void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception;

    /**
     * Gets called once the writable state of a {@link Channel} changed. You can check the state with
     * {@link Channel#isWritable()}.
     */
    void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception;

    /**
     * Gets called if a {@link Throwable} was thrown.
     */
    @Override
    @SuppressWarnings("deprecation")
    void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception;
}

public interface ChannelOutboundHandler extends ChannelHandler {
    /**
     * 서버 소켓 채널이 클라이언트의 연결을 대기하는 IP와 포트가 설정되었을 때 발생하는 이벤트
     */
    void bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) throws Exception;

    /**
     * 클라이언트 소켓 채널이 서버와 연결되었을 때 발생하는 이벤트 
     * 원격지의 SocketAddress, 로컬의 SocketAddress 정보가 인수로 입력된다.
     */
    void connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) throws Exception;

    /**
     * 클라이언트 소켓 채널의 연결이 끊어졌을 때 발생
     */
    void disconnect(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception;

    /**
     * 클라이언트 소켓 채널의 연결이 닫혔을 때 발생
     */
    void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception;

    /**
     * Called once a deregister operation is made from the current registered {@link EventLoop}.
     */
    void deregister(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception;

    /**
     * 
     */
    void read(ChannelHandlerContext ctx) throws Exception;

    /**
     * 소켓 채널에 데이터가 기록되었을 때 발생한다. 
     * wirte 이벤트에는 소켓 채널에 기록된 데이터 버퍼가 인수로 입력된다.
     */
    void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception;

    /**
     * 소켓 채널에 대한 flush 메소드가 호출되었을 때 발생한다.
     */
    void flush(ChannelHandlerContext ctx) throws Exception;
}

ChannelFuture f = b.bind(8888).sync();
f.channel().closeFuture().sync();

// 비동기 bind()를 호출한다. 포트 바인딩이 완료되기 전에 ChannelFuture 객체를 돌려준다.
ChannelFuture bindFuture = b.bind(8888);
// 주어진 ChannelFuture 객체의 작업이 완료될 때까지 블로킹한다.
// bind() 가 완료되면 sync() 도 완료된다.
bindFuture.sync();

// bindFuture 객체를 통해 채널을 얻어온다. 여기서 얻은 채널은 8888번 포트에 바인딩된 서버 채널이다.
Channel serverChannel = bindFuture.channel();
// 바인드가 완료된 서버 채널의 closeFuture 객체를 돌려준다.
// 내티 내부에서 채널이 생성될 때 closeFuture 객체도 같이 생성되므로 
// closeFuture()가 돌려주는 closeFuture 객체는 항상 동일한 객체이다.
channelFuture closeFuture = serverChannel.closeFuture();
// closeFuture 객체는 채널의 연결이 종료될 때 연결 종료 이벤트를 받는다.
closeFuture.sync();