package com.neusoft.edu.socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
/**
 * 服務(wù)器端代碼
 * 獲取客戶端發(fā)送的信息，顯示并且返回對應(yīng)的回復(fù)
 * 1、創(chuàng)建ServerSocket對象
 * 2、調(diào)用accept方法獲取客戶端連接
 * 3、使用輸入流讀取客戶端發(fā)送的數(shù)據(jù)
 * 4、使用輸出流向客戶端寫入數(shù)據(jù)
 * 5、關(guān)閉對應(yīng)的對象
 * @author L
 *
 */
public class ChatServer {
    /**
     * @param args
     */
    public static void main(String[] args) {
        try {
            //1、創(chuàng)建ServerSocket對象,8875為自定義端口號
            ServerSocket server = new ServerSocket(8857);

            //簡單提示
            System.out.println("等待客戶端連接……");

            //2、獲取客戶端連接
            Socket client = server.accept();

            //獲取客戶端的相關(guān)信息
            System.out.println(client.getInetAddress().getHostAddress() + "連接上來了……");

            //3.1、定義輸入流和輸出流對象
            BufferedReader in = new BufferedReader(
                    new InputStreamReader(
                            client.getInputStream()));

            //用來獲取從控制臺輸入的數(shù)據(jù)，將該數(shù)據(jù)發(fā)送給客戶端
            BufferedReader inByServer = new BufferedReader(
                    new InputStreamReader(System.in));

            PrintWriter out = new PrintWriter(client.getOutputStream(), true);

            //讀取到的數(shù)據(jù)
            String data = null;
            String answer = null;

            //循環(huán)和客戶端進(jìn)行通信
            do
            {
                //3.2、讀取客戶端發(fā)送的數(shù)據(jù)
                data = in.readLine();

                //在服務(wù)器端顯示讀取到的數(shù)據(jù)
                System.out.println("客戶端發(fā)送信息：" + data);

                //獲取服務(wù)器端要發(fā)送給客戶端的信息
                System.out.print("服務(wù)器端回復(fù)客戶端：");
                answer = inByServer.readLine();

                //3.3、將數(shù)據(jù)寫入到客戶端
                out.println(answer);
                out.flush();
            }while(!"bye".equals(data));

            //4、關(guān)閉相關(guān)資源
            out.flush();
            in.close();
            inByServer.close();
            out.close();

            //關(guān)閉Socket對象
            client.close();
            server.close();

            System.out.println("服務(wù)器端關(guān)閉……");
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

package com.neusoft.edu.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * 聊天客戶端
 * 1、創(chuàng)建Socket對象
 * 2、寫入數(shù)據(jù)
 * 3、讀取從服務(wù)器端發(fā)來的數(shù)據(jù)
 * 4、關(guān)閉
 * @author L
 *
 */
public class ChatClient {

    /**
     * @param args
     */
    public static void main(String[] args) {
        try {
            //1、創(chuàng)建Socket對象，("192.168.1.107", 8857)分別為主機(jī)IP和端口號，兩個類端口號要一致
            Socket client = new Socket("192.168.1.107", 8857);

            //2.1、創(chuàng)建輸入流和輸出流對象
            BufferedReader in = new BufferedReader(
                    new InputStreamReader(
                            client.getInputStream()));

            PrintWriter out = new PrintWriter(client.getOutputStream(), true);

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

            //服務(wù)器端發(fā)送的數(shù)據(jù)
            String data = null;
            //客戶端向服務(wù)器端寫入的數(shù)據(jù)
            String answer = null;

            do
            {
                //2.2、客戶端的讀寫操作
                System.out.print("你說：");
                //獲取要發(fā)送給服務(wù)器端的數(shù)據(jù)
                answer = inByClient.readLine();
                //向服務(wù)器端寫入數(shù)據(jù)
                out.println(answer);
                out.flush();

                //獲取服務(wù)器端發(fā)送的數(shù)據(jù)
                data = in.readLine();
                //輸出從服務(wù)器端獲取的數(shù)據(jù)
                System.out.println("服務(wù)器端返回信息是：" + data);
            }while(!"bye".equals(data));

            //3、關(guān)閉
            in.close();
            out.close();
            inByClient.close();
            client.close();

            System.out.println("客戶端關(guān)閉……");
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}