开发中, 通过 websocket 来管理 docker 镜像和容器

common/src/main/java/cn/reghao/bnt/common/docker/model/DockerPayload.java

@@ -0,0 +1,22 @@
+package cn.reghao.bnt.common.docker.model;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author reghao
+ * @date 2025-12-16 22:26:20
+ */
+@Setter
+@Getter
+public class DockerPayload implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    private String ops;
+    private String machineId;
+    private List<String> payload = new ArrayList<>();
+}

web/src/main/java/cn/reghao/bnt/web/ws/handler/FrontendHandler.java

@@ -1,5 +1,6 @@
 package cn.reghao.bnt.web.ws.handler;
 
+import cn.reghao.bnt.common.docker.model.DockerPayload;
 import cn.reghao.bnt.web.ws.SessionManagerFront;
 import cn.reghao.bnt.web.ws.WsSender;
 import cn.reghao.bnt.web.ws.event.DockerOpsService;
@@ -48,6 +49,7 @@ public class FrontendHandler implements WebSocketHandler {
             if (webSocketMessage instanceof TextMessage) {
                 log.info("接收到 WebSocket 文本消息");
                 String jsonPayload = (String) webSocketMessage.getPayload();
+                DockerPayload dockerPayload = JsonConverter.jsonToObject(jsonPayload, DockerPayload.class);
                 JsonObject jsonObject = JsonConverter.jsonToJsonElement(jsonPayload).getAsJsonObject();
                 String ops = jsonObject.get("ops").getAsString();
                 String machineId = jsonObject.get("machineId").getAsString();