springboot+websocket进度条实战

package com.fl.timeprocessor.controller; import com.fl.timeprocessor.entity.ProcessInfo; import com.fl.timeprocessor.server.WebSocketServer; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import javax.annotation.PostConstruct; /** * Created with IntelliJ IDEA. * * @Author: fulin * @Date: 2022/11/08/10:40 * @Description: */ @RestController public class ProcessInfoController { //伪造id 可以用UUID public int index = 1; //模拟任务 @PostConstruct public void init() { for (int i = 0; i < 10; i++) { ProcessInfo processInfo = new ProcessInfo(String.valueOf(i), 100000l); WebSocketServer.processInfoList.add(processInfo); } startAll(); } @GetMapping("/edit/{time}") public String edit(@PathVariable("time") long duration) { ProcessInfo processInfo = new ProcessInfo(index + "", duration); WebSocketServer.processInfoList.add(processInfo); return "ok"; } @GetMapping("/start/all") public String startAll() { WebSocketServer.processInfoList.stream().forEach(processInfo -> processInfo.start()); return "ok"; } @GetMapping("/start/{id}") public String startById(@PathVariable("id") String id) { WebSocketServer.processInfoList.stream().filter(processInfo -> processInfo.getId().equals(id)).forEach(processInfo -> processInfo.start()); return "ok"; } @GetMapping("/stop/{id}") public String stopById(@PathVariable("id") String id) { WebSocketServer.processInfoList.stream().filter(processInfo -> processInfo.getId().equals(id)).forEach(processInfo -> processInfo.stop()); return "ok"; } @GetMapping("/stopAll") public String stopAll() { WebSocketServer.processInfoList.stream().forEach(processInfo -> processInfo.stop()); return "ok"; } @GetMapping("/restart") public String reStartAll() { WebSocketServer.processInfoList.stream().forEach(processInfo -> processInfo.restart()); return "ok"; } @GetMapping("/restart/{id}") public String reStart(@PathVariable("id") String id) { WebSocketServer.processInfoList.stream().filter(processInfo -> processInfo.getId().equals(id)).forEach(processInfo -> processInfo.restart()); return "ok"; } }