增加 redis

.gitignore

@@ -43,3 +43,4 @@
 /logs
 /*.class
 .DS_Store
+/gddlly/build

gateway/src/main/java/com/gyee/edge/gddlly/clientworker/IClientWorker.java

@@ -13,6 +13,10 @@ public interface IClientWorker {
 
     int getState();
 
+    void shutdown();
+
+    int getStatus();
+
     ChannelFuture sendMessage(Object message);
 
     ChannelFuture sendBytes(Byte[] bytes);

gateway/src/main/java/com/gyee/edge/gddlly/clientworker/iec102/IEC102SerialClientWorker.java

@@ -120,6 +120,16 @@ public class IEC102SerialClientWorker implements IClientWorker {
     }
 
     @Override
+    public void stop() {
+
+    }
+
+    @Override
+    public int getState() {
+        return 0;
+    }
+
+    @Override
     public void shutdown() {
         if (channel != null && channel.isOpen())
             channel.close();

gateway/src/main/java/com/gyee/edge/gddlly/clientworker/iec102/IEC102TcpClientWorker.java

@@ -85,6 +85,16 @@ public class IEC102TcpClientWorker implements ISlaveClientWorker, Runnable {
     }
 
     @Override
+    public void shutdown() {
+
+    }
+
+    @Override
+    public int getStatus() {
+        return 0;
+    }
+
+    @Override
     public ChannelFuture sendMessage(Object message) {
         return null;
     }

gateway/src/main/java/com/gyee/edge/gddlly/clientworker/rocketmq/RocketMQClientWorker.java

@@ -23,6 +23,16 @@ public class RocketMQClientWorker implements IMasterClientWorker, Runnable {
     }
 
     @Override
+    public void stop() {
+
+    }
+
+    @Override
+    public int getState() {
+        return 0;
+    }
+
+    @Override
     public void shutdown() {
 
     }

gddlly/build.gradle

@@ -24,5 +24,5 @@ dependencies {
     implementation("org.apache.logging.log4j:log4j-api:$log4jVersion")
     implementation("org.apache.logging.log4j:log4j-slf4j-impl:$log4jVersion")
     implementation("org.xerial:sqlite-jdbc:$sqliteJdbc")
-
+    implementation("org.springframework.boot:spring-boot-starter-data-redis:$springBootRedis")
 }