1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 |
- 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();
- }
- }
- }
|