Java-->實現群聊功能(C/S模式--TCP協議)

--> Java 對TCP協議的支持：

--> java.net包中定義了兩個類ServerSocket 和Socket ，分別用來實現雙向連接的server 端和client 端。

--> Client 類定義客戶端

package com.dragon.java.tcpchat;

import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * 客戶端
 * 
 * @author Auser
 * 
 */
public class Client {
    public static void main(String args[]) throws UnknownHostException,
            IOException {
        Socket client = new Socket("192.168.1.188", 10000);

        // 穿件發送信息的線程
        new ClientSend(client).start();
        // 創建接收信息的線程
        new ClientReceive(client).start();

　　　　　// 因為要實現聊天功能，而不是只發送一次信息，所以輸出流和客戶端都不能關閉。
        // client.shutdownOutput();
        // client.close();

    }
}

--> ClientSend 類 定義客戶端向服務端發送信息的線程

package com.dragon.java.tcpchat;

import java.io.IOException;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;

/**
 * 客戶端向服務端發送信息的線程
 * 
 * @author Auser
 * 
 */
public class ClientSend extends Thread {
    private Scanner scanner;
    private Socket socket;

    public ClientSend(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        scanner = new Scanner(System.in);

        try {
            PrintStream ps = new PrintStream(socket.getOutputStream());
            String line = "";
            // 阻塞式發送信息
            while ((line = scanner.nextLine()) != null) {
                ps.println(line);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

--> ClientReceive 類 定義客戶端接收服務端信息的線程

package com.dragon.java.tcpchat;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;

/**
 * 客戶端接收信息的線程
 * 
 * @author Auser
 * 
 */
public class ClientReceive extends Thread {
    private Socket socket;

    public ClientReceive(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            BufferedReader br = new BufferedReader(new InputStreamReader(
                    socket.getInputStream()));
            // 按行接收信息
            String line = "";
            while ((line = br.readLine()) != null) {
                System.out.println(line);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

--> Server 類定義服務端

package com.dragon.java.tcpchat;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

/**
 * 伺服器
 * 
 * @author Auser
 * 
 */
public class Server {
    public static void main(String[] args) throws IOException,
            InterruptedException {
        List<Socket> list = new ArrayList<>();

        // 創建伺服器端的套接字
        ServerSocket server = new ServerSocket(10000);

        while (true) {
            // 接收客戶端的阻塞方法
            Socket socket = server.accept();
            // 設計到多個線程可能會對集合進行增刪的操作，要進行同步的處理
            synchronized (list) {
                list.add(socket);
            }
            // 啟動一個新的線程去處理這個客戶端的交流
            new HandleSocket(socket, list).start();
        }
　　　　 // 因為不知道客戶端什麼時候發送信息，所以服務端要一直開啟不能關閉。
    }
}

--> HandleSocket 類對連接到服務端的客戶端進行操作(上下線通知、屏蔽拉黑、將信息發送到每個客戶端等...)

package com.dragon.java.tcpchat;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.Socket;
import java.util.List;

/**
 * 處理每個(單個)連接到伺服器的客戶端的線程
 * 
 * @author Auser
 * 
 */
public class HandleSocket extends Thread {

    private Socket socket;
    private List<Socket> list;

    /**
     * 構造方法
     * 
     * @param socket
     *            當前連接的客戶端
     * @param list
     *            存儲已連接客戶端的集合
     */
    public HandleSocket(Socket socket, List<Socket> list) {
        this.socket = socket;
        this.list = list;
    }

    /**
     * 線程run方法
     */
    @Override
    public void run() {
        InetAddress address = socket.getInetAddress(); // 獲取連接到伺服器的這的客戶端的地址
        String ip = address.getHostAddress();
        System.out.println(ip + "上線了！");
        if (ip.equals("192.168.1.117")) {
            synchronized (list) {
                sendToAll(ip + "由於違規操作，已被拉入黑名單！");
                list.remove(socket);
            }
            return;
        }

        try {
            BufferedReader br = new BufferedReader(new InputStreamReader(
                    socket.getInputStream(), "gbk"));

            String line = "";
            while ((line = br.readLine()) != null) {
                String msg = ip + ":" + line;
                System.out.println(msg); // 輸出到伺服器端的控制台
                // 把這個客戶端說的話，發給其他所有的客戶端
                sendToAll(msg);
            }

        } catch (IOException e) {
            // e.printStackTrace();
            System.out.println(ip + "下線了！");
            synchronized (list) {
                list.remove(socket);
            }
        }
    }

    /**
     * 把信息發送給所有的客戶端，去除當前socket
     * 
     * @param msg
     *            發送的信息
     */
    private void sendToAll(String msg) {
        synchronized (list) {
            for (Socket s : list) {
                if (s != socket) {
                    try {
                        PrintStream ps = new PrintStream(s.getOutputStream());
                        ps.println();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }

}

--> 註意：因為要實現客戶端連接到服務端，即客戶端要先找到服務端，所以服務端要先開啟，再開啟服務端...

--> 這是一個弱小的區域網群聊功能...