server1.java

来自「本书结合作者丰富的实践经验和深厚的理论基础」· Java 代码 · 共 53 行

import java.io.*;
import java.net.*;
public class Server1 extends Thread {
   Socket socket1;
   public Server1( Socket s) {
      socket1=s;
      start();
   }
   public void run() {
      try {
         BufferedReader in=new BufferedReader(new InputStreamReader(socket1.getInputStream()));
         PrintWriter out =new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket1.getOutputStream())), true);
         for (int i = 0; i < 5; i ++) {
            String str=in.readLine();
            System.out.println("Server receives " +str);
            out.println("Server returns back "+str);
         }
         System.out.println("closing...");
      }
   catch (IOException e) {
      System.err.println("IO Exception");
   }
   finally {
      try {
         socket1.close();
      }
      catch (IOException e) {
         System.err.println("Socket not closed");
      }
   }
}

static final int PORT = 8080;
public static void main(String[] args) throws IOException {
   ServerSocket s = new ServerSocket(PORT);
      System.out.println("Server Started");
      try {
         while(true) {
            Socket socket1 = s.accept();
            try {
               new Server1(socket1);
            }
            catch(Exception e) {
                socket1.close();
            }
         }
      }
      finally {
         s.close();
      }
   }
}