package?com.crazymakercircle.chat.client;

import?com.crazymakercircle.chat.common.ClientMsgBuilder;
import?com.crazymakercircle.chat.common.bean.ChatMsg;
import?com.crazymakercircle.chat.common.bean.User;
import?com.crazymakercircle.chat.common.bean.msg.ProtoMsg;
import?com.crazymakercircle.chat.common.codec.PackageSpliter;
import?com.crazymakercircle.chat.common.codec.ProtobufDecoder;
import?com.crazymakercircle.chat.common.codec.ProtobufEncoder;
import?io.netty.bootstrap.Bootstrap;
import?io.netty.buffer.PooledByteBufAllocator;
import?io.netty.channel.*;
import?io.netty.channel.nio.NioEventLoopGroup;
import?io.netty.channel.socket.SocketChannel;
import?io.netty.channel.socket.nio.NioSocketChannel;
import?org.slf4j.Logger;
import?org.slf4j.LoggerFactory;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.beans.factory.annotation.Value;
import?org.springframework.stereotype.Service;

import?java.util.Date;
import?java.util.concurrent.TimeUnit;

@Service（“EchoClient“）
public?class?ChatClient
{
????static?final?Logger?LOGGER?=
????????????LoggerFactory.getLogger（ChatClient.class）;
????//?服務(wù)器ip地址
????@Value（“${server.ip}“）
????private?String?host;
????//?服務(wù)器端口
????@Value（“${server.port}“）
????private?int?port;

????//?通過nio方式來接收連接和處理連接
????private?EventLoopGroup?group?=?new?NioEventLoopGroup（）;

????@Autowired
????private?ChatClientHandler?chatClientHandler;

????private?Channel?channel;
????private?User?user;

????/**
?????*?唯一標(biāo)記
?????*/
????private?boolean?initFalg?=?true;

????/**
?????*?客戶端的是Bootstrap，服務(wù)端的則是?ServerBootstrap。
?????*?都是AbstractBootstrap的子類。
?????**/
????public?void?run（）
????{
????????doConnect（new?Bootstrap（）?group）;
????}

????/**
?????*?重連
?????*/
????public?void?doConnect（Bootstrap?bootstrap?EventLoopGroup?eventLoopGroup）
????{
????????ChannelFuture?f?=?null;
????????try
????????{
????????????if?（bootstrap?!=?null）
????????????{
????????????????bootstrap.group（eventLoopGroup）;
????????????????bootstrap.channel（NioSocketChannel.class）;
????????????????bootstrap.option（ChannelOption.SO_KEEPALIVE?true）;
????????????????bootstrap.option（ChannelOption.ALLOCATOR?PooledByteBufAllocator.DEFAULT）;
????????????????bootstrap.remoteAddress（host?port）;

????????????????//?設(shè)置通道初始化
????????????????bootstrap.handler（
????????????????????????new?ChannelInitializer（）
????????????????????????{
????????????????????????????public?void?initChannel（SocketChannel?ch）?throws?Exception
????????????????????????????{
????????????????????????????????ch.pipeline（）.addLast（new?PackageSpliter（））;
????????????????????????????????ch.pipeline（）.addLast（new?ProtobufDecoder（））;
????????????????????????????????ch.pipeline（）.addLast（new?ProtobufEncoder（））;
????????????????????????????????ch.pipeline（）.addLast（chatClientHandler）;

????????????????????????????}
????????????????????????}
????????????????）;

?????????????