/**
 * 
 */
package connect;

import java.util.Date;

import javax.annotation.Resource;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
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.NioSocketChannel;
import jedis.Jedisclusters;
import masterpro.MasterChannelInitializer;
import masterpro.MasterDisconnectListener;

/**
 * @Description: client------>master
 * @version: v1.0.0
 * @author: wbl
 * @date: 2019年8月30日 上午10:04:30
 */
public class ToMasterDesign implements Runnable{
	private int masterid = 0;
	private String ip = "";
	private int port = 0;
	
	@Resource
	public Jedisclusters jedisCluster;
	
	public ToMasterDesign(int masterid, String ip,int port){
		this.masterid = masterid;
		this.ip =ip;
		this.port = port;
	}
	
	@Override
	public void run() {
		connect();
	}
	
	public void connect(){
		 EventLoopGroup group = new NioEventLoopGroup();
 try {
 Bootstrap gate = new Bootstrap();
 gate.group(group)
 		 .channel(NioSocketChannel.class)
 		 .option(ChannelOption.TCP_NODELAY, true)
 		 .handler(new MasterChannelInitializer(masterid));
 ChannelFuture channelFuture = gate.connect(ip, port).sync();
 if(channelFuture.channel().isActive()){
 	sendMsg(channelFuture.channel());
 }
 channelFuture.addListener(new MasterDisconnectListener(masterid,ip,port)); 
 channelFuture.channel().closeFuture().sync();
 } catch (InterruptedException e) {
 e.printStackTrace();
 } finally {
 group.shutdownGracefully();
 }
	}
	
	
	
 public void sendMsg(Channel channel) {
	 String str = "gateway_Login";
	 System.out.println("Login: ["+new Date() + "] "+channel.remoteAddress().toString().substring(1));
 channel.writeAndFlush(str);
 }

}