0. 前言

決定以Netty為核心，以WebSocket為應(yīng)用層通信協(xié)議做一個(gè)互聯(lián)網(wǎng)聊天系統(tǒng)，整體而言就像微信網(wǎng)頁(yè)版一樣，但考慮到這個(gè)聊天系統(tǒng)的功能非常多，因此只打算實(shí)現(xiàn)核心的聊天功能，包括單發(fā)、群發(fā)、文件發(fā)送，然后把項(xiàng)目與Spring整合做成開(kāi)源、可拓展的方式，給大家參考、討論、使用，歡迎大家的指點(diǎn)。

關(guān)于Netty

Netty 是一個(gè)利用 Java 的高級(jí)網(wǎng)絡(luò)的能力，隱藏其背后的復(fù)雜性而提供一個(gè)易于使用的 API 的客戶端/服務(wù)器框架。

關(guān)于WebSocket通信協(xié)議

WebSocket是為了解決HTTP協(xié)議中通信只能由客戶端發(fā)起這個(gè)弊端而出現(xiàn)的，WebSocket基于HTTP5協(xié)議，借用HTTP進(jìn)行握手、升級(jí)，能夠做到輕量的、高效的、雙向的在客戶端和服務(wù)端之間傳輸文本數(shù)據(jù)。

1、技術(shù)準(zhǔn)備

IDE：MyEclipse 2016

JDK版本：1.8.0_121

瀏覽器：谷歌瀏覽器、360瀏覽器（極速模式）（涉及網(wǎng)頁(yè)前端設(shè)計(jì)，后端開(kāi)發(fā)表示很苦悶）

涉及技術(shù)：

• Netty 4
• WebSocket + HTTP
• Spring MVC + Spring
• JQuery
• Bootstrap 3 + Bootstrap-fileinput
• Maven 3.5
• Tomcat 8.0

2. 整體說(shuō)明

2.1 設(shè)計(jì)思想

整個(gè)通信系統(tǒng)以Tomcat作為核心服務(wù)器運(yùn)行，其下另開(kāi)一個(gè)線程運(yùn)行Netty WebSocket服務(wù)器，Tomcat服務(wù)器主要處理客戶登錄、個(gè)人信息管理等的HTTP類型請(qǐng)求（通常的業(yè)務(wù)類型），端口為8080，Netty WebSockt服務(wù)器主要處理用戶消息通信的WebSocket類型請(qǐng)求，端口為3333。用戶通過(guò)瀏覽器登錄后，瀏覽器會(huì)維持一個(gè)Session對(duì)象（有效時(shí)間30分鐘）來(lái)保持登錄狀態(tài)，Tomcat服務(wù)器會(huì)返回用戶的個(gè)人信息，同時(shí)記錄在線用戶，根據(jù)用戶id建立一條WebSocket連接并保存在后端以便進(jìn)行實(shí)時(shí)通信。當(dāng)一個(gè)用戶向另一用戶發(fā)起通信，服務(wù)器會(huì)根據(jù)消息內(nèi)容中的對(duì)話方用戶id，找到保存的WebSocket連接，通過(guò)該連接發(fā)送消息，對(duì)方就能夠收到即時(shí)收到消息。當(dāng)用戶注銷或退出時(shí)，釋放WebSocket連接，清空Session對(duì)象中的登錄狀態(tài)。（插播一條廣告：需要開(kāi)通正版IDEA的可以聯(lián)系我，56元一年，正版授權(quán)激活，官網(wǎng)可查有效期，有需要的加我微信：poxiaozhiai6，備注：914。）

事實(shí)上Netty也可以用作一個(gè)HTTP服務(wù)器，而這里使用Spring MVC處理HTTP請(qǐng)求是出于熟悉的緣故，也比較接近傳統(tǒng)開(kāi)發(fā)的方式。

2.2 系統(tǒng)結(jié)構(gòu)

系統(tǒng)采用B/S（Browser/Server），即瀏覽器/服務(wù)器的結(jié)構(gòu)，主要事務(wù)邏輯在服務(wù)器端（Server）實(shí)現(xiàn)。借鑒MVC模式的思想，從上至下具體又分為視圖層（View）、控制層（Controller）、業(yè)務(wù)層（Service）、模型層（Model）、數(shù)據(jù)訪問(wèn)層（Data Access）

2.3 項(xiàng)目結(jié)構(gòu)

項(xiàng)目后端結(jié)構(gòu)：

項(xiàng)目前端結(jié)構(gòu)：

2.4 系統(tǒng)功能模塊

系統(tǒng)只包括兩個(gè)模塊：登錄模塊和聊天管理模塊。

• 登錄模塊：既然作為一個(gè)系統(tǒng)，那么登錄的角色認(rèn)證是必不可少的，這里使用簡(jiǎn)單、傳統(tǒng)的Session方式維持登錄狀態(tài)，當(dāng)然也有對(duì)應(yīng)的注銷功能，但這里的注銷除了清空Session對(duì)象，還要釋放WebSocket連接，否則造成內(nèi)存泄露。
• 聊天管理模塊：系統(tǒng)的核心模塊，這部分主要使用Netty框架實(shí)現(xiàn)，功能包括信息、文件的單條和多條發(fā)送，也支持表情發(fā)送。
• 其他模塊：如好友管理模塊、聊天記錄管理、注冊(cè)模塊等，我并沒(méi)有實(shí)現(xiàn)，有興趣的話可以自行實(shí)現(xiàn)，與傳統(tǒng)的開(kāi)發(fā)方式類似。

由于本系統(tǒng)涉及多個(gè)用戶狀態(tài)，有必要進(jìn)行說(shuō)明，下面給出本系統(tǒng)的用戶狀態(tài)轉(zhuǎn)換圖。

2.5 系統(tǒng)界面

系統(tǒng)聊天界面如下：

3. 核心編碼

這里只說(shuō)明需要注意的地方，詳細(xì)的請(qǐng)看源碼

3.1 Netty服務(wù)器啟動(dòng)與關(guān)閉

當(dāng)關(guān)閉Tomcat服務(wù)器時(shí)，也要釋放Netty相關(guān)資源，否則會(huì)造成內(nèi)存泄漏，關(guān)閉方法如下面的close()，如果只是使用shutdownGracefully()方法的話，關(guān)閉時(shí)會(huì)報(bào)內(nèi)存泄露Memory Leak異常（但I(xiàn)DE可能來(lái)不及輸出到控制臺(tái)）

/**
 * 描述: Netty WebSocket服務(wù)器
 *      使用獨(dú)立的線程啟動(dòng)
 * @author Kanarien
 * @version 1.0
 * @date 2018年5月18日 上午11:22:51
 */
public class WebSocketServer implements Runnable{
 
        /**
  * 描述：?jiǎn)?dòng)Netty Websocket服務(wù)器
  */
 public void build() {
     // 略，詳細(xì)請(qǐng)看源碼
 }
     
      /**
  * 描述：關(guān)閉Netty Websocket服務(wù)器，主要是釋放連接
  *     連接包括：服務(wù)器連接serverChannel，
  *     客戶端TCP處理連接bossGroup，
  *     客戶端I/O操作連接workerGroup
  *
  *     若只使用
  *         bossGroupFuture = bossGroup.shutdownGracefully();
  *         workerGroupFuture = workerGroup.shutdownGracefully();
  *     會(huì)造成內(nèi)存泄漏。
  */
 public void close(){
     serverChannelFuture.channel().close();
  Future<?> bossGroupFuture = bossGroup.shutdownGracefully();
        Future<?> workerGroupFuture = workerGroup.shutdownGracefully();
 
        try {
            bossGroupFuture.await();
            workerGroupFuture.await();
        } catch (InterruptedException ignore) {
            ignore.printStackTrace();
        }
 }
 
}

4. 效果及操作演示

4.1 登錄操作

登錄入口為：http://localhost:8080/WebSocket/login 或 http://localhost:8080/WebSocket/ 當(dāng)前系統(tǒng)用戶固定為9個(gè)，群組1個(gè)，包括9人用戶。

• 用戶1 用戶名：Member001 密碼：001
• 用戶2 用戶名：Member002 密碼：002
• ······
• 用戶9 用戶名：Member009 密碼：009

4.2 聊天演示

5. 源碼下載

下載鏈接: https://pan.baidu.com/s/1JuXRqWH0HFN0ruMm-BnysA

提取碼: e9ej

以上就是基于Java實(shí)現(xiàn)互聯(lián)網(wǎng)實(shí)時(shí)聊天系統(tǒng)(附源碼)的詳細(xì)內(nèi)容，更多關(guān)于Java實(shí)時(shí)聊天系統(tǒng)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論