添加客户端相关

Author: Peng Hu

src/main/java/info/xiaomo/gengine/network/client/ChannelConnectListener.java

@@ -0,0 +1,62 @@
+package info.xiaomo.gengine.network.client;
+
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelFutureListener;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.TimeUnit;
+
+
+/**
+ * Created by 张力 on 2017/6/30.
+ */
+public class ChannelConnectListener implements ChannelFutureListener {
+
+    private final Client client;
+
+    private final int index;
+
+    public static final Logger LOGGER = LoggerFactory.getLogger(ChannelConnectListener.class);
+
+    public ChannelConnectListener(Client client, int index) {
+        this.client = client;
+        this.index = index;
+    }
+
+    @Override
+    public void operationComplete(ChannelFuture future) {
+
+        ClientBuilder builder = client.getBuilder();
+
+        if (future.isSuccess()) {
+
+            client.registerChannel(index, future.channel());
+
+            if (client.getBuilder().getClientListener() != null) {
+                client.getBuilder().getClientListener().afterConnected(future.channel());
+            }
+            LOGGER.info("成功连接到服务器,index->{}, host->{}, port->{}", index, builder.getHost(), builder.getPort());
+            return;
+        }
+
+
+        LOGGER.error("连接服务器失败,index->{}, host->{}, port->{}", index, builder.getHost(), builder.getPort());
+
+        if (client.isStopped()) {
+            LOGGER.error("客户端已经关闭不重连,index->{}, host->{}, port->{}", index, builder.getHost(), builder.getPort());
+        } else if (!client.needReconnect) {
+            LOGGER.error("重连功能关闭不重连,index->{}, host->{}, port->{}", index, builder.getHost(), builder.getPort());
+        } else {
+
+            int reconnectDelay = client.getReconnectDelay(index);
+            client.countReconnectDelay(index);
+
+            LOGGER.error("{}秒后进行重连,index->{}, host->{}, port->{}", reconnectDelay, index, builder.getHost(), builder.getPort());
+            Client.executor.schedule(() -> {
+                client.createChannel(index);
+            }, reconnectDelay, TimeUnit.SECONDS);
+        }
+
+    }
+}

src/main/java/info/xiaomo/gengine/network/client/ChannelDisconnectedListener.java

@@ -0,0 +1,44 @@
+package info.xiaomo.gengine.network.client;
+
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelFutureListener;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Created by 张力 on 2017/6/30.
+ */
+public class ChannelDisconnectedListener implements ChannelFutureListener {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(ChannelDisconnectedListener.class);
+
+    private final Client client;
+
+    private final int index;
+
+
+    public ChannelDisconnectedListener(Client client, int index) {
+        this.client = client;
+        this.index = index;
+    }
+
+    @Override
+    public void operationComplete(ChannelFuture future) {
+        if (client.isStopped()) {
+            LOGGER.info("连接断开，客户端已关闭不进行重连，host->{},port->{}", client.getBuilder().getHost(), client.getBuilder().getPort());
+        } else if (!client.needReconnect) {
+            LOGGER.info("连接断开，重连功能关闭不重连，host->{},port->{}", client.getBuilder().getHost(), client.getBuilder().getPort());
+        } else {
+            int reconnectDelay = client.getReconnectDelay(index);
+            client.countReconnectDelay(index);
+
+            LOGGER.info("连接断开，{}秒后开始重连，host->{},port->{}", reconnectDelay, client.getBuilder().getHost(), client.getBuilder().getPort());
+
+            Client.executor.schedule(() -> {
+                client.createChannel(index);
+            }, reconnectDelay, TimeUnit.SECONDS);
+        }
+    }
+}