博主介紹：?java資深開發(fā)工程師、Java領(lǐng)域優(yōu)質(zhì)創(chuàng)作者,博客之星、專注于Java技術(shù)領(lǐng)域和學(xué)生畢業(yè)項(xiàng)目實(shí)戰(zhàn)，面試講解跟進(jìn)，高校老師/講師/同行交流合作?

胡廣愿景：

"比特星球"，致力于幫助底層人員找到工作，讓每個(gè)底層人員都能找到屬于自己的星球。

拓展學(xué)習(xí)領(lǐng)域，獲取社會(huì)知識(shí)，讓你更好地面對(duì)職業(yè)挑戰(zhàn)。與此同時(shí)，我們將實(shí)時(shí)關(guān)注社會(huì)熱點(diǎn)，分享最新科技動(dòng)態(tài)，激勵(lì)你不斷進(jìn)步。加入比特星球，共同構(gòu)建一個(gè)互助的學(xué)習(xí)社區(qū)。

???? 感興趣的可以先收藏起來???? 不然下次找不到喲

大家在畢設(shè)選題，項(xiàng)目以及論文編寫、就業(yè)面試等相關(guān)問題都可以給我留言咨詢，希望幫助更多的人

??文末獲取源碼聯(lián)系??

??文末獲取源碼聯(lián)系??

??文末獲取源碼聯(lián)系??

?大家好，我叫胡廣，廢話不多說咱們直接進(jìn)入正題?。?！

socket科普

參考《Socket通信原理》https://www.cnblogs.com/wangcq/p/3520400.html

整體流程圖

我們制作的這個(gè)實(shí)時(shí)在線聊天系統(tǒng)分為客戶端、服務(wù)端，

兩個(gè)步驟：

1、連接注冊(cè)

客戶端往服務(wù)端發(fā)起注冊(cè)請(qǐng)求，服務(wù)端將客戶端的地址、端口存入HashSet在內(nèi)存中緩存起來

2、消息處理(聊天功能)

客戶端發(fā)送消息至服務(wù)端，服務(wù)端處理消息格式私密消息格式為 @targetUser(私密用戶名) 消息內(nèi)容。如果不為此格式那么就向除自己以外的用戶都發(fā)送消息

整個(gè)的實(shí)現(xiàn)原理用一張圖即可解釋

相比你看到了此文章這里，基本有個(gè)大概的了解了吧

接下來就到了你最期待的時(shí)候了，沒錯(cuò)就是實(shí)現(xiàn)代碼，哈哈哈，我不知道有多少人是為了代碼過來的，可否給我點(diǎn)個(gè)免費(fèi)的小贊和收藏呢，胡廣拜謝了。

如果你也是底層程序員正在水生活熱的生活中迷茫，感到就業(yè)困難，面試少，可以到此文章末尾的公眾號(hào)聯(lián)系到我哦，我?guī)湍阋黄鹂朔矍暗睦щy。《同是天涯淪落人，相逢何必曾相識(shí)》

實(shí)現(xiàn)代碼

客戶端代碼

1.這里使用 Socket 類創(chuàng)建一個(gè)與指定服務(wù)器地址和端口的socket連接

2.通過 BufferedReader 和 PrintWriter 分別設(shè)置輸入和輸出流。reader 用于讀取服務(wù)器的消息，writer 用于向服務(wù)器發(fā)送消息。consoleReader 用于讀取用戶在控制臺(tái)輸入的消息

3.使用一個(gè)線程來不斷地從服務(wù)器接收消息，并將其顯示在客戶端的控制臺(tái)上。

4.在主線程中，用戶可以輸入消息，程序?qū)⑵浒l(fā)送到服務(wù)器。如果用戶輸入 "exit"，則退出循環(huán)，關(guān)閉連接

5.異常處理部分用于捕捉可能發(fā)生的 IOException 異常，并打印異常信息。

package org.sqs.socketchat.client;

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

/**
 * 通信客戶端ds
 */
public class ChatClient {
    public static void main(String[] args) {


        String serverHost = "127.0.0.1";
        int serverPort = 8080;

        try (Socket socket = new Socket(serverHost, serverPort);
             //字符流讀取
             BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
             //輸出字符流
             PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);
             //讀取控制臺(tái)么
             BufferedReader consoleReader = new BufferedReader(new InputStreamReader(System.in))) {

            // 啟動(dòng)接收消息線程
            new Thread(() -> {
                try {
                    while (true) {
                        String message = reader.readLine();
                        if (message == null) {
                            break;
                        }
                        System.out.println(message);
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }).start();

            // 發(fā)送用戶輸入的消息
            while (true) {
                String userInput = consoleReader.readLine();
                //退出鏈接
                if (userInput.equals("exit")) {
                    break;
                }
                //往服務(wù)端輸出消息
                writer.println(userInput);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

服務(wù)端代碼

消息處理器

1.當(dāng)客戶端發(fā)送消息時(shí)，服務(wù)端會(huì)檢查消息是否以 "@" 開頭，如果是，則認(rèn)為是私密消息。私密消息格式為 @targetUser message。如果消息格式正確，服務(wù)端會(huì)將私密消息發(fā)送給目標(biāo)用戶，否則會(huì)通知發(fā)送者用戶不存在。廣播消息給所有用戶的方法和之前相同。這只是一個(gè)簡(jiǎn)單的實(shí)現(xiàn)，實(shí)際場(chǎng)景中可能需要更復(fù)雜的邏輯和安全性保障。

package org.sqs.socketchat.server;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Set;

/**
 * 消息處理
 */
public class ChatHandler implements Runnable{
    //socket客戶端
    private Socket clientSocket;
    //客戶端集
    private Set<ChatHandler> handlers;
    //緩沖輸入字符流
    private BufferedReader reader;
    //輸出字符流
    private PrintWriter writer;
    //添加用戶名字段
    private String username;

    /**
     * 消息處理
     * @param socket
     * @param handlers
     */
    public ChatHandler(Socket socket, Set<ChatHandler> handlers) {
        this.clientSocket = socket;
        this.handlers = handlers;

        try {
            //輸入流與輸出流
            reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            writer = new PrintWriter(socket.getOutputStream(), true);
            // 為每個(gè)客戶端生成一個(gè)唯一的用戶名（可根據(jù)實(shí)際需求修改）這里用的是當(dāng)前時(shí)間,小伙伴可以用UUID來代替都行
            this.username = "User" + System.currentTimeMillis();
            sendMessage("您的客戶端連接名為 " + username);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 獲取用戶名
    public String getUsername() {
        return username;
    }

    /**
     * 開啟消息處理
     */
    @Override
    public void run() {
        try {
            while (true) {
                //讀取消息
                String message = reader.readLine();
                //消息非空校驗(yàn)
                if (message == null) {
                    break;
                }

                // 解析私密消息格式（示例：@targetUser message）
                if (message.startsWith("@")) {
                    String[] parts = message.split(" ", 2);
                    if (parts.length == 2) {
                        ChatServer.sendPrivateMessage(parts[1], parts[0].substring(1), this);
                        continue;
                    }
                }

                // 廣播消息給所有客戶端
                ChatServer.broadcast(username + ": " + message, this);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            // 異常之后移除處理器
            handlers.remove(this);
            try {
                clientSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public void sendMessage(String message) {
        writer.println(message);
    }
}

服務(wù)端的端口監(jiān)聽

1.監(jiān)聽客戶端連接端口8080

2.將客戶端信息存入內(nèi)存緩存處理

3.提供群聊廣播消息、私密消息功能

package org.sqs.socketchat.server;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashSet;
import java.util.Set;

/**
 * 通信服務(wù)端
 */
public class ChatServer {
    //定義端口號(hào)
    private static final int PORT = 8080;
    //定義聊天處理器,將每個(gè)客戶端存入處理,用Set不會(huì)重復(fù)
    private static Set<ChatHandler> handlers = new HashSet<>();

    public static void main(String[] args) {
        //監(jiān)聽端口號(hào)
        try (ServerSocket serverSocket = new ServerSocket(PORT)) {
            System.out.println("聊天服務(wù)端正在此端口上運(yùn)行：" + PORT);

            //開始循環(huán)監(jiān)聽
            while (true) {
                //1.服務(wù)器調(diào)用 serverSocket.accept() 方法：該方法會(huì)一直阻塞，直到有客戶端請(qǐng)求連接到服務(wù)器。
                //2.客戶端發(fā)起連接請(qǐng)求： 當(dāng)有客戶端發(fā)起連接請(qǐng)求時(shí)，serverSocket.accept() 會(huì)返回一個(gè)新的 Socket 對(duì)象，該對(duì)象代表與客戶端建立的連接。
                //3.創(chuàng)建新的 Socket 對(duì)象： 服務(wù)器通過 serverSocket.accept() 創(chuàng)建一個(gè)新的 Socket 對(duì)象，該對(duì)象包含了客戶端的信息，包括客戶端的地址和端口等。
                //4.處理客戶端連接： 服務(wù)器可以使用返回的 Socket 對(duì)象與客戶端進(jìn)行通信，發(fā)送和接收數(shù)據(jù)
                Socket clientSocket = serverSocket.accept();
                System.out.println("新的客戶端已連接 " + clientSocket);

                //將此socket客戶端連接存入Set當(dāng)中
                ChatHandler handler = new ChatHandler(clientSocket, handlers);
                handlers.add(handler);

                //創(chuàng)一個(gè)新線程來處理此客戶端的消息。建議：新線程可以用線程池來管理,固定1線程的線程池或者調(diào)整線程池策略
                Thread handlerThread = new Thread(handler);
                handlerThread.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // Broadcast消息給所有客戶端。廣播
    public static void broadcast(String message, ChatHandler sender) {
        for (ChatHandler handler : handlers) {
            // 避免將消息發(fā)回給發(fā)送者
            if (handler != sender) {
                handler.sendMessage(message);
            }
        }
    }

    // 發(fā)送私密消息給指定客戶端
    public static void sendPrivateMessage(String message, String targetClient, ChatHandler sender) {
        for (ChatHandler handler : handlers) {
            // 找到目標(biāo)客戶端并發(fā)送私密消息
            if (handler.getUsername().equals(targetClient)) {
                handler.sendMessage(sender.getUsername() + " (私密): " + message);
                return;
            }
        }

        // 如果目標(biāo)客戶端不存在，通知發(fā)送者
        sender.sendMessage("用戶 '" + targetClient + "' 找不到.");
    }
}

以上就是所有的代碼咯，當(dāng)然還有標(biāo)題中提到的心跳以及超時(shí)的機(jī)制解決方案，以下代碼可供大家參考

心跳機(jī)制代碼

弄一個(gè)Timer定時(shí)器，定時(shí)的向服務(wù)端發(fā)送消息來保持socket連接的活躍性

    /**
     * 往上機(jī)系統(tǒng)發(fā)送指令，接收響應(yīng)
     *
     * @param message
     */
    public void sendMessage(String message) {
        try {
            log.info(message);
            if(null != out){
                out.println(message);
            }else{
                log.error("發(fā)送消息失敗!!! Socket out 為null,請(qǐng)檢查連接是否成功");
            }
            String response;
            if(null != in){
                response = in.readLine();
                log.info(response);
            }else{
                log.error("發(fā)送消息失敗!!! Socket in 為null,請(qǐng)檢查連接是否成功");
            }
        } catch (IOException e) {
                e.printStackTrace();
        } finally {
            try {
                closeConnection();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 定時(shí)心跳
     *
     * @param intervalSeconds
     */
    private void startHeartbeatTimer(int intervalSeconds) {
        Timer timer = new Timer();
        timer.scheduleAtFixedRate(new TimerTask() {
            @Override
            public void run() {
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                sendMessage("客戶端：我的心跳信息，俺還活著哦！\t" + sdf.format(new Date()));
            }
        }, 0, intervalSeconds * 1000L);
    }

超時(shí)機(jī)制代碼

連接socket服務(wù)端時(shí)，捕獲一個(gè)超時(shí)的異常就行

        try {
            socket = new Socket(serverHost, serverPort);
            //讀寫操作的超時(shí)時(shí)間
            socket.setSoTimeout(timeout);
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()), true);
        } catch (IOException e) {
            // 捕獲連接超時(shí)異常
            if (e instanceof ConnectException) {
                log.error("初始化連接失敗,請(qǐng)檢查server的活躍性!!!");
            } else {
                // 處理其他異常
                e.printStackTrace();
            }
        } finally {
            try {
                closeConnection();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

效果圖展示

?客戶端1效果圖：

?客戶端2效果圖：

客戶端3效果圖：

服務(wù)端效果圖：

?源碼+項(xiàng)目部署

數(shù)據(jù)庫還有源碼一起都打包再下邊的地址里了，下載開箱即用，跟springboot一樣，嘻嘻嘻！

嗯嗯嗯......終于到了激動(dòng)人心的時(shí)候了，我來幫你搞定一切各種面試，技術(shù)問題，畢業(yè)設(shè)計(jì)，帝王般的服務(wù)你值得擁有，免費(fèi)的喲。

各類源碼掃描搜索公眾號(hào)《與胡廣一起探索比特星球》發(fā)送任何消息免費(fèi)獲取

各類源碼掃描搜索公眾號(hào)《與胡廣一起探索比特星球》發(fā)送任何消息免費(fèi)獲取

各類源碼掃描搜索公眾號(hào)《與胡廣一起探索比特星球》發(fā)送任何消息免費(fèi)獲取

最后附上

一寸光陰一寸金，寸金難買寸光陰。請(qǐng)珍惜現(xiàn)在美好的青春，咱們一起努力奮斗，創(chuàng)造美好未來

拜托拜托！??！拜托拜托！??！拜托拜托?。?！

BIT PLANET?文章來源地址http://www.zghlxwxcb.cn/news/detail-826867.html

到了這里，關(guān)于基于Springboot整合Socket仿微信實(shí)現(xiàn)群聊、私聊功能。實(shí)現(xiàn)客戶端client,服務(wù)端server心跳維護(hù)、超時(shí)機(jī)制【一文通】的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！