摘要：基本消息對象的設(shè)計消息對象的設(shè)計主要由兩部分組成特定數(shù)據(jù)幀對應(yīng)的特定消息對象。該類包含上節(jié)數(shù)據(jù)幀主幀及子幀的所有公共信息，僅僅未包含子幀中的數(shù)據(jù)體信息，該需求由基本消息對象的子類實現(xiàn)。

開發(fā)工程中，有一個常見的需求：服務(wù)端程序和多個客戶端程序通過 TCP 協(xié)議進行通信，通信雙方需通信的消息種類眾多，并且客戶端的數(shù)量可能有數(shù)萬個。為此，雙方需要約定盡可能豐富、靈活的數(shù)據(jù)幀「數(shù)據(jù)包」協(xié)議，方便后續(xù)業(yè)務(wù)功能的設(shè)計。

本文設(shè)計了一種通信協(xié)議，為壓縮數(shù)據(jù)量，該協(xié)議的數(shù)據(jù)幀以二進制方式進行傳輸并識別，即其基本單位為字節(jié)，必要時將部分字節(jié)流手動轉(zhuǎn)化為可讀文本。通過設(shè)定功能位來實現(xiàn)豐富的通信消息類型，并且采用注冊的方式，可方便擴展新的業(yè)務(wù)消息類型，可靈活地增刪通信消息對象。采用 Netty 框架保證高并發(fā)場景下程序的性能。

系統(tǒng)整體設(shè)計框圖如下：

首先給出通用的數(shù)據(jù)幀格式如下，一個數(shù)據(jù)幀主幀由：幀識別位、幀功能位、設(shè)備號、數(shù)據(jù)長度、數(shù)據(jù)體等 5 部分組成?！钙鋵嵶钔ㄓ玫臄?shù)據(jù)幀只有幀識別位，根據(jù)幀識別位確定幀類型，從而確定其余四個部分，本文中幀識別位固定，幀格式即固定了」

幀識別位：確定數(shù)據(jù)幀的開始，亦確定本幀的幀類型。

幀功能位：確定該幀所傳送的消息類型，特定的幀功能位對應(yīng)特定的數(shù)據(jù)體。

設(shè)備號：設(shè)備的識別號，服務(wù)端據(jù)此識別不同的客戶端。

數(shù)據(jù)長度：數(shù)據(jù)體所占用的字節(jié)數(shù)。

數(shù)據(jù)體：根據(jù)幀功能位，所確定的需傳輸?shù)木唧w的消息。

數(shù)據(jù)幀除數(shù)據(jù)體以外的部分稱為幀頭，考慮這樣一種需求，如果某幀所要傳輸?shù)臄?shù)據(jù)體部分內(nèi)容很少，導(dǎo)致一個幀的大部分容量均被幀頭占據(jù)，導(dǎo)致有效數(shù)據(jù)的占比很小，這就產(chǎn)生了巨大的浪費，舉例如下：

如一個開鎖幀，只需傳輸一個開鎖信號即可，消息的接收方、消息類型均體現(xiàn)在了幀頭中，數(shù)據(jù)部分只需要 0 個或 1 個字節(jié)即可。

客戶端需要向服務(wù)器發(fā)送自己的當(dāng)前狀態(tài)信息，該狀態(tài)信息可能也只需要 1 個字節(jié)左右。

由于如上實際的需求，如果增大了每一幀的有效數(shù)據(jù)的占比，整個通信鏈路的數(shù)據(jù)量會明顯減少，IO 負(fù)擔(dān)也會因此減輕，所以據(jù)此繼續(xù)對幀協(xié)議進行設(shè)計。

如上圖，對數(shù)據(jù)幀主幀中的「數(shù)據(jù)體」部分進行進一步拆分，數(shù)據(jù)幀主幀的數(shù)據(jù)體部分由子幀組成，子幀由：子幀功能位、數(shù)據(jù)長度、數(shù)據(jù)體等 3 部分組成。

子幀功能位：確定該子幀所傳送的消息類型，總而言之，主幀、子幀功能位共同確定了該子幀的消息類型。

數(shù)據(jù)長度：數(shù)據(jù)體所占用的字節(jié)數(shù)。

數(shù)據(jù)體：根據(jù)子幀功能位，所確定的需傳輸?shù)木唧w的消息。

完整的幀格式如下圖所示，數(shù)據(jù)幀主幀的數(shù)據(jù)體部分完全由子幀組成，通信雙方通信時，可以往一個主幀中添加多個子幀，從而可以極大提高鏈路的使用效率。

數(shù)據(jù)幀已進行了如上精心設(shè)計，將設(shè)計的數(shù)據(jù)幀通過程序?qū)崿F(xiàn)并投入實際使用才是最終目的。

以服務(wù)端的工作為例來進行說明。服務(wù)端程序監(jiān)聽指定端口，客戶端通過 TCP 協(xié)議向服務(wù)器發(fā)送二進制數(shù)據(jù)消息，服務(wù)端接收到二進制數(shù)據(jù)并進行處理，此處采用責(zé)任鏈模式，Netty 框架內(nèi)建了方便的基于責(zé)任鏈模式的消息處理方法：

第一個處理器將捕獲的數(shù)據(jù)截取為一個一個協(xié)議約定的數(shù)據(jù)幀并送入下層處理器，如果捕獲的二進制數(shù)據(jù)未符合協(xié)議約定的格式，則可以直接丟棄。「此處未考慮半包、粘包等場景」

第二個處理器捕獲到約定的數(shù)據(jù)幀，則著手對不同類型數(shù)據(jù)幀進行解析，解析為不同類型的 Java 消息對象，并將反序列化成功并驗證成功的 Java 對象送入下層處理器。如果上述過程失敗，可以認(rèn)為客戶端設(shè)計不合理，導(dǎo)致出現(xiàn)無效消息，直接丟棄該對象，也可以繼續(xù)通知服務(wù)端或客戶端該異常情況。

第三個處理器捕獲到正確的 Java 消息對象，則可以直接送入上層 Java 模塊進行處理，此處可根據(jù)不同的對象類型送入不同的上層處理模塊，或者在此處進行其他的工作「比如消息日志記錄工作等」。

Java 消息對象的設(shè)計主要由兩部分組成：

特定數(shù)據(jù)幀對應(yīng)的特定 Java 消息對象。

特定 Java 消息對象對應(yīng)的特定的該消息對象編解碼器。

以下是基本 Java 消息對象：

public abstract class BaseMsg implements Cloneable {

    private final BaseMsgCodec msgCodec;
    private int groupId;
    private int deviceId;
    private int resendTimes = 0;

    protected BaseMsg(BaseMsgCodec msgCodec, int groupId, int deviceId) {
        this.msgCodec = msgCodec;
        this.groupId = groupId;
        this.deviceId = deviceId;
    }

    /**
     * 獲取該消息對象的細(xì)節(jié)描述
     *
     * @return 該消息對象的細(xì)節(jié)描述
     */
    public String msgDetailToString() {
        return msgCodec.getDetail() +
                "[majorMsgId=" + Integer.toHexString(msgCodec.getMajorMsgId()).toUpperCase() +
                ", subMsgId=" + Integer.toHexString(msgCodec.getSubMsgId()).toUpperCase() +
                ", groupId=" + groupId +
                ", deviceId=" + deviceId + "]";
    }

    /**
     * 重發(fā)該消息對象的記錄信息更新
     */
    public void doResend() {
        resendTimes++;
    }
}

由上述代碼可知，每個消息對象均包含該對象對應(yīng)編解碼器的引用，方便獲取該消息對象的擴展信息，或者方便將該消息對象重新序列化為數(shù)據(jù)幀。該類包含上節(jié)數(shù)據(jù)幀主幀及子幀的所有公共信息，僅僅未包含子幀中的數(shù)據(jù)體信息，該需求由基本 Java 消息對象的子類實現(xiàn)。

該類由 abstract 修飾，是抽象類，無法直接實例化，具體的工作由該類的子類完成，即由具體的真正業(yè)務(wù)相關(guān)的 Java 消息對象完成。

以下為 Java 消息對象的基本編解碼器：

/**
 * 單個消息對象「幀」的編解碼器
 */
public abstract class BaseMsgCodec implements SubFramecoder, SubFramedecoder {

    private final int majorMsgId;
    private final int subMsgId;
    private final String detail;

    protected BaseMsgCodec(int majorMsgId, int subMsgId, String detail) {
        this.majorMsgId = majorMsgId;
        this.subMsgId = subMsgId;
        this.detail = detail;
    }

    public String getDetail() {
        return detail;
    }

    public int getMajorMsgId() {
        return majorMsgId;
    }

    public int getSubMsgId() {
        return subMsgId;
    }
}

由上述代碼可知，特定 Java 消息對象的編解碼器由數(shù)據(jù)幀的主幀、子幀功能位共同決定，這樣確保了消息編解碼器的規(guī)范，避免消息過多時的混亂。

Java 編解碼器實現(xiàn)了如下兩個接口，表明編解碼器可將 Java 消息對象編碼為數(shù)據(jù)幀，或?qū)?shù)據(jù)幀解碼為指定的 Java 消息對象：

public interface SubFramecoder {
    /**
     * 將 Java 消息對象編碼為數(shù)據(jù)幀
     *
     * @param msg    消息對象
     * @param buffer TCP 數(shù)據(jù)幀的容器
     * @return 生成的 TCP 數(shù)據(jù)幀的 ByteBuf
     */
    ByteBuf code(BaseMsg msg, ByteBuf buffer);
}

public interface SubFramedecoder {
    /**
     * 將數(shù)據(jù)幀解碼為指定的 Java 消息對象
     *
     * @param groupId  設(shè)備組 ID
     * @param deviceId 設(shè)備 ID
     * @param data     幀數(shù)據(jù)
     * @return 特定的 Java 消息對象
     */
    BaseMsg decode(int groupId, int deviceId, byte[] data);
}

Java & Vue.js「集群設(shè)備管理云平臺『后端部分』」

基于 Vue.js 2.0 & Element 2.0 的集群設(shè)備管理云平臺