/**
 * 
 */
package connect;

import java.util.Date;

import javax.annotation.Resource;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;

import divpro.DivChannelInitializer;
import freeconfig.GetProperties;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import jedis.Jedisclusters;

/**
 * @Description: 
 * 心跳时间，不同设备或厂家的心跳时间是不同的,按配置更改就行
 * @author: wbl
 * @date: 2019年8月30日 上午10:04:44
 */
@Configuration
public class ToClientDesign implements Runnable{
	private int poolNum = 0;
	
	@Resource
	public static  Jedisclusters jedisCluster;
	
	public ToClientDesign(int poolnum){
		this.poolNum = poolnum;
	}
	
	@Override
	public void run() {
		EventLoopGroup bossGroup = new NioEventLoopGroup(ConfigDesign.BIZGROUPSIZE);
        EventLoopGroup workerGroup = new NioEventLoopGroup(ConfigDesign.BIZTHREADSIZE);
        try {
            ServerBootstrap gateServer = new ServerBootstrap();
            gateServer.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .option(ChannelOption.SO_BACKLOG, ConfigDesign.CACHESIZE)
                    .childHandler(new DivChannelInitializer());
            String port = GetProperties.getValue("client.port");
            System.out.println("read client config:"+port);
            ChannelFuture f = gateServer.bind(Integer.parseInt(port)).sync();
            System.out.println("bind: ["+new Date()+"]   服务器开始监听端口"+port+"，等待客户端连接.........");
            f.channel().closeFuture().sync();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            /**优雅退出，释放线程池资源*/
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
	}
}