import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.CharsetUtil;

/**
 * 自定义的服务端类
 * 1. 注解标识可以被多个 channel 安全的共享。
 * @author binbin.hou
 * @date 2019/3/31
 * @since v1
 */
@ChannelHandler.Sharable
public class EchoServerHandler extends ChannelInboundHandlerAdapter {

    /**
     * 信息读取
     * @param ctx 上下文
     * @param msg 消息
     * @throws Exception if any
     */
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        ByteBuf byteBuf = (ByteBuf)msg;
        final String string = byteBuf.toString(CharsetUtil.UTF_8);
        System.out.println("Echo server received: " + string);

        // 将接收到的消息，写给发送者
        ctx.write(byteBuf);
    }

    /**
     * 消息读取完成
     * @param ctx 上下文
     * @throws Exception if any
     */
    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        //将未处理的消息冲刷到远程
        // 关闭当前 channel
        ctx.writeAndFlush(Unpooled.EMPTY_BUFFER)
                .addListener(ChannelFutureListener.CLOSE);
    }

    /**
     * 异常处理
     * 1. 处理异常消息
     * 2. 关闭 channel
     * @param ctx 上下文
     * @param cause 原因
     * @throws Exception if any
     */
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        System.err.println("异常原因：" + cause.getMessage());

        ctx.close();
    }
}