package com.zy.gateway.pipeline;

import io.netty.channel.Channel;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelInitializer;
import io.netty.handler.timeout.IdleStateHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;


/**
 * handler管道
 * 控制所有netty handler流向
 * 待完成: 动态管理handler
 * Created by vincent on 2019-04-02
 */
@Component
@ChannelHandler.Sharable
public class HandlerInitializer extends ChannelInitializer<Channel> {

    @Autowired
    private PipelineProperties pipelineProperties;

    /**
     * Set some channel handlers on channel pipeline
     */
    @Override
    protected void initChannel(Channel channel) {
        channel.pipeline()
                // 心跳
                .addLast(new IdleStateHandler(pipelineProperties.getHeartSeconds(), 0, 0))
//                // 编码器
//                .addLast(protocolEncoder)
//                // 解码器
//                .addLast(new ProtocolDecoder(4096))
//                // 校验码处理器
//                .addLast(validateHandler)
//                // 认证处理器
//                .addLast(vehAuthHandler)
//                // 业务处理器
//                .addLast(gbPackageServerHandler)
//                // 通道保护器
//                .addLast(protectorHandler)
        ;

        // Channel局部变量，相当于线程的ThreadLocal
//        initAttrTrack(channel);
    }


}