新增主动重连功能以及定时检测连接有效性

src/main/java/lion/Message/AbstractMessage.java

@@ -14,6 +14,8 @@ public class AbstractMessage {
 
     public static final byte MAINTAIN_MESSAGE = 7;
 
+    public static final byte AVAILABLE_CHECK_MESSAGE = 8;
+
     public byte messageType;
 
     public int messageId;

src/main/java/lion/Message/Main/AvailableCheckMessage.java

@@ -0,0 +1,11 @@
+package lion.Message.Main;
+
+import lion.Message.AbstractMessage;
+import lombok.Data;
+
+@Data
+public class AvailableCheckMessage extends AbstractMessage {
+    {
+        messageType = AVAILABLE_CHECK_MESSAGE;
+    }
+}

src/main/java/lion/Message/MessageCodec.java

@@ -45,6 +45,7 @@ public class MessageCodec extends ByteToMessageCodec<AbstractMessage> {
             case AbstractMessage.DELETE_GALLERY_MESSAGE -> objectMapper.readValue(metadata, DeleteGalleryMessage.class);
             case AbstractMessage.IDENTITY_MESSAGE -> objectMapper.readValue(metadata, IdentityMessage.class);
             case AbstractMessage.MAINTAIN_MESSAGE -> objectMapper.readValue(metadata, MaintainMessage.class);
+            case AbstractMessage.AVAILABLE_CHECK_MESSAGE -> objectMapper.readValue(metadata, AvailableCheckMessage.class);
             default -> null;
         };
 

src/main/java/lion/storageNode.java

@@ -177,6 +177,11 @@ public class storageNode {
                     ResponseMessage responseMessage = new ResponseMessage(deleteGalleryMessage.messageId, result);
                     ctx.writeAndFlush(responseMessage);
                 }
+                case AbstractMessage.AVAILABLE_CHECK_MESSAGE -> {
+                    AvailableCheckMessage acm = (AvailableCheckMessage) abstractMessage;
+                    ResponseMessage responseMessage = new ResponseMessage(acm.messageId, (byte)0);
+                    ctx.writeAndFlush(responseMessage);
+                }
             }
 //
 //            //修复预览