receiver.java

《java网络编程精解》的源代码

import java.io.*;
import java.net.*;
public class Receiver {
  private int port=8000;
  private ServerSocket serverSocket;
  private static int stopWay=1;  //结束通信的方式
  private final int NATURAL_STOP=1; //自然结束
  private final int SUDDEN_STOP=2;  //突然终止程序
  private final int SOCKET_STOP=3;  //关闭Socket，再结束程序
  private final int INPUT_STOP=4;  //关闭输入流，再结束程序
  private final int SERVERSOCKET_STOP=5;  //关闭ServerSocket，再结束程序

  public Receiver() throws IOException {
    serverSocket = new ServerSocket(port);
    System.out.println("服务器已经启动");
  }

  private BufferedReader getReader(Socket socket)throws IOException{
    InputStream socketIn = socket.getInputStream();
    return new BufferedReader(new InputStreamReader(socketIn));
  }

  public void receive() throws Exception{
    Socket socket=null;
    socket = serverSocket.accept();
    BufferedReader br =getReader(socket);
    
    for(int i=0;i<20;i++) {
       String msg=br.readLine();
       System.out.println("receive:"+msg);
       Thread.sleep(1000);
       if(i==2){  //终止程序，结束通信
        if(stopWay==SUDDEN_STOP){
          System.out.println("突然终止程序");
          System.exit(0);
        }else if(stopWay==SOCKET_STOP){
          System.out.println("关闭Socket并终止程序");
          socket.close();
          break;
        }else if(stopWay==INPUT_STOP){
          System.out.println("关闭输入流并终止程序");
          socket.shutdownInput();
          break;
        }else if(stopWay==SERVERSOCKET_STOP){
          System.out.println("关闭ServerSocket并终止程序");
          serverSocket.close();
          break;
        } 
      }  
    }
    
    if(stopWay==NATURAL_STOP){
      socket.close();
      serverSocket.close(); 
    }
  }  
  
  public static void main(String args[])throws Exception {
    if(args.length>0)stopWay=Integer.parseInt(args[0]);
    new Receiver().receive();
  }
}


/****************************************************
 * 作者：孙卫琴                                     *
 * 来源：<<Java网络编程精解>>                       *
 * 技术支持网址：www.javathinker.org                *
 ***************************************************/