Operating-System.zip

package com.example.operating_system.controller; import com.example.operating_system.Threads.RunnableTest; import jakarta.websocket.server.PathParam; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import java.io.IOException; import java.net.*; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ThreadPoolExecutor; @RestController public class MainController { /** * 获取host里的FPort-LPort端口所有状态 * @param host * @param FPort * @param LPort * @return */ @GetMapping("/scan/{host}/{FPort}/{LPort}/{type}/{thread}") public String Scan(@PathVariable("host") String host, @PathVariable("FPort") String FPort, @PathVariable("LPort") String LPort, @PathVariable("type") String type, @PathVariable("thread") String thread) { int startPort = Integer.parseInt(FPort); int endPort = Integer.parseInt(LPort); int threads = Integer.parseInt(thread); //创建线程池 ExecutorService service = Executors.newFixedThreadPool(threads); ThreadPoolExecutor service1 = (ThreadPoolExecutor) service; //设置线程池属性 service1.setMaximumPoolSize(500);//设置线程池中线程数的上限 for (int port = startPort; port <= endPort; port++) { service.execute(new RunnableTest(host,port,type)); } System.out.println("成功调用"); //关闭线程池 service.shutdown(); return "请求成功"; } /** * 获取host里的FPort-LPort端口所有状态 * @param host * @param FPort * @param LPort * @return */ @GetMapping("/scan/{host}/{FPort}/{LPort}/{type}") public String Scan(@PathVariable("host") String host, @PathVariable("FPort") String FPort, @PathVariable("LPort") String LPort, @PathVariable("type") String type) { int startPort = Integer.parseInt(FPort); int endPort = Integer.parseInt(LPort); for (int port = startPort; port <= endPort; port++) { if (TCPisPortOpen(host, port)) { if (type.equals("close")) { continue; } String message = "Port " + port + " is open"; System.out.println(message); ScannerController.broadcast(message); } else { if (type.equals("open")) { continue; } String message = "Port " + port + " is closed"; System.out.println(message); ScannerController.broadcast(message); } } System.out.println("成功调用"); return "请求成功"; } private static boolean TCPisPortOpen(String host, int port) { try { // 创建Socket并尝试连接 Socket socket = new Socket(); socket.connect(new InetSocketAddress(host, port), 1000); // 1000毫秒超时 socket.close(); return true; } catch (IOException e) { return false; } } private static boolean UDPisPortOpen(String host, int port) { try{ DatagramSocket socket = new DatagramSocket(); socket.setSoTimeout(1000); byte[] buffer = new byte[1]; DatagramPacket packet = new DatagramPacket(buffer, buffer.length, InetAddress.getByName(host), port); socket.send(packet); socket.receive(packet); System.out.println("Port "+port+ " is open baseUDP"); return true; }catch (IOException e) { System.out.println("Port "+port+ " is close baseUDP"); return false; } } }