package com.itstack.netty;

import java.nio.charset.Charset;

import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.DelimiterBasedFrameDecoder;
import io.netty.handler.codec.LineBasedFrameDecoder;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;

public class ChildChannelHandler extends ChannelInitializer<SocketChannel> {

	@Override
	protected void initChannel(SocketChannel ch) throws Exception {

		System.out.println("报告");
		System.out.println("信息：有一客户端链接到本服务端");
		System.out.println("IP:" + ch.localAddress().getHostName());
		System.out.println("Port:" + ch.localAddress().getPort());
		System.out.println("报告完毕");

		// 半包处理【基于换行符】
		//ch.pipeline().addLast(new LineBasedFrameDecoder(1024));
		//半包处理, ‘;’ 作为分包符
		ch.pipeline().addLast(new DelimiterBasedFrameDecoder(1024,Unpooled.copiedBuffer(";".getBytes())));
//		 字符串编码
		ch.pipeline().addLast(new StringDecoder());
		// 字符串解码
		ch.pipeline().addLast(new StringEncoder());
		// 在管道中添加我们自己的接收数据实现方法
		ch.pipeline().addLast(new MyServerHanlder());

	}

}