package com.walker.tcp.netty;

import com.walker.tcp.connect.LongConnection;
import io.netty.channel.ChannelHandler.Sharable;
import io.netty.channel.ChannelHandlerContext;

/**
 * 使用netty实现的通信处理handler，该handler调用的方法通过自己的handler来适配处理。
 * @author 时克英
 * @date 2018-08-16
 *
 */
@Sharable
public class DefaultLongHandler extends AbstractChannelInBoundHandler<Object> {
//public class DefaultLongHandler extends AbstractChannelInBoundHandler<String> {

 	@Override
 	protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
//          // 收到消息直接打印输出
//         System.out.println(ctx.channel().remoteAddress() + " Say : " + msg);
//         // 返回客户端消息 - 我已经接收到了你的消息
//          ctx.writeAndFlush("Received your message !\n");
//          System.out.println("通道id = " + ctx.channel().id().asLongText() + ", " + ctx.channel().id().asShortText());
 		String message = msg == null ? null : msg.toString();

 		String id = ctx.channel().id().asLongText() ;
 		LongConnection conn = (LongConnection)connectionManager.getConnection(id);
 		msgThreadLocal.set(message);

 		tcpServerHandler.onRead(conn, message);
      }

     @Override
     public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
//    	 System.out.println("服务端读取完成数据一次。" + ctx.channel().remoteAddress() );

    	 String id = ctx.channel().id().asLongText() ;
    	 Object msg = msgThreadLocal.get();

    	 tcpServerHandler.onReadComplete(msg, id, ctx);
    	 msgThreadLocal.set(null);
         super.channelReadComplete(ctx);
     }

}