serverdemo.java

JAVA类库参考手册

package clientserverchat;
import java.net.*;
import java.io.*;

public class ServerDemo
{
        public static void main(String [] args) throws IOException
              {
                 String toClient;
                 PrintWriter out=null;
                 BufferedReader in=null;
                 boolean runable=true;

                 ServerSocket serverSocket=null;
                 try
                    {
                      serverSocket=new ServerSocket(8000);
                    }
                 catch(IOException e)
                    {
                       System.out.println("不能创建8001端口");
                       System.exit(1);
                    }
                  Socket clientSocket=null;
                  try
                    {
                       clientSocket=serverSocket.accept();
                    }
                  catch(IOException e)
                    {
                       System.err.println("访问端口失败");
                       System.exit(1);
                    }
                   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();
                   serverSocket.close();
          }
}


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