diff --git a/proxy/src/main/java/io/mpms/socket/AgentWebSocketTomcatHandle.java b/proxy/src/main/java/io/mpms/socket/AgentWebSocketTomcatHandle.java new file mode 100644 index 0000000000000000000000000000000000000000..9df10209b31a1b9c51b9da46d659e6c6297f5eb9 --- /dev/null +++ b/proxy/src/main/java/io/mpms/socket/AgentWebSocketTomcatHandle.java @@ -0,0 +1,32 @@ +package io.mpms.socket; + +import cn.hutool.core.exceptions.ExceptionUtil; +import cn.hutool.core.io.FileUtil; +import cn.jiangzeyin.common.DefaultSystemLog; +import cn.jiangzeyin.common.JsonMessage; +import cn.jiangzeyin.common.spring.SpringUtil; +import com.alibaba.fastjson.JSONObject; +import io.jpom.JpomApplication; +import io.jpom.model.data.TomcatInfoModel; +import io.jpom.service.manage.TomcatEditService; +import io.jpom.system.WebAopLog; +import io.jpom.util.SocketSessionUtil; +import org.springframework.stereotype.Component; + +import javax.websocket.*; +import javax.websocket.server.ServerEndpoint; +import java.io.File; +import java.io.IOException; +import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; + +/** + * 插件端,控制台socket + * + */ +@ServerEndpoint(value = "/tomcat_log") +@Component +public class AgentWebSocketTomcatHandle extends BaseAgentWebSocketHandle { + + +} diff --git a/proxy/src/main/java/io/mpms/socket/AgentWebSocketUpdateHandle.java b/proxy/src/main/java/io/mpms/socket/AgentWebSocketUpdateHandle.java new file mode 100644 index 0000000000000000000000000000000000000000..b680e4a29e95fbec3a8cc83c85bfe3e1c8efd904 --- /dev/null +++ b/proxy/src/main/java/io/mpms/socket/AgentWebSocketUpdateHandle.java @@ -0,0 +1,29 @@ +package io.mpms.socket; + +import cn.jiangzeyin.common.DefaultSystemLog; +import com.alibaba.fastjson.JSONObject; +import io.jpom.JpomApplication; +import io.jpom.common.JpomManifest; +import io.jpom.model.AgentFileModel; +import io.jpom.model.WebSocketMessageModel; +import io.jpom.model.data.UploadFileModel; +import io.jpom.system.AgentConfigBean; +import io.jpom.util.SocketSessionUtil; +import org.springframework.stereotype.Component; + +import javax.websocket.*; +import javax.websocket.server.ServerEndpoint; +import java.util.HashMap; +import java.util.Map; + +/** + * 在线升级 + * + * + */ +@ServerEndpoint(value = "/node_update") +@Component +public class AgentWebSocketUpdateHandle extends BaseAgentWebSocketHandle { + + +}