serverformult.java

来自「Java程序设计实用教程源代码 本书源代码按章分别放置在不同的文件夹中,所有程」· Java 代码 · 共 55 行

import java.io.*;
import java.net.*;
import java.util.*;
public class serverForMult extends Thread {
  Socket server;
  public serverForMult(Socket socket) {
    server = socket;
    start();
  }
  public void run() {
    try {
      BufferedReader br = new BufferedReader(new InputStreamReader(server.
          getInputStream()));
      PrintWriter pw = new PrintWriter(new BufferedWriter(new
          OutputStreamWriter(server.getOutputStream())), true);
      for (int i = 0; i<10; i++) {
        String str = br.readLine();
        System.out.println("服务器接收：" + str);
        pw.println((new Date()).toString() + "服务器返回：" + str);
      }
      System.out.println("关闭线程…");
    }
    catch (IOException e) {
      System.err.println("IO异常");
    }
    finally {
      try {
        server.close();
      }
      catch (IOException e) {
        System.err.println("未关闭Socket！");
      }
    }
  }
  static final int PORT = 8001;
  public static void main(String[] args) throws IOException {
    ServerSocket serverSocket = new ServerSocket(PORT);
    System.out.println("已启动服务器");
    try {
      while (true) {
        Socket socket1 = serverSocket.accept();
        try {
          new serverForMult(socket1);
        }
        catch (Exception e) {
          socket1.close();
        }
      }
    }
    finally {
      serverSocket.close();
    }
  }
}