From b1a631f8b4252e7731cd3683bf64f42f59e47463 Mon Sep 17 00:00:00 2001 From: chuzhongzai Date: Tue, 20 Jan 2026 22:28:45 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E4=B8=BB=E5=8A=A8=E9=87=8D?= =?UTF-8?q?=E8=BF=9E=E5=8A=9F=E8=83=BD=E4=BB=A5=E5=8F=8A=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E6=A3=80=E6=B5=8B=E8=BF=9E=E6=8E=A5=E6=9C=89=E6=95=88=E6=80=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/lion/Message/AbstractMessage.java | 2 ++ .../java/lion/Message/Main/AvailableCheckMessage.java | 11 +++++++++++ src/main/java/lion/Message/MessageCodec.java | 1 + src/main/java/lion/storageNode.java | 5 +++++ 4 files changed, 19 insertions(+) create mode 100644 src/main/java/lion/Message/Main/AvailableCheckMessage.java diff --git a/src/main/java/lion/Message/AbstractMessage.java b/src/main/java/lion/Message/AbstractMessage.java index ff7aada..8a2633a 100644 --- a/src/main/java/lion/Message/AbstractMessage.java +++ b/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; diff --git a/src/main/java/lion/Message/Main/AvailableCheckMessage.java b/src/main/java/lion/Message/Main/AvailableCheckMessage.java new file mode 100644 index 0000000..60d7ada --- /dev/null +++ b/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; + } +} diff --git a/src/main/java/lion/Message/MessageCodec.java b/src/main/java/lion/Message/MessageCodec.java index d61c135..7106a95 100644 --- a/src/main/java/lion/Message/MessageCodec.java +++ b/src/main/java/lion/Message/MessageCodec.java @@ -45,6 +45,7 @@ public class MessageCodec extends ByteToMessageCodec { 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; }; diff --git a/src/main/java/lion/storageNode.java b/src/main/java/lion/storageNode.java index 3719c80..e051f56 100644 --- a/src/main/java/lion/storageNode.java +++ b/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); + } } // // //修复预览