Easy-Manager-Tool 集成各类工具的核心使用方法，去繁就简，打造集成化程度高且专业的开、测、维一体化管理工具

package com.aizuda.easyManagerTool.service.docker.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.lang.TypeReference; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; import com.aizuda.easy.security.domain.Rep; import com.aizuda.easy.security.domain.Req; import com.aizuda.easyManagerTool.config.socket.SocketSend; import com.aizuda.easyManagerTool.domain.dto.PageDTO; import com.aizuda.easyManagerTool.domain.dto.dbc.db.ForwardInfo; import com.aizuda.easyManagerTool.domain.dto.docker.*; import com.aizuda.easyManagerTool.domain.dto.monitor.MonitorEditDTO; import com.aizuda.easyManagerTool.domain.dto.socket.SocketMessageDTO; import com.aizuda.easyManagerTool.domain.dto.terminal.SSHInfoDTO; import com.aizuda.easyManagerTool.domain.entity.docker.DockerListEntity; import com.aizuda.easyManagerTool.domain.entity.monitor.MonitorUrlEntity; import com.aizuda.easyManagerTool.domain.vo.PageVO; import com.aizuda.easyManagerTool.domain.vo.docker.*; import com.aizuda.easyManagerTool.domain.vo.server.ServerCompleteVO; import com.aizuda.easyManagerTool.domain.vo.setting.SettingUserVO; import com.aizuda.easyManagerTool.domain.vo.socket.SocketMessageVO; import com.aizuda.easyManagerTool.mapper.docker.DockerConfigMapper; import com.aizuda.easyManagerTool.mapper.docker.DockerListMapper; import com.aizuda.easyManagerTool.mapper.server.ServerMapper; import com.aizuda.easyManagerTool.service.docker.DockerListServer; import com.aizuda.easyManagerTool.service.monitor.MonitorDataService; import com.aizuda.easyManagerTool.service.socket.SocketEventService; import com.aizuda.easyManagerTool.service.socket.impl.SocketSessionManager; import com.aizuda.easyManagerTool.service.terminal.ScriptService; import com.aizuda.easyManagerTool.service.terminal.impl.TerminalSessionManager; import com.aizuda.easyManagerTool.util.AssertUtil; import com.aizuda.easyManagerTool.util.SSHManagerUtil; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.github.dockerjava.api.DockerClient; import com.github.dockerjava.api.async.ResultCallback; import com.github.dockerjava.api.command.*; import com.github.dockerjava.api.exception.ConflictException; import com.github.dockerjava.api.model.*; import com.github.dockerjava.core.DefaultDockerClientConfig; import com.github.dockerjava.core.DockerClientConfig; import com.github.dockerjava.core.DockerClientImpl; import com.github.dockerjava.httpclient5.ApacheDockerHttpClient; import com.github.dockerjava.transport.DockerHttpClient; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.CommandLineRunner; import org.springframework.stereotype.Service; import org.springframework.web.socket.TextMessage; import org.springframework.web.socket.WebSocketSession; import javax.annotation.Resource; import java.io.IOException; import java.io.InputStream; import java.io.PipedInputStream; import java.io.PipedOutputStream; import java.time.Duration; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.function.BiConsumer; import java.util.stream.Collectors; @Slf4j @Service(value = "docker") public class DockerListServerImpl extends ServiceImpl<DockerListMapper, DockerListEntity> implements DockerListServer, CommandLineRunner, SocketEventService { @Resource private DockerListMapper dockerListMapper; @Resource private DockerConfigMapper dockerConfigMapper; @Resource private ScriptService scriptService; @Resource private ServerMapper serverMapper; @Value("${server.port}") private String port; @Value("${config.intranet-ip}") private String intranetIp; @Resource MonitorDataService monitorDataService; @Override public Rep<PageVO<DockerListVO>> find(Req<PageDTO<DockerListEntity>, SettingUserVO> req) { PageDTO<DockerListEntity> pageDTO = req.getData(); DockerListEntity data = pageDTO.getData(); Page<DockerListEntity> page = new Page<DockerListEntity>(pageDTO.getCurrent(), pageDTO.getSize()); // 查询 唯一条件是要根据 权限查询 IPage<DockerListVO> dockerListVOIPage = dockerListMapper.find(page, ObjectUtil.isEmpty(data)? new DockerListEntity():data); // 从缓存查询 dockerListVOIPage.getRecords().parallelStream().forEach(item ->{ DockerManagerVO dockerManagerVO = DockerManager.get(item.getId()); if(ObjectUtil.isEmpty(dockerManagerVO) || !dockerManagerVO.isState()){ return; } item.setState(dockerManagerVO.isState()); item.setServerCpu(dockerManagerVO.getInfo().getNCPU()); item.setServerMemory(dockerManagerVO.getInfo().getMemTotal()); item.setDockerRootDir(dockerManagerVO.getInfo().getDockerRootDir()); item.setImageNum(dockerManagerVO.getImages().size()); item.setContainerNum(dockerManagerVO.getInfo().getContainers()); item.setNetworkNum(dockerManagerVO.getNetworks().size()); item.setVolumeNum(dockerManagerVO.getVolumes().getVolumes().size()); }); List<DockerListVO> sort = CollUtil.sort(dockerListVOIPage.getRecords(), Comparator.comparing(DockerListVO::getState).reversed()); PageVO<DockerListVO> pageVO = new PageVO<DockerListVO>(pageDTO) .setTotal(dockerListVOIPage.getTotal()) .setRecords(sort); return Rep.ok(pageVO); } @Override public Rep<DockerListVO> edit(Req<DockerListEntity, SettingUserVO> req) { DockerListEntity data = req.getData(); if(CollUtil.isEmpty(data.getServerIds())){ return Rep.error(500,"请选择服务器"); } if(!data.getListSsh()){ AssertUtil.objIsNull(data.getListPort(), "请填写tcp端口"); } // 查询重复 List<DockerListEntity> dockerListEntities = dockerListMapper.selectByServerIds(data.getServerIds()); if(CollUtil.isNotEmpty(dockerListEntities)){ return Rep.error(500,"请勿重复添加"); } List<DockerListEntity> collect = data.getServerIds().stream().map(i -> { DockerListEntity dockerListEntity = BeanUtil.copyProperties(data,DockerListEntity.class); dockerListEntity.setServerId(i); dockerListEntity.setTenantId(req.getData().getTenantId()); dockerListEntity.setCreateTime(new Date()); dockerListEntity.setUpdateTime(new Date()); return dockerListEntity; }).collect(Collectors.toList()); // 通知更新 saveOrUpdateBatch(collect); init(); return Rep.ok(); } @Override public Rep<DockerListVO> del(Req<DockerListEntity, SettingUserVO> req) { DockerListEntity data = req.getData(); AssertUtil.objIsNull(data.getId(),"数据错误"); dockerListMapper.deleteById(data.getId()); DockerManager.del(data.getId()); return Rep.ok(); } @Override public void refresh() { DockerManager.getList().parallelStream().forEach(i -> { i.refresh(); }); } @Override public Rep<List<Image>> imageList(Req<DockerListImageDTO, SettingUserVO> req) { DockerListImageDTO data = req.getData(); AssertUtil.objIsNull(data.getId(),"数据错误"); DockerManagerVO dockerManagerVO = DockerManager.get(data.getId()); dockerManagerVO.refresh(); return Rep.ok(dockerManagerVO.getImages()); } @Override public Rep<List<Image>> imageDel(Req<DockerListImageDTO, SettingUserVO> req) { DockerListImageDTO data = req.getData(); AssertUtil.objIsNull