Server.java 1.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. package com.sf.socket;
  2. import java.io.InputStream;
  3. import java.net.ServerSocket;
  4. import java.net.Socket;
  5. import java.time.LocalDateTime;
  6. import java.time.format.DateTimeFormatter;
  7. public class Server {
  8. public static void main(String[] args) throws Exception {
  9. // 创建一个端口号为 1234的进程
  10. ServerSocket serverSocket = new ServerSocket(1234);
  11. // 等待客户端的连接
  12. while (true){
  13. // 通过 accept()方法 可以接收到一个连接过来的客户端
  14. Socket socket = serverSocket.accept();
  15. // 此时接收数据 是输入
  16. // InputStream inputStream = socket.getInputStream();
  17. // // 通过字节数组 将输入流的内容显示为字符串
  18. // byte[] bytes = new byte[1024];
  19. // // 将输入流的数据 写入字节数组中
  20. // int len = inputStream.read(bytes);
  21. // // 通过传入内容的大小 来构建字符串
  22. // String message = new String(bytes, 0, len);
  23. // System.out.println(message);
  24. //
  25. // System.out.println(System.currentTimeMillis());
  26. // // 打印当前时间
  27. // LocalDateTime now = LocalDateTime.now();
  28. // // 定义格式
  29. // DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
  30. // String str = now.format(formatter);
  31. // System.out.println("当前时间:" + str);
  32. //
  33. // // 当前服务端的处理 是一个一个处理的 第一个结束后 要等待5s 才处理第二个
  34. // // 模拟服务端的处理时间
  35. // Thread.sleep(5000);
  36. MyTask myTask = new MyTask(socket);
  37. Thread thread = new Thread(myTask);
  38. thread.start();
  39. }
  40. }
  41. }