package com.xcong.excoin.netty.initalizer;
|
|
import com.xcong.excoin.netty.handler.TcpServerHandler;
|
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.Unpooled;
|
import io.netty.channel.ChannelInitializer;
|
import io.netty.channel.socket.nio.NioSocketChannel;
|
import io.netty.handler.codec.DelimiterBasedFrameDecoder;
|
import io.netty.handler.codec.string.StringDecoder;
|
import io.netty.handler.codec.string.StringEncoder;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* @author wzy
|
* @email wangdoubleone@gmail.com
|
* @date 2019-05-06
|
*/
|
@Component
|
public class TcpServerInitializer extends ChannelInitializer<NioSocketChannel> {
|
|
@Autowired
|
private TcpServerHandler tcpServerHandler;
|
|
@Override
|
protected void initChannel(NioSocketChannel ch) throws Exception {
|
ByteBuf buf = Unpooled.copiedBuffer("_split".getBytes());
|
ch.pipeline().addLast(new DelimiterBasedFrameDecoder(1024, buf));
|
ch.pipeline().addLast(new StringDecoder());
|
ch.pipeline().addLast(new StringEncoder());
|
ch.pipeline().addLast(tcpServerHandler);
|
}
|
}
|
