摘要：前言大家可以看看上一篇用構(gòu)建一個簡單的聊天室在上一篇文章中我們已經(jīng)實現(xiàn)了自我對話好友交流群聊離線消息等的功能。系統(tǒng)通知恭喜您連續(xù)登錄超過天，獎勵積分。

本文首發(fā)公眾號與個人博客：Java貓說 & 貓叔的博客 | MySelf，轉(zhuǎn)載請申明出處。

大家可以看看上一篇：用Java構(gòu)建一個簡單的WebSocket聊天室

在上一篇文章中我們已經(jīng)實現(xiàn)了：自我對話、好友交流、群聊、離線消息等的功能。

而本篇，我們的框架升級了，并且開通了幾個新的HTTP接口功能，同時也把原先框架的一些異常做了處理。

我們將使用更少的代碼完成功能更加完善的聊天項目！

我們整個Demo基本不需要大家花費太多時間，就可以實現(xiàn)以下的功能。

用戶token登錄校驗
自我聊天
點對點聊天
群聊
獲取在線用戶數(shù)與用戶標簽列表
發(fā)送系統(tǒng)通知

首先，我們需要介紹一下我們今天打算采用的框架，InChat : 一個輕量級、高效率的支持多端（應用與硬件Iot）的異步網(wǎng)絡應用通訊框架，采用這個框架，我們基本上只需要兩三個類就可以實現(xiàn)我們今天需要的功能了。

InChat ，本身不依賴于任何的底層框架，所以大家只要會基本的Java語言就可以實現(xiàn)一套自己的WebSocket聊天室。

關(guān)于詳細的手冊說明，大家可以看看官網(wǎng)的介紹：

V1.1.2版本使用說明

V1.1.2版本視頻教學

    com.github.UncleCatMySelf
    InChat
    1.1.2

我們不需要依賴其他的Maven包，只要本文提及的框架即可。

    com.github.UncleCatMySelf
    InChat
    1.1.2

你只需要繼承InChat的默認配置類InitNetty即可，如下

public class MyInit extends InitNetty {
    /** 自定義啟動監(jiān)聽端口 */
    @Override
    public int getWebport() {
        return 8090;
    }
}

此接口與原先一樣，僅修改了方法名

public class DataBaseServiceImpl implements InChatToDataBaseService {

    @Override
    public Boolean writeMessage(InChatMessage message) {
        System.out.println(message.toString());
        return true;
    }
}

此接口沒有做過多的修改

public class VerifyServiceImpl implements InChatVerifyService {

    @Override
    public boolean verifyToken(String token) {
        return true;
    }

    @Override
    public JSONArray getArrayByGroupId(String groupId) {
        JSONArray jsonArray = JSONArray.parseArray("["1111","2222","3333"]");
        return jsonArray;
    }
}

此接口具有Demo模板，用戶需要繼承InChat框架的FromServerService接口，同時該接口注釋也有實例demo，我們需要實現(xiàn)一個自定義的枚舉，你可以這樣寫：

public enum  FromServerServiceImpl implements FromServerService {

    //你可以自定義自己的系統(tǒng)消息，請以Integer-String的形式
    TYPE1(1,"【系統(tǒng)通知】您的賬號存在異常，請注意安全保密信息。"),
    TYPE2(2,"【系統(tǒng)通知】恭喜您連續(xù)登錄超過5天，獎勵5積分。");

    private Integer code;

    private String message;

    FromServerServiceImpl(Integer code, String message){
        this.code = code;
        this.message = message;
    }

    public Integer getCode() {
        return code;
    }

    //實現(xiàn)接口的方法，遍歷本枚舉的code，獲取對應的消息，作為系統(tǒng)消息發(fā)送
    public String findByCode(Object code) {
        Integer codes = (Integer)code;
        for (FromServerServiceImpl item: FromServerServiceImpl.values()) {
            if (item.code == codes){
                return item.message;
            }
        }
        return null;
    }

    public void setCode(Integer code) {
        this.code = code;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }


}

1.1.2版本的啟動項目變得異常的簡單，你只需要配置啟動的配置工廠即可。

public class application {

    public static void main(String[] args) {
        //配置你的自定義配置
        ConfigFactory.initNetty = new MyInit();
        //配置校驗類
        ConfigFactory.inChatVerifyService = new VerifyServiceImpl();
        //配置消息接收處理類
        ConfigFactory.inChatToDataBaseService = new DataBaseServiceImpl();
        //配置服務端系統(tǒng)消息枚舉，這里的值無所謂 TYPE1或者TYPE2或者TYPEN均可以
        ConfigFactory.fromServerService = FromServerServiceImpl.TYPE1;
        //啟動InChat
        InitServer.open();
    }

}

啟動成功

DEBUG - -Dio.netty.threadLocalDirectBufferSize: 0
DEBUG - -Dio.netty.maxThreadLocalCharBufferSize: 16384
 INFO - 服務端啟動成功【192.168.56.1:8090】

當聊天連接未注冊情況下，客戶端自動斷開后，服務會自動包對應的異常

 INFO - [Handler：channelInactive]/192.168.56.1:8090關(guān)閉成功
ERROR - [捕獲異常：NotFindLoginChannlException]-[Handler：channelInactive] 關(guān)閉未正常注冊鏈接！

原先的自我發(fā)送,點對點發(fā)送,群聊均與原來一樣
原先的接口說明可以看上一版本： v1.1.0-alpha版本使用說明

新增HTTP接口三個，在你啟動Inchat的時候，默認啟動，對于你的其他web API并無任何影響，它是一個IM的輔助作用。本版本不支持用戶自定義相關(guān)的InChat HTTP接口

獲取在線用戶數(shù)

地址：[ip：端口]/get_size GET

返回值

{
    "code": 200,
    "data": {
        "online": 1,//當前在線數(shù)
        "time": "Jan 3, 2019 10:06:45 PM"http://查詢時間
    }
}

獲取在線用戶標識

地址：[ip:端口]/get_list GET

返回值

{
    "code": 200,
    "data": {
        //返回在線用戶列表
        "tokens": [ 
            "1111"
        ]
    }
}

根據(jù)用戶標簽，發(fā)送系統(tǒng)指定消息

地址：[ip:端口]/send_from_server POST

參數(shù)：token(你可以從get_list中得到在線用戶標簽)、value(你在系統(tǒng)中添加枚舉的code值，這里不接受字符串)

返回值

{
    "code": 400,
    "data": {
        "message": "通知發(fā)送成功"
    }
}

(有個小BUG，返回值code應該是200)

InChat : 一個輕量級、高效率的支持多端（應用與硬件Iot）的異步網(wǎng)絡應用通訊框架，大家可以直接來這個項目下獲取前端頁面，或者直接訪問這個地址：https://github.com/UncleCatMy...

對于這個前端頁面，我們需要更改一下IP地址。

接下來直接啟動后端項目，當我們看到以下的信息，則項目啟動成功。

 INFO - 服務端啟動成功【192.168.1.121:8090】

這里的IP需要更換以下讀者啟動后的IP地址。

接著直接用瀏覽器打開chat.html的頁面即可，關(guān)于js的方法，大家可以看看InChatV1.1.0版本使用說明。

運行效果已經(jīng)提前展示啦！

現(xiàn)架構(gòu)設計（碼農(nóng)）兼創(chuàng)業(yè)技術(shù)顧問，不羈平庸，熱愛開源，雜談程序人生與不定期干貨。