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

本文首發(fā)公眾號(hào)與個(gè)人博客：Java貓說(shuō) & 貓叔的博客 | MySelf，轉(zhuǎn)載請(qǐng)申明出處。

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

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

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

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

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

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

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

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

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

V1.1.2版本使用說(shuō)明

V1.1.2版本視頻教學(xué)

    com.github.UncleCatMySelf
    InChat
    1.1.2

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

    com.github.UncleCatMySelf
    InChat
    1.1.2

你只需要繼承InChat的默認(rèn)配置類InitNetty即可，如下

public class MyInit extends InitNetty {
    /** 自定義啟動(dòng)監(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;
    }
}

此接口沒(méi)有做過(guò)多的修改

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接口，同時(shí)該接口注釋也有實(shí)例demo，我們需要實(shí)現(xiàn)一個(gè)自定義的枚舉，你可以這樣寫：

public enum  FromServerServiceImpl implements FromServerService {

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

    private Integer code;

    private String message;

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

    public Integer getCode() {
        return code;
    }

    //實(shí)現(xiàn)接口的方法，遍歷本枚舉的code，獲取對(duì)應(yīng)的消息，作為系統(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版本的啟動(dòng)項(xiàng)目變得異常的簡(jiǎn)單，你只需要配置啟動(dòng)的配置工廠即可。

public class application {

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

}

啟動(dòng)成功

DEBUG - -Dio.netty.threadLocalDirectBufferSize: 0
DEBUG - -Dio.netty.maxThreadLocalCharBufferSize: 16384
 INFO - 服務(wù)端啟動(dòng)成功【192.168.56.1:8090】

當(dāng)聊天連接未注冊(cè)情況下，客戶端自動(dòng)斷開后，服務(wù)會(huì)自動(dòng)包對(duì)應(yīng)的異常

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

原先的自我發(fā)送,點(diǎn)對(duì)點(diǎn)發(fā)送,群聊均與原來(lái)一樣
原先的接口說(shuō)明可以看上一版本： v1.1.0-alpha版本使用說(shuō)明

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

獲取在線用戶數(shù)

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

返回值

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

獲取在線用戶標(biāo)識(shí)

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

返回值

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

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

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

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

返回值

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

(有個(gè)小BUG，返回值code應(yīng)該是200)

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

對(duì)于這個(gè)前端頁(yè)面，我們需要更改一下IP地址。

接下來(lái)直接啟動(dòng)后端項(xiàng)目，當(dāng)我們看到以下的信息，則項(xiàng)目啟動(dòng)成功。

 INFO - 服務(wù)端啟動(dòng)成功【192.168.1.121:8090】

這里的IP需要更換以下讀者啟動(dòng)后的IP地址。

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

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

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