import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.ServerSocket;

import java.net.Socket;

public class ChatServer {

    public static void main(String[]   args)  {

       ServerSocket server=null;

       Socket socket=null;

       BufferedReader in=null;

       try {

           server = new ServerSocket(8888);

           socket=server.accept();

           new ServerThread(socket).start();

           //main线程负责读取客户端发来的信息

           in=new BufferedReader(new   InputStreamReader(socket.getInputStream()));

           while(true){

              String str=in.readLine();

              System.out.println("客户端说："+str);

           }

       } catch (IOException e) {

           e.printStackTrace();

       }finally{

           try {

              in.close();

           } catch (IOException e) {

              e.printStackTrace();

           }

           try {

              socket.close();

           } catch (IOException e) {

              e.printStackTrace();

           }

       }

    }

}

/**

 * 专门向客户端发送消息的线程

 * @author Administrator

 *

 */

class ServerThread extends Thread {

    Socket ss;

    BufferedWriter out;

    BufferedReader br;

    public ServerThread(Socket ss){

       this.ss = ss;

       try {

           out=new BufferedWriter(new   OutputStreamWriter(ss.getOutputStream()));

           br = new BufferedReader(new   InputStreamReader(System.in));      

       } catch (IOException e) {

           e.printStackTrace();

       }

    }

    public void run(){

       try {

           while(true){

              String str2 = br.readLine();

              out.write(str2+"\n");

              out.flush();  

           }

       } catch (IOException e) {

           e.printStackTrace();

       }finally{

           try {

              out.close();

           } catch (IOException e) {

              e.printStackTrace();

           }

           try {

              br.close();

           } catch (IOException e) {

              e.printStackTrace();

           }

       }

    }

}

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.InetAddress;

import java.net.Socket;

import java.net.UnknownHostException;

public class ChatClient {

    public static void main(String[] args) {

       Socket  socket = null;  

       BufferedReader in = null;

       try {

           socket=new Socket(InetAddress.getByName("192.168.1.32"),8888);  

           new ClientThread(socket).start();

           in=new BufferedReader(new   InputStreamReader(socket.getInputStream()));

           //main线程负责接收服务器发来的信息

           while(true){

               System.out.println("服务器说："+in.readLine());  

           }

       } catch (UnknownHostException e) {

           e.printStackTrace();

       } catch (IOException e) {

           e.printStackTrace();

       }finally{

           try {

              socket.close();

           } catch (IOException e) {

              e.printStackTrace();

           }

           try {

              in.close();

           } catch (IOException e) {

              e.printStackTrace();

           }

       }

    }

}  

/**

 * 用于向服务器发送消息

 * @author Administrator

 *

 */

class ClientThread extends Thread{

    Socket s;

    BufferedWriter out;

    BufferedReader wt;

    public ClientThread(Socket s){

       this.s = s;

       try {

           out=new BufferedWriter(new   OutputStreamWriter(s.getOutputStream()));

           wt=new BufferedReader(new   InputStreamReader(System.in));

       } catch (IOException e) {

           e.printStackTrace();

       }

    }

    public void run(){

           try {

              while(true){

                  String str = wt.readLine();

                  out.write(str+"\n" );

                  out.flush();

              }

           } catch (IOException e) {

              e.printStackTrace();

           }finally{

              try {

                  wt.close();

              } catch (IOException e) {

                  e.printStackTrace();

              }

               try {

                  out.close();

              } catch (IOException e) {

                  e.printStackTrace();

              }

           }

    }

}