serverdemo.java~11~

服务器聊天室编写 c/s

package serverdemo;

import javax.swing.UIManager;

import java.net.*;
import java.io.*;

public class ServerDemo{
  public static void main(String[] args) throws IOException {
    ServerSocket serverSocket = null;
    try {
      serverSocket = new ServerSocket(9998);
    }
    catch (IOException e) {
      System.err.println("不能创建1111端口");
      System.exit(1);
    }
    while (true) {
      Socket clientSocket = null;
      try {
        clientSocket = serverSocket.accept();
      }
      catch (IOException e) {
        System.err.println("访问端口失败");
        System.exit(1);
      }
      (new ClientThread(clientSocket)).start();
    }
    //serverSocket.close();
   // serverSocket.close();
  }
}

  class ClientThread
      extends Thread {
    Socket clientSocket = null;
    PrintWriter out = null;
    BufferedReader in = null;
    boolean runable = true;

    public ClientThread(Socket clientSocket) {
      this.clientSocket = clientSocket;
    }

    public void run() {
      String toClient;
      try {
        out = new PrintWriter(clientSocket.getOutputStream(), true);
        in = new BufferedReader(new InputStreamReader(clientSocket.
            getInputStream()));
        BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.
            in));
        toClient = "您好";
        out.println(toClient);
        ReadClientThread readClientThread = new ReadClientThread(in);
        readClientThread.start();
        while (runable) {
          toClient = stdIn.readLine();
          out.println(toClient);
          if (toClient.equals("Bye"))break;
          runable = readClientThread.runable;
        }
        readClientThread.fromClient = "欢迎下次再来";
        readClientThread.runable = false;
        out.close();
        in.close();
        stdIn.close();
        clientSocket.close();
      }
      catch (Exception e) {
        e.printStackTrace();
      }
    }
  }


class ReadClientThread extends Thread{
  BufferedReader in = null;
  String fromClient = "";
  boolean runable = true;
  public ReadClientThread(BufferedReader in){
    this.in = in;
  }
  public void run(){
    while(runable){
      try{fromClient = in.readLine();}catch(Exception e){runable = false;}
      if(fromClient.equals("Bye")){
        System.out.print("客户端程序退出");
        runable = false;
        break;

      }
      System.out.println("客户端" + fromClient);
    }
  }

}