package com.example.controller; import cn.hutool.core.io.FileUtil; import com.example.common.Result; import com.example.exception.CustomException; import jakarta.servlet.ServletOutputStream; import jakarta.servlet.http.HttpServletResponse; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import java.io.IOException; import java.net.URLEncoder; import java.nio.charset.StandardCharsets; //处理文件上传和下载的相关接口 @RestController @RequestMapping("/files") public class FileController { //文件上传 @PostMapping("/upload") public Result upload(@RequestParam("file") MultipartFile file) throws Exception { String filePath=System.getProperty("user.dir")+"/files/";//获取当前项目的根路径(xm-pro的绝对路径E:\Item\代码\xm-pro\springboot) //找到文件位置 if(FileUtil.isDirectory(filePath)){ FileUtil.mkdir(filePath); } byte[] bytes= file.getBytes(); String fileName=System.currentTimeMillis()+"_"+file.getOriginalFilename();//文件的原始名称,加唯一数 //写入文件 FileUtil.writeBytes(bytes, filePath+fileName); String url="http://localhost:8080/files/download/"+fileName; return Result.success(url); } //文件下载 //下载路径 @GetMapping("/download/{fileName}")//通过浏览器直接访问用get public void download(@PathVariable String fileName,HttpServletResponse response) throws CustomException, IOException {//流的方式下载不需要返回对象 String filePath=System.getProperty("user.dir")+"/files/";//获取当前项目的根路径(xm-pro的绝对路径E:\Item\代码\xm-pro\springboot) //找到文件位置 String realPath=filePath+fileName;//E:\Item\代码\xm-pro\files\图片名称 boolean exist=FileUtil.exist(realPath); if(!exist){ throw new CustomException("文件不存在"); } //读取文件的字节流 byte[] bytes= FileUtil.readBytes(realPath); ServletOutputStream os=response.getOutputStream(); //输出流对象把文件写到客户端 os.write(bytes); os.flush(); os.close(); } } <el-form-item label="头像" prop="avatar"> <el-upload action="http://localhost:8080/files/upload" :Headers="{token:data.user.token}" :on-success="handleFileSuccess" list-type="picture" > <el-button type="primary">上传头像</el-button> </el-upload> </el-form-item> const handleFileSuccess=(res)=>{ data.form.avatar=res.data } 为什么前端点击上传头像时,数据库里面avatar里面没有添加成功url值

package com.example.controller; import cn.hutool.core.io.FileUtil; import com.example.exception.CustomerException; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; //处理文件上传和下载的相关接口 //文件下载 @RestController @RequestMapping("/files") public class FileController { @GetMapping("/download/{fileName}")//通过浏览器直接访问用get public void download(@PathVariable String fileName){//流的方式下载不需要返回对象 String filePath=System.getProperty("user.dir")+"/files/";//获取当前项目的根路径(xm-pro的绝对路径E:\Item\代码\xm-pro\springboot) //找到文件位置 String realPath=filePath+fileName;//E:\Item\代码\xm-pro\files\图片名称 boolean exist=FileUtil.exist(realPath); if(!exist){ throw new CustomerException("文件不存在"); } } }为什么会出现无法解析符号 ‘CustomerException’

接下来看导入部分，用户导入了cn.hutool.core.io.FileUtil和Spring的相关注解，但明显缺少了CustomerException类的导入。通常，自定义异常类会被放在项目的某个包中，比如com.example.exception，而代码中确实...

package com.example.controller; import cn.hutool.core.io.FileUtil; import com.example.exception.CustomException; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; //处理文件上传和下载的相关接口 //文件下载 @RestController @RequestMapping("/files") public class FileController { @GetMapping("/download/{fileName}")//通过浏览器直接访问用get public void download(@PathVariable String fileName){//流的方式下载不需要返回对象 String filePath=System.getProperty("user.dir")+"/files/";//获取当前项目的根路径(xm-pro的绝对路径E:\Item\代码\xm-pro\springboot) //找到文件位置 String realPath=filePath+fileName;//E:\Item\代码\xm-pro\files\图片名称 boolean exist=FileUtil.exist(realPath); if(!exist){ throw new CustomerException("文件不存在"); } } }为什么会出现无法解析符号 'CustomerException'

import com.example.exception.CustomException; // ✅ 正确导入 throw new CustomerException("..."); // ❌ 拼写错误（多了一个"er"）三、解决方案： 1. 修改为正确的类名拼写： java if(!exist){ throw...

package com.example.springboot.controller; import cn.hutool.core.io.FileUtil; import com.example.springboot.common.AuthAccess; import com.example.springboot.common.Result; import jakarta.servlet.ServletOutputStream; import jakarta.servlet.http.HttpServletResponse; import lombok.SneakyThrows; import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import java.io.File; import java.io.IOException; import java.lang.reflect.Field; //上传图片 /** * @author Kings * @date 2025/06/26 */ @RestController @RequestMapping("/file") public class FileController { @Value("${ip:localhost}") String ip; @Value("${spring.port}") String port; private static final String UPLOAD_PATH = System.getProperty("user.dir") + File.separator + "files"; /** * 上传 * * @param file 文件 * @return @return {@link Result } * @author 邓 * @date 2025/06/26 */ @SneakyThrows @PostMapping("/upload") private Result upload(MultipartFile file) { String originalFilename = file.getOriginalFilename(); //文件的原始名称 String mainName = FileUtil.mainName(originalFilename); String extName = FileUtil.extName("文件的后缀"); if (!FileUtil.exist(UPLOAD_PATH)) { FileUtil.mkdir(UPLOAD_PATH); //如果当前文件的父级目录不存在，就创建 } if (FileUtil.exist(UPLOAD_PATH + File.separator + originalFilename)) { //如果当前上传的文件已经存在了，那么这个时候我就要重命名一个文件 originalFilename = System.currentTimeMillis() + "-" + mainName + "." + extName; } File saveFile = new File(UPLOAD_PATH + File.separator + originalFilename); file.transferTo(saveFile); //存储到磁盘 String url = "https://" + ip + ":" + port + "/file/download/" + originalFilename; return Result.success(url); //返回文件的链接，这个链接就是文件的下载地址，这个下载地址就是我的后台提供出来的 } /** * 下载 * * @param fileName 文件名 * @param response 响应 * @return * @author 邓 * @date 2025/06/26 */ //下载 @GetMapping("/download/{fileName}") private void download(@PathVariable String fileName, HttpServletResponse response) throws IOException { String filePath = UPLOAD_PATH + File.separator + fileName; if (FileUtil.exist(filePath)) { return; } byte[] bytes = FileUtil.readBytes(filePath); ServletOutputStream outputStream = response.getOutputStream(); outputStream.write(bytes); //数组是一个字节数组，也就是文件的字节流数组 outputStream.flush(); outputStream.close(); } }

import cn.hutool.core.io.FileUtil; import com.example.springboot.common.AuthAccess; import com.example.springboot.common.Result; import jakarta.servlet.ServletOutputStream; import jakarta.servlet....

package com.chinamobile.ehr.file.excel.service.error; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.IoUtil; import cn.hutool.extra.spring.SpringUtil; import com.ai.aif.log4x.Logger; import com.ai.aif.log4x.LoggerFactory; import com.alibaba.excel.EasyExcel; import com.alibaba.excel.ExcelWriter; import com.alibaba.excel.write.metadata.WriteSheet; import com.chinamobile.ehr.file.excel.dao.TaskRepository; import com.chinamobile.ehr.file.excel.dto.ExcelResult; import com.chinamobile.ehr.file.excel.dto.RowData; import com.chinamobile.ehr.file.excel.dto.ValidateMsg; import com.chinamobile.ehr.file.excel.utils.EasyExcelUtil; import org.apache.poi.ss.usermodel.*; import java.io.ByteArrayInputStream; import java.io.InputStream; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.concurrent.BlockingQueue; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.function.Function; public class EasyExcelErrorThread implements Runnable { private static Logger logger = LoggerFactory.getLogger(EasyExcelErrorThread.class); private BlockingQueue> validateBlockingQueue; private AtomicBoolean stop = new AtomicBoolean(false); private CountDownLatch countDownLatch = new CountDownLatch(1); private ExcelResult excelResult; private Function<ExcelResult, Boolean> callback; public Function<ExcelResult, Boolean> getCallback() { return callback; } public void setCallback(Function<ExcelResult, Boolean> callback) { this.callback = callback; } public void stopAwait() { try { validateBlockingQueue.put(new ArrayList<>()); countDownLatch.await(5, TimeUnit.MINUTES); } catch (InterruptedException e) { logger.error("错误信息", e); } } public EasyExcelErrorThread(BlockingQueue> validateBlockingQueue, ExcelResult excelResult) { this.validateBlockingQueue = validateBlockingQueue; this.excelResult = excelResult; } @Override public void run() { Long startTime = System.currentTimeMillis(); ExcelWriter excelWriter = null; InputStream inputStream = null; StringBuilder fileIsExitSB = new StringBuilder(); fileIsExitSB.append("oriFile: ").append(excelResult.getFilePath()); fileIsExitSB.append("errFile:").append(excelResult.getErrorFilePath()).append("; "); try { // 追踪文件是否存在 fileLog(fileIsExitSB,"start"); FileUtil.copy(excelResult.getFilePath(), excelResult.getErrorFilePath(), true); fileLog(fileIsExitSB,"copy"); logger.info("错误导出-复制错误文件：{}",System.currentTimeMillis()-startTime); byte[] errorTemplateBytes = EasyExcelUtil.createErrorTemplate(excelResult.getErrorFilePath(),excelResult.getTableName()); fileLog(fileIsExitSB,"createErrorTemplate"); logger.info("错误导出-生成错误模版：{}",System.currentTimeMillis()-startTime); inputStream = new ByteArrayInputStream(errorTemplateBytes); excelWriter = EasyExcel.write(excelResult.getErrorFilePath()).withTemplate(inputStream).inMemory(Boolean.FALSE).build(); fileLog(fileIsExitSB,"write"); // 把sheet设置为不需要头不然会输出sheet的头这样看起来第一个table 就有2个头了 WriteSheet writeSheet = EasyExcel.writerSheet(0).needHead(Boolean.FALSE).build(); while (true) { List<RowData> validateRowList = validateBlockingQueue.take(); if (CollectionUtil.isEmpty(validateRowList)) { break; } List<Map<String, Object>> rowList = EasyExcelUtil.getErrorExcelRowList(validateRowList); excelWriter.fill(rowList, writeSheet); // 记录导出数据量，并回调 excelResult.setErrorExportCount(excelResult.getErrorExportCount() + rowList.size()); callback.apply(excelResult); logger.info("错误导出-导出数据-{}：{}",excelResult.getErrorExportCount(),System.currentTimeMillis()-startTime); } //强制计算所有公式（可选） Workbook workbook = excelWriter.writeContext().writeWorkbookHolder().getWorkbook(); workbook.setForceFormulaRecalculation(true); // 简单刷新批注 Sheet sheet = workbook.getSheetAt(0); for (Row row : sheet) { for (Cell cell : row) { if (cell.getCellType() == CellType.FORMULA && cell.getCellComment() != null) { cell.setCellComment(cell.getCellComment()); // 重新设置触发刷新 } } } fileLog(fileIsExitSB,"end"); } catch (InterruptedException e) { logger.error("错误导出-写入错误excel错误", e); throw new RuntimeException(e); } finally { // 更新追踪文件是否存在记录 fileLog(fileIsExitSB,"finally"); excelResult.setFileIsExitStr(fileIsExitSB.toString()); callback.apply(excelResult); IoUtil.close(inputStream); IoUtil.close(excelWriter); // 更新错误文件大小 updateFileSize(); countDownLatch.countDown(); logger.info("错误导出-结束：{}", System.currentTimeMillis() - startTime); } } public boolean updateFileSize() { Long size = FileUtil.file(excelResult.getErrorFilePath()).length()/1024; String guid = excelResult.getErrAttachFile(); TaskRepository taskRepository = SpringUtil.getBean(TaskRepository.class); Boolean result = taskRepository.updateFileSize(size, guid); return result; } private void fileLog(StringBuilder fileIsExitSB, String tip){ fileIsExitSB.append(tip).append(": "); boolean oriFileIsExit = FileUtil.isExistsAndNotDirectory(FileUtil.file(excelResult.getFilePath()).toPath(), false); boolean errFileIsExit = FileUtil.isExistsAndNotDirectory(FileUtil.file(excelResult.getErrorFilePath()).toPath(), false); fileIsExitSB.append("oriFileIsExit: ").append(oriFileIsExit).append("; "); fileIsExitSB.append("errFileIsExit: ").append(errFileIsExit).append("; ");; } } 导出的文件有一列是公式列，导出后批注不显示，如何刷新所有批注

我们正在解决EasyExcel导出Excel文件后，公式列的批注不显示的问题。根据之前的讨论，我们知道需要触发公式计算和批注刷新。以下是完整的解决方案： ### 解决方案步骤 1. **强制公式计算**：在写入数据后，强制...

package com.example.demo.service.impl; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.IoUtil; import cn.hutool.core.lang.UUID; import cn.hutool.core.thread.ThreadFactoryBuilder; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.example.demo.dao.entity.WExecuteHost; import com.example.demo.dao.entity.WPersonalHost; import com.example.demo.dao.mapper.WExecuteHostMapper; import com.example.demo.service.WExecuteHostService; import com.example.demo.service.WPersonalHostService; import lombok.Data; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.messaging.simp.SimpMessagingTemplate; import org.springframework.stereotype.Service; import javax.annotation.PreDestroy; import java.io.BufferedReader; import java.io.File; import java.io.IOException; import java.io.InputStreamReader; import java.nio.charset.StandardCharsets; import java.util.List; import java.util.Map; import java.util.Queue; import java.util.concurrent.*; @Service public class WExecuteHostServiceImpl extends ServiceImpl<WExecuteHostMapper, WExecuteHost> implements WExecuteHostService { @Autowired private WPersonalHostService wPersonalHostService; @Data private static class UserSession { private Process cmdProcess; private volatile boolean isProcessRunning; private String sessionId; private String logFilePath; private final Queue<String> logBuffer = new ConcurrentLinkedQueue<>(); private static final int BATCH_SIZE = 50; // 批量写入阈值 } private final Map<String, UserSession> userSessions = new ConcurrentHashMap<>(); private final SimpMessagingTemplate messagingTemplate; // 异步日志写入线程池 private static final ExecutorService LOG_WRITER_POOL = Executors.newCachedThreadPool( new ThreadFactoryBuilder().setNamePrefix("log-writer-").build()); // 日志刷新调度器 private static final ScheduledExecutorService LOG_FLUSH_SCHEDULER = Executors.newSingleThreadScheduledExecutor(); public WExecuteHostServiceImpl(SimpMessagingTemplate messagingTemplate) { this.messagingTemplate = messagingTemplate; startLogFlushService(); } // 初始化日志刷新服务 private void startLogFlushService() { LOG_FLUSH_SCHEDULER.scheduleAtFixedRate(() -> { userSessions.values().forEach(session -> { if (!session.getLogBuffer().isEmpty()) { List<String> batch = CollUtil.newArrayList(session.getLogBuffer()); session.getLogBuffer().clear(); asyncWriteLog(session.getLogFilePath(), String.join("\n", batch)); } }); }, 0, 1, TimeUnit.SECONDS); } @Override public String pipList() { // 示例实现：返回模拟的管道列表（实际需根据业务需求实现） return "[]"; } @Override public void executeCommand(String command, String executeHost, String userId) { // 1. 权限校验 if (!validateUserHost(userId, executeHost)) { sendError("无权访问该主机", userId); return; } // 2. 初始化日志系统 UserSession session = userSessions.computeIfAbsent(userId, key -> { if (userSessions.containsKey(userId)) { sendError("已有命令执行中，请等待完成", userId); return null; } return createNewSession(userId, executeHost); }); if (session == null) return; // 3. 命令处理 if ("ABORT".equalsIgnoreCase(command)) { handleAbort(userId); return; } // 写入命令到日志 session.getLogBuffer().offer( "\n———————— 执行时间 " + DateUtil.now() + " ————————\n[<<Input<<] " + command); // 发送命令到进程 IoUtil.writeUtf8(session.getCmdProcess().getOutputStream(), true,command + "\n"); } private boolean validateUserHost(String userId, String executeHost) { LambdaQueryWrapper<WPersonalHost> queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(WPersonalHost::getP13, userId) .eq(WPersonalHost::getExecuteHost, executeHost) .eq(WPersonalHost::getState, "在线"); return wPersonalHostService.getOne(queryWrapper) != null; } private UserSession createNewSession(String userId, String executeHost) { try { UserSession session = new UserSession(); session.setSessionId(UUID.randomUUID().toString()); session.setLogFilePath(initLogFile(userId, executeHost)); // 启动CMD进程（带唯一标题） ProcessBuilder pb = new ProcessBuilder("cmd.exe", "/k", "title " + generateUniqueTitle(userId)); session.setCmdProcess(pb.redirectErrorStream(true).start()); // 启动输出监听线程 startOutputThread(session, userId); return session; } catch (IOException e) { sendError("进程启动失败: " + e.getMessage(), userId); return null; } } private String initLogFile(String userId, String executeHost) { // 1. 构建基础路径（使用File.separator） String baseDir = FileUtil.normalize( System.getProperty("user.dir") + File.separator + "command-log"); // 2. 构建安全路径（统一使用File.separator） String safePath = FileUtil.normalize( baseDir + File.separator + userId + File.separator + executeHost + File.separator + "项目名称"); // 3. 安全校验（现在路径分隔符一致） if (!safePath.startsWith(baseDir)) { throw new SecurityException("非法日志路径: " + safePath); } // 4. 创建目录（自动处理路径分隔符） FileUtil.mkdir(safePath); // 5. 生成日志文件 String logFileName = DateUtil.today() + ".log"; return FileUtil.touch(safePath + File.separator + logFileName).getAbsolutePath(); } private void startOutputThread(UserSession session, String userId) { new Thread(() -> { try (BufferedReader reader = new BufferedReader( new InputStreamReader(session.getCmdProcess().getInputStream(), "GBK"))) { String line; while ((line = reader.readLine()) != null) { // WebSocket推送 messagingTemplate.convertAndSend("/topic/commandOutput/" + userId, line); // 日志缓冲 session.getLogBuffer().offer(line); if (session.getLogBuffer().size() >= UserSession.BATCH_SIZE) { asyncWriteLog(session.getLogFilePath(), String.join("\n", session.getLogBuffer())); session.getLogBuffer().clear(); } } } catch (Exception e) { sendError("输出流异常: " + e.getMessage(), userId); } finally { cleanupSession(userId); } }).start(); } private void asyncWriteLog(String logFilePath, String content) { CompletableFuture.runAsync(() -> { try { FileUtil.appendUtf8String(content + System.lineSeparator(), logFilePath); } catch (Exception e) { System.err.println("日志写入失败: " + e.getMessage()); } }, LOG_WRITER_POOL); } private void cleanupSession(String userId) { UserSession session = userSessions.remove(userId); if (session != null) { try { if (session.getCmdProcess() != null) { session.getCmdProcess().destroyForcibly(); } } catch (Exception ignored) {} } } @PreDestroy public void cleanup() { LOG_FLUSH_SCHEDULER.shutdown(); LOG_WRITER_POOL.shutdown(); userSessions.forEach((userId, session) -> { try { if (session.getCmdProcess() != null) { session.getCmdProcess().destroyForcibly(); } } catch (Exception ignored) {} }); userSessions.clear(); } public void handleAbort(String userId) { UserSession session = userSessions.get(userId); if (session != null && session.isProcessRunning()) { session.getCmdProcess().destroyForcibly(); sendError("⏹ 用户命令已终止", userId); } else { sendError("⏹ 无执行中命令", userId); } } private void sendError(String message, String userId) { try { messagingTemplate.convertAndSend("/topic/commandOutput/" + userId, "❌ " + message); } catch (Exception ignored) { } } private String generateUniqueTitle(String userId) { return "CMD_SESSION_" + userId + "_" + System.currentTimeMillis(); } }如何让输入的输出的都是GBK

修改日志写入方法asyncWriteLog：将FileUtil.appendUtf8String改为使用FileUtil.appendString，并指定编码为GBK。但是注意：我们的日志文件不仅包含命令行的输出（GBK），还包含我们自己添加的一些说明（比如执行...

我现在有多个服务，a是前端，b是java后端，还有很多个小java客户端。我的小客户端是部署在多台电脑上的，使用websocket执行代码，我现在想要的是过去小客户端的所有websocket要用b进行一个中转，即a<=>b<=>小客户端。这是我的a的代码： import { Client } from '@stomp/stompjs'; import SockJS from 'sockjs-client'; // npm remove stompjs // npm install @stomp/stompjs sockjs-client --save export default { connect() { return new Promise((resolve, reject) => { const socket = new SockJS('http://10.228.73.15:31001/websocket'); const stompClient = new Client({ webSocketFactory: () => socket, debug: () => { // 禁用调试输出，或根据需要处理 }, reconnectDelay: 5000, heartbeatIncoming: 4000, heartbeatOutgoing: 4000, }); stompClient.onConnect = (frame) => { console.log('Connected:', frame); resolve(stompClient); // 连接成功后立即订阅个人主题 // stompClient.subscribe(/topic/commandOutput/${userId}, (message) => { // console.log(1,message) // }); }; stompClient.onStompError = (error) => { console.error('Connection error:', error); reject(error); }; stompClient.activate(); }); } };<template> 当前登录用户： <input v-model="userId" placeholder="请输入p13" @keyup.enter="connectWebSocket"> <button @click="connectWebSocket" style="margin-left: 10px;">登录</button> <input ref="commandInput" v-model="currentCommand" style="width: 600px" placeholder="输入任意命令（如：ipconfig / dir）" :disabled="isExecuting" @keyup.enter="sendCommand" > <button @click="sendCommand" style="margin-left: 10px;" :disabled="isExecuting">执行命令</button> <button @click="abortCommand" style="margin-left: 10px; background: #ff4d4f" :disabled="!isExecuting" > 中止命令 </button> 已执行命令 {{ msg }} 实时命令输出 {{ currentOutput }} </template> <script> import websocket from '@/utils/websocket' export default { name: 'HelloWorld', props: { msg: String }, data() { return { currentCommand: '', messages: [], currentOutput: '', stompClient: null, index: 1, userId: '', isExecuting: false // 控制命令是否正在执行 }; }, methods: { async connectWebSocket() { alert("登录成功"); try { this.stompClient = await websocket.connect(this.userId); this.$nextTick(() => { this.$refs.commandInput.focus(); // 命令结束后重新聚焦到输入框 }); const subscription = this.stompClient.subscribe(/topic/commandOutput/${this.userId}, (message) => { const output = message.body; if (output.startsWith("⏹")) { this.isExecuting = false; // 命令执行结束，允许用户继续输入 this.$nextTick(() => { this.$refs.commandInput.focus(); // 命令结束后重新聚焦到输入框 }); return; } this.currentOutput += output.trim() + '\n'; this.$nextTick(() => { if (this.$refs.outputPre) { this.$refs.outputPre.scrollTop = this.$refs.outputPre.scrollHeight; } }); }); this.stompClient.onDisconnect = () => { subscription.unsubscribe(); }; // 检查命令执行状态 await this.checkCommandStatus(); } catch (error) { console.error('WebSocket连接失败:', error); } }, async checkCommandStatus() { try { const response = await fetch(/win/status/${this.userId}); if (!response.ok) { console.error('无法获取命令状态'); return; } this.isExecuting = await response.json(); // 更新前端状态 if (this.isExecuting) { alert("上一个命令尚未完成，请等待或中止命令！"); } } catch (error) { console.error('检查命令状态时出错:', error); } }, sendCommand() { if (this.userId === '') { alert("请输入当前登录用户"); return; } this.isExecuting = true; if (this.currentCommand.trim() && this.stompClient) { // 删除 currentOutput 的最后一个非空行 if (this.currentOutput) { let lastNewLineIndex = this.currentOutput.lastIndexOf('\n'); let lastNonEmptyIndex = -1; // 从后往前遍历，找到最后一个非空行的起始位置 for (let i = this.currentOutput.length - 1; i >= 0; i--) { if (this.currentOutput[i] === '\n') { // 如果当前字符是换行符，并且之前的字符不是空白字符，则记录位置 if (lastNewLineIndex !== -1 && i < lastNewLineIndex) { lastNonEmptyIndex = lastNewLineIndex; break; } lastNewLineIndex = i; } else if (this.currentOutput[i].trim() !== '') { // 找到非空字符，更新 lastNewLineIndex lastNewLineIndex = i; } } // 如果找到了非空行，则删除它 if (lastNonEmptyIndex !== -1) { const nextNewLineIndex = this.currentOutput.indexOf('\n', lastNonEmptyIndex); if (nextNewLineIndex === -1) { this.currentOutput = this.currentOutput.substring(0, lastNonEmptyIndex); } else { this.currentOutput = this.currentOutput.substring(0, lastNonEmptyIndex) + this.currentOutput.substring(nextNewLineIndex); } } // 删除最后一个空行 if (this.currentOutput.endsWith('\n')) { this.currentOutput = this.currentOutput.substring(0, this.currentOutput.length - 1); } } // 发送命令 this.stompClient.publish({ destination: '/app/executeCommand', body: JSON.stringify({ command: this.currentCommand.trim(), //todo 之后改为动态 host: '10.228.73.15', userId: this.userId }), }); this.messages.push(this.index + '. ' + this.currentCommand); this.index += 1; this.currentCommand = ''; } }, async abortCommand() { if (this.stompClient) { const response = await fetch(/win/handleAbort/${this.userId}); if (response){ this.messages.push("已发送中止命令"); } } }, onTabChange(key, type) { this[type] = key; }, }, beforeDestroy() { if (this.stompClient) { this.stompClient.deactivate(); } } } </script> <style scoped> pre { white-space: pre-line; background-color: #f4f4f4; padding: 10px; border: 1px solid #ddd; } </style> 这是我的小客户端的代码： package com.example.demo.config; import org.springframework.context.annotation.Configuration; import org.springframework.messaging.simp.config.MessageBrokerRegistry; import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker; import org.springframework.web.socket.config.annotation.StompEndpointRegistry; import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer; @Configuration @EnableWebSocketMessageBroker public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { @Override public void configureMessageBroker(MessageBrokerRegistry config) { config.enableSimpleBroker("/topic"); config.setApplicationDestinationPrefixes("/app"); } @Override public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoint("/websocket") .setAllowedOriginPatterns("") .withSockJS(); } }package com.example.demo.service.impl; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.IoUtil; import cn.hutool.core.lang.UUID; import cn.hutool.core.thread.ThreadFactoryBuilder; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.example.demo.dao.entity.WExecuteHost; import com.example.demo.dao.entity.WHostProcess; import com.example.demo.dao.entity.WPersonalHost; import com.example.demo.dao.mapper.WExecuteHostMapper; import com.example.demo.request.ProcessRequest; import com.example.demo.service.WExecuteHostService; import com.example.demo.service.WHostProcessService; import com.example.demo.service.WPersonalHostService; import lombok.Data; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.messaging.simp.SimpMessagingTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.interceptor.TransactionAspectSupport; import javax.annotation.PreDestroy; import java.io.BufferedReader; import java.io.File; import java.io.IOException; import java.io.InputStreamReader; import java.nio.charset.Charset; import java.nio.charset.StandardCharsets; import java.util.Date; import java.util.List; import java.util.Map; import java.util.Queue; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.regex.Matcher; import java.util.regex.Pattern; @Service public class WExecuteHostServiceImpl extends ServiceImpl<WExecuteHostMapper, WExecuteHost> implements WExecuteHostService { @Autowired private WPersonalHostService wPersonalHostService; @Autowired private WHostProcessService wHostProcessService; @Data private static class UserSession { private Process cmdProcess; private volatile boolean isProcessRunning; private String sessionId; private String logFilePath; private final Queue<String> logBuffer = new ConcurrentLinkedQueue<>(); private static final int BATCH_SIZE = 50; // 批量写入阈值 // 命令执行状态锁 private final AtomicBoolean isExecuting = new AtomicBoolean(false); } private final Map<String, UserSession> userSessions = new ConcurrentHashMap<>(); private final SimpMessagingTemplate messagingTemplate; // 异步日志写入线程池 private static final ExecutorService LOG_WRITER_POOL = Executors.newCachedThreadPool( new ThreadFactoryBuilder().setNamePrefix("log-writer-").build()); // 日志刷新调度器 private static final ScheduledExecutorService LOG_FLUSH_SCHEDULER = Executors.newSingleThreadScheduledExecutor(); public WExecuteHostServiceImpl(SimpMessagingTemplate messagingTemplate) { this.messagingTemplate = messagingTemplate; startLogFlushService(); } // 初始化日志刷新服务 private void startLogFlushService() { LOG_FLUSH_SCHEDULER.scheduleAtFixedRate(() -> { userSessions.values().forEach(session -> { if (!session.getLogBuffer().isEmpty()) { List<String> batch = CollUtil.newArrayList(session.getLogBuffer()); session.getLogBuffer().clear(); asyncWriteLog(session.getLogFilePath(), String.join("\n", batch)); } }); }, 0, 1, TimeUnit.SECONDS); } @Override public void executeCommand(String command, String host, String userId) { // 0. ABORT命令特殊处理（优先处理终止请求） if ("ABORT".equalsIgnoreCase(command)) { handleAbort(userId); return; } // 1. 权限校验 if (!validateUserHost(userId, host)) { sendError("无权访问该主机", userId); return; } // 2. 检查用户当前会话状态 UserSession session = userSessions.get(userId); if (session != null && session.isExecuting.get()) { sendError("已有命令执行中，请等待完成或使用ABORT终止", userId); return; } // 3. 创建新会话（带原子状态检查） session = userSessions.computeIfAbsent(userId, key -> { UserSession newSession = createNewSession(userId, host); if (newSession != null) { newSession.isExecuting.set(true); // 标记为执行中 } return newSession; }); if (session == null) return; // 4. 写入日志并执行命令 try { // 确保获得执行锁 if (!session.isExecuting.compareAndSet(true, true)) { sendError("命令执行冲突，请重试", userId); return; } session.getLogBuffer().offer("——————————————— " + DateUtil.now() + " ———————————————"); // 发送命令到进程 IoUtil.write(session.getCmdProcess().getOutputStream(), Charset.forName("GBK"), true, command + "\n"); } catch (Exception e) { session.isExecuting.set(false); // 发生异常时释放锁 sendError("命令发送失败: " + e.getMessage(), userId); } } @Override public Boolean isCommandExecuting(String userId) { UserSession session = userSessions.get(userId); return session != null && session.isExecuting.get(); } @Override public void handleAbort(String userId) { UserSession session = userSessions.get(userId); if (session == null || session.getCmdProcess() == null) { sendError("没有活动的命令进程", userId); return; } try { long pid = session.getCmdProcess().pid(); System.out.println("Attempting to kill process with PID: " + pid); // 使用 taskkill 命令终止进程 ProcessBuilder taskKill = new ProcessBuilder("taskkill", "/F", "/T", "/PID", String.valueOf(pid)); Process killProcess = taskKill.start(); // 等待命令执行完成 int exitCode = killProcess.waitFor(); System.out.println("taskkill exit code: " + exitCode); if (exitCode == 0) { // 进程终止成功 session.isExecuting.set(false); cleanupSession(userId); messagingTemplate.convertAndSend("/topic/commandOutput/" + userId, "✔️" + "进程已通过 taskkill 终止 (PID: " + pid + ")"); messagingTemplate.convertAndSend("/topic/commandOutput/" + userId, ""); messagingTemplate.convertAndSend("/topic/commandOutput/" + userId, System.getProperty("user.dir") + ">"); } else { // 进程终止失败 sendError("终止进程失败，错误码: " + exitCode, userId); } } catch (IOException | InterruptedException e) { System.err.println("Error killing process: " + e.getMessage()); sendError("终止进程失败: " + e.getMessage(), userId); } } @Override public String startProcess(ProcessRequest processRequest) { try { // 数据库表新增数据 String id = processRequest.getId(); String p13 = processRequest.getP13().trim(); String processName = processRequest.getProcessName().trim(); String productNumber = processRequest.getProductNumber().trim(); String executeHost = processRequest.getExecuteHost().trim(); String department = processRequest.getDepartment().trim(); String version = processRequest.getVersion().trim(); String type = processRequest.getType(); boolean saveOrUpdateResult; if (type.equals("新增")) { // 判断产品编号是否唯一 LambdaQueryWrapper<WHostProcess> processWrapper = new LambdaQueryWrapper<>(); processWrapper.eq(WHostProcess::getProductNumber, productNumber); WHostProcess process = wHostProcessService.getOne(processWrapper); if (process != null) { return "该产品编号已被他人使用，请使用其他的产品编号。"; } if (StrUtil.isEmpty(p13) || StrUtil.isEmpty(processName) || StrUtil.isEmpty(productNumber) || StrUtil.isEmpty(executeHost) || StrUtil.isEmpty(department) || StrUtil.isEmpty(version)) { return "新增进程失败。"; } WHostProcess wHostProcess = new WHostProcess(); wHostProcess.setP13(p13); wHostProcess.setProcessName(processName); wHostProcess.setProductNumber(productNumber); wHostProcess.setHost(executeHost); wHostProcess.setDepartment(department); wHostProcess.setState("离线"); wHostProcess.setVersion(version); wHostProcess.setBeginTime(new Date()); saveOrUpdateResult = wHostProcessService.save(wHostProcess); } else { // 执行更新操作 WHostProcess wHostProcess = wHostProcessService.getById(id); // 判断产品编号是否唯一 if (!wHostProcess.getProductNumber().equals(productNumber)) { LambdaQueryWrapper<WHostProcess> processWrapper = new LambdaQueryWrapper<>(); processWrapper.eq(WHostProcess::getProductNumber, productNumber); WHostProcess process = wHostProcessService.getOne(processWrapper); if (process != null) { return "该产品编号已被他人使用，请使用其他的产品编号。"; } } wHostProcess.setProcessName(processName); wHostProcess.setProductNumber(productNumber); wHostProcess.setHost(executeHost); wHostProcess.setDepartment(department); wHostProcess.setState("离线"); wHostProcess.setVersion(version); wHostProcess.setUpdateTime(new Date()); saveOrUpdateResult = wHostProcessService.updateById(wHostProcess); } if (saveOrUpdateResult) { LambdaQueryWrapper<WPersonalHost> queryWrapper = new LambdaQueryWrapper<>(); queryWrapper .eq(WPersonalHost::getExecuteHost, processRequest.getExecuteHost()) .eq(WPersonalHost::getSharedHost, processRequest.getSharedHost()); WPersonalHost wPersonalHost = wPersonalHostService.getOne(queryWrapper); // 执行py启动命令 //todo 后续动态 String pythonEXEPath = "D:\\miniforge\\envs" + File.separator + p13 + File.separator + p13 + "_python" + wPersonalHost.getPythonEnv() + File.separator + "python.exe -u"; String mainPyPath = System.getProperty("user.dir") + File.separator + "python-package" + File.separator + executeHost + File.separator + p13 + File.separator + "test" + File.separator + "main.py"; this.executeCommand(pythonEXEPath + " " + mainPyPath, processRequest.getExecuteHost(), processRequest.getP13()); return "正在启动项目..."; } } catch (Exception e) { e.printStackTrace(); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); } return "新增进程失败。"; } @Override public String stopProcess(ProcessRequest processRequest) { try { //todo 后续动态 String account = "fangpeiyuan"; Integer pid = processRequest.getPid(); LambdaQueryWrapper<WHostProcess> queryWrapper = new LambdaQueryWrapper<>(); queryWrapper .eq(WHostProcess::getP13, account) .eq(WHostProcess::getPid, pid); WHostProcess wHostProcess = wHostProcessService.getOne(queryWrapper); if (wHostProcess == null) { return "当前进程终止失败，请联系管理员！"; } // 执行终止命令并获取返回值 Process process = Runtime.getRuntime().exec( "taskkill /F /PID \"" + pid + "\""); int exitCode = process.waitFor(); if (exitCode == 0) { wHostProcess.setState("离线"); wHostProcess.setPid(null); wHostProcess.setUpdateTime(DateUtil.date()); wHostProcessService.updateById(wHostProcess); return "进程终止成功。"; } else { // 获取错误流信息（可选） BufferedReader errorReader = new BufferedReader( new InputStreamReader(process.getErrorStream())); String errorLine; StringBuilder errorMessage = new StringBuilder(); while ((errorLine = errorReader.readLine()) != null) { errorMessage.append(errorLine).append("\n"); } return "进程终止失败，错误码: " + exitCode + (errorMessage.length() > 0 ? "，错误信息: " + errorMessage : ""); } } catch (Exception e) { e.printStackTrace(); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return "当前进程终止失败: " + e.getMessage(); } } private boolean validateUserHost(String userId, String executeHost) { LambdaQueryWrapper<WPersonalHost> queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(WPersonalHost::getP13, userId) .eq(WPersonalHost::getExecuteHost, executeHost) .eq(WPersonalHost::getState, "在线"); return wPersonalHostService.getOne(queryWrapper) != null; } private UserSession createNewSession(String userId, String executeHost) { try { UserSession session = new UserSession(); session.setSessionId(UUID.randomUUID().toString()); session.setLogFilePath(initLogFile(userId, executeHost)); // 启动CMD进程（带唯一标题） ProcessBuilder pb = new ProcessBuilder("cmd.exe", "/k", "title " + generateUniqueTitle(userId)); session.setCmdProcess(pb.redirectErrorStream(true).start()); // 启动输出监听线程 startOutputThread(session, userId); return session; } catch (IOException e) { sendError("进程启动失败: " + e.getMessage(), userId); return null; } } private String initLogFile(String userId, String executeHost) { // 1. 构建基础路径（使用File.separator） String baseDir = FileUtil.normalize( System.getProperty("user.dir") + File.separator + "command-log"); // 2. 构建安全路径（统一使用File.separator） String safePath = FileUtil.normalize( baseDir + File.separator + userId + File.separator + executeHost + File.separator + "项目名称"); // 3. 安全校验（现在路径分隔符一致） if (!safePath.startsWith(baseDir)) { throw new SecurityException("非法日志路径: " + safePath); } // 4. 创建目录（自动处理路径分隔符） FileUtil.mkdir(safePath); // 5. 生成日志文件 String logFileName = DateUtil.today() + ".log"; return FileUtil.touch(safePath + File.separator + logFileName).getAbsolutePath(); } private void startOutputThread(UserSession session, String userId) { new Thread(() -> { try (BufferedReader reader = new BufferedReader( new InputStreamReader(session.getCmdProcess().getInputStream(), Charset.forName("GBK")))) { String line; while ((line = reader.readLine()) != null) { messagingTemplate.convertAndSend("/topic/commandOutput/" + userId, line); session.getLogBuffer().offer(line); } } catch (Exception e) { sendError("输出流异常: " + e.getMessage(), userId); } finally { session.isExecuting.set(false); // 命令结束释放锁 cleanupSession(userId); // 通知前端命令执行结束 messagingTemplate.convertAndSend("/topic/commandOutput/" + userId, "⏹ 该命令执行已结束"); } }).start(); } private void asyncWriteLog(String logFilePath, String content) { CompletableFuture.runAsync(() -> { try { // 替换掉日志文件中没用的信息，如多余的路径信息 String currentDir = System.getProperty("user.dir"); String escapedDir = currentDir.replace("\\", "\\\\"); String regex = "(?m)^\\s" + escapedDir + ">(?!\\S)\\s*"; // 创建 Pattern 和 Matcher 对象 Pattern pattern = Pattern.compile(regex); Matcher matcher = pattern.matcher(content); // 检查是否存在匹配的模式 if (matcher.find()) { // 如果存在匹配，则进行替换 String cleaned = content.replaceAll(regex, ""); FileUtil.appendString(cleaned + System.lineSeparator(), logFilePath, Charset.forName("GBK")); } else { FileUtil.appendString(content + System.lineSeparator(), logFilePath, Charset.forName("GBK")); } } catch (Exception e) { System.err.println("日志写入失败: " + e.getMessage()); } }, LOG_WRITER_POOL); } private void cleanupSession(String userId) { UserSession session = userSessions.remove(userId); if (session != null) { try { if (session.getCmdProcess() != null) { session.getCmdProcess().destroyForcibly(); } // 强制将剩余日志写入文件（新增代码） if (!session.getLogBuffer().isEmpty()) { asyncWriteLog(session.getLogFilePath(), String.join("\n", session.getLogBuffer())); session.getLogBuffer().clear(); } } catch (Exception ignored) { } } } @PreDestroy public void cleanup() { LOG_FLUSH_SCHEDULER.shutdown(); LOG_WRITER_POOL.shutdown(); userSessions.forEach((userId, session) -> { try { if (session.getCmdProcess() != null) { session.getCmdProcess().destroyForcibly(); } } catch (Exception ignored) { } }); userSessions.clear(); } /** * 发送错误日志 */ private void sendError(String message, String userId) { try { messagingTemplate.convertAndSend("/topic/commandOutput/" + userId, "❌" + message); } catch (Exception ignored) { } } /** * 生成cmd窗口唯一id */ private String generateUniqueTitle(String userId) { return "CMD_SESSION_" + userId + "_" + System.currentTimeMillis(); } } 请参考这两个，帮我实现b作为中转需要的代码，以及a和小客户端需要修改的东西，不要什么心跳检测等复杂的东西，先简单实现，但是代码要给全

importjava.io.IOException;importjava.util.concurrent.CopyOnWriteArraySet;@ServerEndpoint("/frontend")publicclassFrontendEndpoint{//用于记录当前连接的前端A（这里假设只有一个前端A，所以用静态变量）...

FileUtil.copyContent(srcDir, destDir, true); 报下列错误 n.hutool.core.io.IORuntimeException: Src is a directory but dest is a file! at cn.hutool.core.io.file.FileCopier.copy(FileCopier.java:185) at cn.hutool.core.io.FileUtil.copyContent(FileUtil.java:947) at com.cpic.tcx.service.service.impl.TcxCultureServicelmpl.sendMaterials(TcxCultureServicelmpl.java:695) at com.cpic.tcx.service.service.impl.TcxCultureServicelmpl.getMyCultureByld(TcxCultureServicelmpl.java:398) at com.cpic.tcx.service.service.impl.TcxCultureServicelmpl$$FastClassBySpringCGLIB$$be2a98b3.invoke(<generated>) at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123) at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388) at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708) t com.cpic.tcx.service.service.impl.TcxCultureServicelmpI$$EnhancerBySpringCGLIB$$1ae56e60.getMyCultureByld(<generated>) at com.cpic.tcx.controller.TcxCultureController.getMyCultureByld(TcxCultureController.java:188) at com.cpic.tcx.controller.TcxCultureController$$FastClassBySpringCGLIB$$f69b79d4.invoke(<generated>) at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) at ora.sprinaframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.iava:163) nsh ua i st

我们正在解决Hutool库中FileUtil.copyContent方法因源目录和目标文件类型不匹配导致的IORuntimeException错误。具体错误信息是“Srcisadirectorybutdestisafile”。根据引用内容，我们知道Hutool的FileUtil类提供了...

在右侧代码区填充代码，实现如下功能：删除HDFS的/user/hadoop/目录（空目录）；删除HDFS的/tmp/test/目录（非空目录）；列出HDFS根目录下所有的文件和文件夹；列出HDFS下/tmp/的所有文件和文件夹。package step4; import java.io.IOException; import java.net.URI; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.FileUtil; import org.apache.hadoop.fs.Path; public class FileSystemDelete { public static void main(String[] args) throws IOException { //请在 Begin-End 之间添加代码，完成本关任务。 /***** Begin / / End *****/ } }

import java.io.IOException; import java.net.URI; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop....

package com.shanzhu.tourism.utils.recommend; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.map.MapUtil; import com.google.common.collect.Lists; import com.shanzhu.tourism.utils.recommend.dto.RelateDTO; import java.util.*; import java.util.stream.Collectors; import java.util.stream.IntStream; /** * 推荐算法 * * @author: ShanZhu * @date: 2024-07-25 */ public class CoreMath { /** * 推荐计算 */ public List<String> recommend(String userId, List<RelateDTO> list) { //找到最近邻用户id Map<Double, String> distances = computeNearestNeighbor(userId, list); if(MapUtil.isEmpty(distances)){ return Collections.EMPTY_LIST; } //取出相似度最近的用户id String nearest = distances.values().iterator().next(); Iterator<String> iterator = distances.values().iterator(); while (iterator.hasNext()) { nearest = iterator.next(); } Map<String, List<RelateDTO>> userMap = list.stream().collect(Collectors.groupingBy(RelateDTO::getUserId)); //最近邻用户涉及的业务id列表 List<String> neighborItemList = userMap.get(nearest).stream().map(e -> e.getProductId()).collect(Collectors.toList()); //当前用户涉及的业务id列表 List<String> userItemList = userMap.get(userId).stream().map(e -> e.getProductId()).collect(Collectors.toList()); //找到最近邻买过，但是该用户没涉及过的，计算推荐，放入推荐列表 List<String> recommendList = new ArrayList<>(); for (String item : neighborItemList) { if (!userItemList.contains(item)) { recommendList.add(item); } } Collections.sort(recommendList); return recommendList; } /** * 在给定userId的情况下，计算其他用户和它的相关系数并排序 */ private Map<Double, String> computeNearestNeighbor(String userId, List<RelateDTO> list) { //对同一个用户id数据，做分组 Map<String, List<RelateDTO>> userMap = list.stream().collect(Collectors.groupingBy(RelateDTO::getUserId)); //treemap是从小到大排好序的

List<String> lines = FileUtil.readLines("data.csv", StandardCharsets.UTF_8); // Guava构建稀疏矩阵 Table, Integer, Double> ratingMatrix = HashBasedTable.create(); 2. **核心算法实现** ...

commons-io.FileUtil.copyToFile

"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 100%"] ...

工件构建器: Error: Couldn't copy [D:\java chengxu\daer xia\JDBC_web\web\WEB-INF\lib\standard.jar] to [D:\java chengxu\daer xia\JDBC_web\out\artifacts\JDBC_web_war_exploded\WEB-INF\lib\standard.jar] java.io.IOException: Couldn't copy [D:\java chengxu\daer xia\JDBC_web\web\WEB-INF\lib\standard.jar] to [D:\java chengxu\daer xia\JDBC_web\out\artifacts\JDBC_web_war_exploded\WEB-INF\lib\standard.jar] at com.intellij.openapi.util.io.FileUtil.performCopy(FileUtil.java:412) at com.intellij.openapi.util.io.FileUtil.copyContent(FileUtil.java:401) at org.jetbrains.jps.incremental.FSOperations.copy(FSOperations.java:490) at org.jetbrains.jps.incremental.artifacts.instructions.FilterCopyHandler.copyFile(FilterCopyHandler.java:27) at org.jetbrains.jps.incremental.artifacts.instructions.FileBasedArtifactRootDescriptor.copyFromRoot(FileBasedArtifactRootDescriptor.java:89) at org.jetbrains.jps.incremental.artifacts.IncArtifactBuilder$IncArtifactBuilderHelper.processFiles(IncArtifactBuilder.java:236) at org.jetbrains.jps.incremental.artifacts.IncArtifactBuilder$IncArtifactBuilderHelper.build(IncArtifactBuilder.java:95) at org.jetbrains.jps.incremental.artifacts.IncArtifactBuilder.build(IncArtifactBuilder.java:50) at org.jetbrains.jps.incremental.artifacts.IncArtifactBuilder.build(IncArtifactBuilder.java:36) at org.jetbrains.jps.incremental.IncProjectBuilder.buildTarget(IncProjectBuilder.java:1314) at org.jetbrains.jps.incremental.IncProjectBuilder.runBuildersForChunk(IncProjectBuilder.java:608) at org.jetbrains.jps.incremental.IncProjectBuilder.buildTargetsChunk(IncProjectBuilder.java:1573) at org.jetbrains.jps.incremental.IncProjectBuilder.buildChunkIfAffected(IncProjectBuilder.java:1287) at org.jetbrains.jps.incremental.IncProjectBuilder$BuildParallelizer$1.run(IncProjectBuilder.java:1249) at com.intellij.util.concurrency.BoundedTaskExecutor.doRun(BoundedTaskExecutor.java:249) at com.intellij.util.concurrency.BoundedTaskExecutor.access$200(BoundedTaskExecutor.java:30) at com.intellij.util.concurrency.BoundedTaskExecutor$1.executeFirstTaskAndHelpQueue(BoundedTaskExecutor.java:227) at com.intellij.util.ConcurrencyUtil.runUnderThreadName(ConcurrencyUtil.java:218) at com.intellij.util.concurrency.BoundedTaskExecutor$1.run(BoundedTaskExecutor.java:212) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: java.nio.file.AccessDeniedException: D:\java chengxu\daer xia\JDBC_web\out\artifacts\JDBC_web_war_exploded\WEB-INF\lib\standard.jar at java.base/sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:89) at java.base/sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:103) at java.base/sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:108) at java.base/sun.nio.fs.WindowsFileSystemProvider.newByteChannel(WindowsFileSystemProvider.java:236) at java.base/java.nio.file.spi.FileSystemProvider.newOutputStream(FileSystemProvider.java:484) at java.base/java.nio.file.Files.newOutputStream(Files.java:228) at com.intellij.openapi.util.io.FileUtil.openOutputStream(FileUtil.java:445) at com.intellij.openapi.util.io.FileUtil.performCopy(FileUtil.java:408) ... 21 more

用户遇到了java.io.IOException，具体是AccessDeniedException，表明在复制文件时权限不足。通常，这类问题可能发生在以下几种情况：1.目标文件或目录已被其他进程锁定（例如，正在被另一个程序使用）。2.运行...

使用 Hutool 的 FileUtil.copyContent() 方法可以直接将源文件夹内部的所有内容（包含文件和子目录）复制到目标文件夹但是为啥子目录会报错n.hutool.core.io.IORuntimeException: Src is a directory but

File srcFile = FileUtil.file(srcDir, "example.txt"); File destFile = FileUtil.file(destDir, "backup.txt"); FileUtil.copyContent(srcFile, destFile, true); ### 预防措施复制操作前添加类型检查： ...

cn.hutool.core.io.file.FileWriter

import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.IoUtil; import cn.hutool.core.io.file.FileWriter; public class FileWriterExample { public static void main(String[] args) { try ...

cn.hutool.core.io

### Hutool Core IO Package Documentation and Usage Examples The Hutool library is designed to provide developers with a set of utility classes that simplify common programming tasks. The io package...

图片压缩失败: IIOException: Can't read input file! cn.hutool.core.io.IORuntimeException: IIOException: Can't read input file! at cn.hutool.core.img.ImgUtil.read(ImgUtil.java:1755) at cn.hutool.core.img.ImgUtil.scale(ImgUtil.java:83) at com.mdd.admin.HelloWorld.scaleImage(HelloWorld.java:27) at com.mdd.admin.HelloWorld.main(HelloWorld.java:15) Caused by: javax.imageio.IIOException: Can't read input file! at javax.imageio.ImageIO.read(ImageIO.java:1301) at cn.hutool.core.img.ImgUtil.read(ImgUtil.java:1753) ... 3 more

import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.IoUtil; import cn.hutool.image.ImgUtil; import cn.hutool.image.ImageException; import javax.imageio.ImageIO; import java.awt.image....

hutool FileUtil

Hutool是一个Java工具库，其中的FileUtil类提供了一系列操作文件的静态方法。该类可以用于处理文件的读取、写入、复制、删除等操作。下面是FileUtil类的一些常用方法： 1. readUtf8String(File file)：以UTF-8...

基于双向长短期记忆网络(BILSTM)的MATLAB数据分类预测代码实现与应用

基于双向长短期记忆网络（BILSTM）的数据分类预测技术及其在MATLAB中的实现方法。首先解释了BILSTM的工作原理，强调其在处理时间序列和序列相关问题中的优势。接着讨论了数据预处理的重要性和具体步骤，如数据清洗、转换和标准化。随后提供了MATLAB代码示例，涵盖从数据导入到模型训练的完整流程，特别指出代码适用于MATLAB 2019版本及以上。最后总结了BILSTM模型的应用前景和MATLAB作为工具的优势。适合人群：对机器学习尤其是深度学习感兴趣的科研人员和技术开发者，特别是那些希望利用MATLAB进行数据分析和建模的人群。使用场景及目标：①研究时间序列和其他序列相关问题的有效解决方案；②掌握BILSTM模型的具体实现方式；③提高数据分类预测的准确性。阅读建议：读者应该具备一定的编程基础和对深度学习的理解，在实践中逐步深入理解BILSTM的工作机制，并尝试调整参数以适应不同的应用场景。

MySQL索引概览

数据结构底层决定（严格的按照第一个，第二个，第三个字段一个一个匹配），不符合最左匹配则需要全局扫描了；且最左匹配原则遇到范围查询就停止匹配a int,b int,c int,用到索引 a用到索引 a,b用到索引 a,b,c或者或者索引失效用到索引 a用到索引a和b（b的范围导致未用到c用到索引a,b,c只用索引a只用到索引a用到a,b,c用到索引a，没有用到索引b主键索引：又叫聚簇索引，是一种特殊的唯一索引，一个表只能有一个主键，不允许有空值普通索引：也叫非主键索引，回表，借助主键索引。

职业的学校信息化建设.doc

相关推荐

hutool.jar工具包+多音字词典文件.zip

人脸识别依赖的常用java类以及依赖jar包.rar

Xenos.zip_"blackbone" 使用_FileUtil.cpp:452:_Xenos 注入 使用_dll注入_saf

commons-io.FileUtil.copyToFile

使用 Hutool 的 FileUtil.copyContent() 方法可以直接将源文件夹内部的所有内容（包含文件和子目录）复制到目标文件夹 但是为啥子目录会报错n.hutool.core.io.IORuntimeException: Src is a directory but

cn.hutool.core.io.file.FileWriter

cn.hutool.core.io

hutool FileUtil

基于双向长短期记忆网络(BILSTM)的MATLAB数据分类预测代码实现与应用

MySQL索引概览

职业的学校信息化建设.doc

大家在看

indonesia-geojson:印度尼西亚GEOJSON文件收集

JSP SQLServer 网上购物商城 毕业论文

ROS_Android DEMO

Total Commander软件及注册工具

签约中投科信接口设计 商户绑卡签约

最新推荐

利用讯飞语音听写接口实现实时语音转写.doc

基于Debian Jessie的Kibana Docker容器部署指南

Coze智能体工作流：打造钦天监视频内容的创新与实践

使用git仓库的利与弊

TextWorld：基于文本游戏的强化学习环境沙箱

Coze智能体工作流全攻略

64位小端转大端c语言函数起名

upReveal.js: 利用鼠标移动揭示图像的创新技术

金融服务中AI Agent的崛起：智能投资顾问与风险管理

小端转大端c语言函数起名

Xenos.zip_"blackbone" 使用_FileUtil.cpp:452:_Xenos 注入使用_dll注入_saf

使用 Hutool 的 FileUtil.copyContent() 方法可以直接将源文件夹内部的所有内容（包含文件和子目录）复制到目标文件夹但是为啥子目录会报错n.hutool.core.io.IORuntimeException: Src is a directory but

JSP SQLServer 网上购物商城毕业论文

签约中投科信接口设计商户绑卡签约