package com.example.demo.client1;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

public class LinebaseClientHandler extends ChannelInboundHandlerAdapter{
    
    private static int counter;
    
    private byte[] req;
    
    public LinebaseClientHandler(){
        //客户端发送信息需要加换行符，特别重要，否则服务端接收不到；
        req = ("current time:" + System.getProperty("line.separator")).getBytes();
    }
    
    @Override
    public void channelActive(ChannelHandlerContext ctx) {
        ByteBuf firstMessage = null;
        //连接成功后，发送消息，发送100吃，模拟信息发送的频繁
        for(int i = 0;i<100;i++){
            firstMessage = Unpooled.buffer(req.length);
            firstMessage.writeBytes(req);
            ctx.writeAndFlush(firstMessage);
        }
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx,Object msg){
        try{
                        //此处已经LineBasedFrameDecoder、StringDecoder的解码，可以直接接收
            String body = (String) msg;
            System.out.println("now is:" + body + ";the counter is " + ++counter);
        }catch(Exception e){
            e.printStackTrace();
        }
        
    }
    
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    //释放资源
       ctx.close();
    }
}