Add event loop group (#17)

* ssl

* ssl

* update customization ssl (#15)

* update customization ssl

* update

* reduce log level

* update udp codec (#16)

* update setSessionKey

* update for udp

* add even loop group

* update

Author: tvd12

pom.xml

@@ -11,7 +11,7 @@
 
     <artifactId>ezyfox-server-java-client</artifactId>
 
-    <version>1.2.5</version>
+    <version>1.2.6</version>
     <name>ezyfox-server-java-client</name>
     <url>https://youngmonkeys.org/</url>
 

src/main/java/com/tvd12/ezyfoxserver/client/EzyClient.java

@@ -6,6 +6,7 @@
 import com.tvd12.ezyfoxserver.client.constant.EzyCommand;
 import com.tvd12.ezyfoxserver.client.constant.EzyConnectionStatus;
 import com.tvd12.ezyfoxserver.client.constant.EzyDisconnectReason;
+import com.tvd12.ezyfoxserver.client.constant.EzySslType;
 import com.tvd12.ezyfoxserver.client.entity.EzyApp;
 import com.tvd12.ezyfoxserver.client.entity.EzyUser;
 import com.tvd12.ezyfoxserver.client.entity.EzyZone;
@@ -16,6 +17,8 @@
 import com.tvd12.ezyfoxserver.client.socket.EzyPingSchedule;
 import com.tvd12.ezyfoxserver.client.socket.EzySocketClient;
 
+import javax.net.ssl.SSLContext;
+
 public interface EzyClient extends EzyCloseable {
 
     EzySetup setup();
@@ -24,11 +27,15 @@ public interface EzyClient extends EzyCloseable {
 
     boolean reconnect();
 
-    void send(EzyRequest request);
+    default void send(EzyRequest request) {
+        send(request, false);
+    }
 
     void send(EzyRequest request, boolean encrypted);
 
-    void send(EzyCommand cmd, EzyArray data);
+    default void send(EzyCommand cmd, EzyArray data) {
+        send(cmd, data, false);
+    }
 
     void send(EzyCommand cmd, EzyArray data, boolean encrypted);
 
@@ -44,9 +51,17 @@ default void disconnect() {
 
     void udpConnect(String host, int port);
 
-    void udpSend(EzyRequest request);
+    default void udpSend(EzyRequest request) {
+        udpSend(request, false);
+    }
+
+    void udpSend(EzyRequest request, boolean encrypted);
 
-    void udpSend(EzyCommand cmd, EzyArray data);
+    default void udpSend(EzyCommand cmd, EzyArray data) {
+        udpSend(cmd, data, false);
+    }
+
+    void udpSend(EzyCommand cmd, EzyArray data, boolean encrypted);
 
     void close();
 
@@ -56,6 +71,14 @@ default void disconnect() {
 
     boolean isEnableSSL();
 
+    EzySslType getSslType();
+
+    boolean isEnableEncryption();
+
+    boolean isEnableCertificationSSL();
+
+    void setSslContext(SSLContext sslContext);
+
     boolean isEnableDebug();
 
     EzyUser getMe();

src/main/java/com/tvd12/ezyfoxserver/client/EzyClients.java

@@ -3,10 +3,13 @@
 import com.tvd12.ezyfoxserver.client.config.EzyClientConfig;
 import com.tvd12.ezyfoxserver.client.constant.EzyTransportType;
 
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+import static com.tvd12.ezyfox.util.EzyProcessor.processWithLogException;
+
 public final class EzyClients {
 
     private String defaultClientName;
@@ -28,7 +31,8 @@ public EzyClient newClient(EzyClientConfig config) {
 
     public EzyClient newClient(
         EzyTransportType transportType,
-        EzyClientConfig config) {
+        EzyClientConfig config
+    ) {
         synchronized (clients) {
             return doNewClient(transportType, config);
         }
@@ -46,9 +50,6 @@ private EzyClient doNewClient(
                 client = new EzyUTClient(config);
             }
             doAddClient(client);
-            if (defaultClientName == null) {
-                defaultClientName = client.getName();
-            }
         }
         return client;
     }
@@ -112,6 +113,9 @@ public void getClients(List<EzyClient> cachedClients) {
     public void removeClient(String name) {
         synchronized (clients) {
             clients.remove(name);
+            if (name.equals(defaultClientName)) {
+                defaultClientName = null;
+            }
         }
     }
 
@@ -120,4 +124,12 @@ public void clear() {
             this.clients.clear();
         }
     }
+
+    public void disconnectClients() {
+        List<EzyClient> clientsToDisconnect = new ArrayList<>();
+        getClients(clientsToDisconnect);
+        clientsToDisconnect.forEach(it ->
+            processWithLogException(it::disconnect)
+        );
+    }
 }