實(shí)現(xiàn)目標(biāo)

• 實(shí)現(xiàn)服務(wù)端與客戶端的連接
• 實(shí)現(xiàn)多個(gè)客戶端向服務(wù)端發(fā)送消息森缠，并由服務(wù)端將消息發(fā)送給每個(gè)客戶端

涉及的Java類

• java.net.ServerSocket 用于創(chuàng)建服務(wù)器端口
• java.net.Socket 用于創(chuàng)建Socket
• java.net.URLDecoder 用于在服務(wù)端將客戶端傳來(lái)的消息解碼
• java.util.ArrayList 用于動(dòng)態(tài)存放多個(gè)不同的Socket
• Java.util.scanner 用于從控制臺(tái)讀取輸入

具體實(shí)現(xiàn)思路

• 服務(wù)端

  • 在主函數(shù)中建立一個(gè)端口用于監(jiān)聽(tīng)客戶端請(qǐng)求适刀，端口大小可自行設(shè)置

    ServerSocket sock = new ServerSocket(1999)
    

  • 需要接受多個(gè)客戶端的消息祷舀，因此需要和每個(gè)客戶端建立唯一的Socket對(duì)用于通信党涕，所以需要將新建的Socket存入動(dòng)態(tài)容器ArrayList<Socket>中

    ArrayList<Socket> list = new ArrayList<Socket>()
    

  • 使用while循環(huán)，在while循環(huán)中調(diào)用ServerSocket的accept()方法等待客戶端請(qǐng)求返奉，當(dāng)接受到請(qǐng)求時(shí)就將返回的Socket存入容器中尤蒿，并新建一個(gè)線程(調(diào)用start函數(shù))

    while(true) {
        Socket socket = sock.accept();
        list.add(socket);
        new MsgThread(socket, list).start();
    }
    

  • 在線程類中進(jìn)行數(shù)據(jù)的讀入和輸出

  • 定義類的屬性：Socket, ArrayList<Socket>,BufferedReader

  • 定義構(gòu)造函數(shù)粗合，將傳入的參數(shù)賦給當(dāng)前對(duì)象的屬性，同時(shí)乌昔，通過(guò)Socket讀取客戶端的數(shù)據(jù)到BufferedReader對(duì)象

    BufferedReader bf = new BufferedReader(new   InputStreamReader(client.getInputStream));
    //這里需要用InputStreamReader類來(lái)包裝client.getInputStream是為了將字節(jié)流轉(zhuǎn)換成字符流
    

  • 重載run函數(shù)隙疚，將讀取的消息發(fā)送給除當(dāng)前socket對(duì)象外的其他客戶端

    • 在這一步中的PrintWriter的使用要注意，一定要將自動(dòng)刷新設(shè)置為true磕道，否則消息就不能夠即時(shí)傳入到內(nèi)存中供屉，而是會(huì)等到程序結(jié)束時(shí)才傳入，這個(gè)bug卡了我好久

  • 將消息解碼后顯示在控制臺(tái)上

• 客戶端

  • 和服務(wù)端差不多的思路溺蕉，主要是實(shí)現(xiàn)消息的讀取和上傳

  • 新建Socket伶丐，連接服務(wù)端

    Socket client = new Socket("127.000.001", 1999;
    

  • 讀取Socket中的數(shù)據(jù)并顯示在控制臺(tái)上

  • 線程函數(shù)和服務(wù)端類似，無(wú)非是從控制臺(tái)讀取數(shù)據(jù)然后用getOutPutStream寫(xiě)入Socket中

源碼

//服務(wù)端
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.URLDecoder;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;

public class ChatServer {
    //SockerList用于保存當(dāng)前連接的用戶
    public static ArrayList<Socket> SocketList = new ArrayList<Socket>();
    public static void main(String[] args) throws IOException {
        //創(chuàng)建端口監(jiān)聽(tīng)用戶的請(qǐng)求
        ServerSocket sock = new ServerSocket(1999);
        System.out.println("服務(wù)啟動(dòng)....");
        //服務(wù)器循環(huán)接受來(lái)自用戶端的請(qǐng)求
        while(true) {
            //等待客戶端的請(qǐng)求疯特，捕獲到請(qǐng)求后返會(huì)一個(gè)Socket
            Socket socket = sock.accept();
            System.out.println("服務(wù)連接....");
            //將返回的Socket加入在線用戶列表中
            SocketList.add(socket);
            System.out.println("當(dāng)前有" + (SocketList.size()) + "個(gè)用戶");
            //創(chuàng)建一個(gè)新的線程哗魂，每個(gè)連接都會(huì)有自己獨(dú)立的任務(wù)線程，用于實(shí)現(xiàn)接受和發(fā)送消息
            new MsgThread(socket, SocketList).start();
        }
    }
}

//任務(wù)線程
class MsgThread extends Thread {
    //定義單個(gè)用戶連接的Socket
    Socket client;
    //定義用戶組的Socket
    ArrayList<Socket> clients;
    //定義讀入的數(shù)據(jù)
    BufferedReader br;
    //構(gòu)造函數(shù)
    public MsgThread(Socket client, ArrayList<Socket> clients) throws IOException {
        //調(diào)用父類的構(gòu)造函數(shù)
        super();
        //使用傳入的參數(shù)初始化
        this.client = client;
        this.clients = clients;
        //將當(dāng)前用戶的輸入緩存
        br = new BufferedReader(new InputStreamReader(this.client.getInputStream()));
    }
    //重載run()函數(shù)漓雅，將接受到的用戶信息發(fā)送給其他用戶
    @Override
    public void run() {
        try {
            String content = null;
            while(true) {
                //從某個(gè)客戶端獲取信息
                if ((content = br.readLine()) != null) {
                    //將消息發(fā)送給其他各個(gè)客戶端
                    for (Socket socket:clients) {
                        //去掉自身客戶端
                        if (socket != client) {
                            //將消息寫(xiě)入socket的緩存區(qū),設(shè)置為自動(dòng)刷新
                            PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);
                            pw.println(content);
                        }
                    }
                    content = URLDecoder.decode(content, "UTF-8");
                    System.out.println(content);
                }
            }
        }
        catch (IOException e) {
            e.printStackTrace();
        }
    }
}

//客戶端
import java.io.*;
import java.net.*;

public class ChatClient {

    public static void main(String[] args) throws Exception {
        //連接服務(wù)端
        Socket client = new Socket("127.0.0.1", 1999);
        System.out.println("服務(wù)器已連接");
        //新建線程
        new MsgThread(client).start();
        //獲取輸入
        InputStream in = client.getInputStream();
        BufferedReader bf = new BufferedReader(new InputStreamReader(in));
        while (true) {
            String msg = bf.readLine();
            //對(duì)收到的信息進(jìn)行解碼
            msg=URLDecoder.decode(msg, "UTF-8");
            System.out.println(msg);
        }
    }
}

class MsgThread extends Thread {
    Socket client;
    String hostname;
    public MsgThread(Socket client) {
        super();
        this.client = client;
        try {
            //獲取本計(jì)算機(jī)名稱
            InetAddress addr = InetAddress.getLocalHost();
            hostname =addr.getHostName().toString();
        } catch (UnknownHostException e1) {
            e1.printStackTrace();
        }
    }
    //發(fā)送消息
    @Override
    public void run() {
        try {
            //讀取控制臺(tái)輸入
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            //將客戶端輸出流存到pw中
            PrintWriter pw = new PrintWriter(client.getOutputStream(),true);
            while (true) {
                String msg = br.readLine();
                //對(duì)發(fā)出的消息進(jìn)行編碼
                msg = URLEncoder.encode(hostname + "說(shuō):"+ msg, "UTF-8");
                pw.println(msg);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}