From b78939528af0e1ee7f95483b23bbf2b9de416539 Mon Sep 17 00:00:00 2001 From: chuzhongzai Date: Mon, 4 Dec 2023 16:09:09 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E9=AA=8C=E8=AF=81=E6=B6=88?= =?UTF-8?q?=E6=81=AF;=E4=BF=AE=E5=A4=8D=E5=93=8D=E5=BA=94=E7=BB=93?= =?UTF-8?q?=E6=9E=9C=E5=88=A4=E6=96=AD=E9=94=99=E8=AF=AF=E5=BE=97=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/lion/lionwebsite/Message/IdentityMessage.java | 5 +++++ .../java/com/lion/lionwebsite/Service/RemoteService.java | 2 +- src/main/java/com/lion/lionwebsite/Util/Response.java | 5 +---- 3 files changed, 7 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/lion/lionwebsite/Message/IdentityMessage.java b/src/main/java/com/lion/lionwebsite/Message/IdentityMessage.java index f0792f6..225d4c8 100644 --- a/src/main/java/com/lion/lionwebsite/Message/IdentityMessage.java +++ b/src/main/java/com/lion/lionwebsite/Message/IdentityMessage.java @@ -1,10 +1,15 @@ package com.lion.lionwebsite.Message; +import lombok.AllArgsConstructor; import lombok.Data; +import lombok.NoArgsConstructor; @Data +@AllArgsConstructor +@NoArgsConstructor public class IdentityMessage extends AbstractMessage{ { messageType = IDENTITY_MESSAGE; } + String identity; } diff --git a/src/main/java/com/lion/lionwebsite/Service/RemoteService.java b/src/main/java/com/lion/lionwebsite/Service/RemoteService.java index b9239e2..7447f5b 100644 --- a/src/main/java/com/lion/lionwebsite/Service/RemoteService.java +++ b/src/main/java/com/lion/lionwebsite/Service/RemoteService.java @@ -92,7 +92,7 @@ public class RemoteService { pushService.storageNodeOnline(); channel = channelFuture.channel(); - channel.writeAndFlush(new IdentityMessage()); + channel.writeAndFlush(new IdentityMessage("lionwebsite")); return true; }catch (Exception e){ e.printStackTrace(); diff --git a/src/main/java/com/lion/lionwebsite/Util/Response.java b/src/main/java/com/lion/lionwebsite/Util/Response.java index 0e9f225..3da8dd2 100644 --- a/src/main/java/com/lion/lionwebsite/Util/Response.java +++ b/src/main/java/com/lion/lionwebsite/Util/Response.java @@ -1,11 +1,8 @@ package com.lion.lionwebsite.Util; - import com.fasterxml.jackson.databind.JsonNode; -import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.node.ObjectNode; -import java.util.HashMap; public class Response { ObjectNode result; @@ -63,7 +60,7 @@ public class Response { } public boolean isSuccess(){ - return result.get("result").equals("success"); + return result.get("result").asText().equals("success"); }