package com.sf.socket; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; public class Server { public static void main(String[] args) throws Exception { // 创建一个端口号为 1234的进程 ServerSocket serverSocket = new ServerSocket(1234); // 等待客户端的连接 while (true){ // 通过 accept()方法 可以接收到一个连接过来的客户端 Socket socket = serverSocket.accept(); // 此时接收数据 是输入 // InputStream inputStream = socket.getInputStream(); // // 通过字节数组 将输入流的内容显示为字符串 // byte[] bytes = new byte[1024]; // // 将输入流的数据 写入字节数组中 // int len = inputStream.read(bytes); // // 通过传入内容的大小 来构建字符串 // String message = new String(bytes, 0, len); // System.out.println(message); // // System.out.println(System.currentTimeMillis()); // // 打印当前时间 // LocalDateTime now = LocalDateTime.now(); // // 定义格式 // DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); // String str = now.format(formatter); // System.out.println("当前时间:" + str); // // // 当前服务端的处理 是一个一个处理的 第一个结束后 要等待5s 才处理第二个 // // 模拟服务端的处理时间 // Thread.sleep(5000); MyTask myTask = new MyTask(socket); Thread thread = new Thread(myTask); thread.start(); } } }