使用CocosCreator怎么實現(xiàn)網(wǎng)絡通信

使用CocosCreator怎么實現(xiàn)網(wǎng)絡通信？相信很多沒有經(jīng)驗的人對此束手無策，為此本文總結了問題出現(xiàn)的原因和解決方法，通過這篇文章希望你能解決這個問題。

具體實施

public constructor(driver: ConnectDriver) {
        this._driver = driver;
}

先定義通用的網(wǎng)絡通信數(shù)據(jù)結構。其中請求分為數(shù)據(jù)和控制兩種類型，用于區(qū)分心跳、登錄、重連

/**
 * 請求類型
 */
export enum RequestType {
    DATA = 1,
    CTRL
}
 
/**
 * 網(wǎng)絡通信數(shù)據(jù)結構
 */
export interface NetData {
    seq?: number; // 序列號
    mod: number; // 模塊
    cmd: number; // 命令
    path?: string; // 路徑
    data?: any; // 數(shù)據(jù)
    tmpData?: any; // 數(shù)據(jù)處理器臨時數(shù)據(jù)
    status?: number; //狀態(tài)碼
    type?: RequestType;  //請求類型
}

然后定義通用的對外接口

public open(url: string, port: number, isBinary: boolean, timeout: number, retryCount: number, params: any, cb: (succ: boolean) => void): void {}
 
public close(): number {}
 
public reopen(cb: (succ: boolean) => void): void {}
 
public sendData(data: NetData, params: HttpReq | any, succCb: (data: NetData) => void, failedCb: (code: number, reason: string) => void): void {}
 
public resendNotRecv(): void {}

其中resendNotRecv用于重連后發(fā)送沒有收到響應的包，后端根據(jù)序列號決定是否處理。

這里沒有對推送的處理，實際上推送是接收到服務端數(shù)據(jù)后，調(diào)用廣播給監(jiān)聽者。下面定義監(jiān)聽者

/**
 * 網(wǎng)絡連接事件監(jiān)聽接口
 */
export interface ConnectEventListener {
    onOpen(driver: ConnectDriver);
    onClosed(driver: ConnectDriver);
    onError(driver: ConnectDriver, msg: string);
    onSendStart(driver: ConnectDriver);
    onRecvEnd(driver: ConnectDriver);
}
 
/**
 * 網(wǎng)絡事件監(jiān)聽接口
 */
export interface NetEventListener extends ConnectEventListener {
    onPush(driver: ConnectDriver, data: NetData): void;
}

對外提供注冊和移除接口

public addEventListener(listener: NetEventListener): void {}
 
public removeEventListener(listener: NetEventListener): void {}

針對第三個問題，需要定義一些預處理器，在發(fā)送數(shù)據(jù)前和接收到數(shù)據(jù)后，做攔截預處理。

/**
 * 網(wǎng)絡通信數(shù)據(jù)處理器接口
 */
export interface NetDataProcessor {
    processReqData(data: any): any;
    processRespData(data: any): any;
}

對外提供添加和移除接口，這樣就可以靈活定義通信數(shù)據(jù)格式

public addDataProcessor(processor: NetDataProcessor): void {}
 
public removeDataProcessor(processor: NetDataProcessor): void {}

針對第四個問題，同樣是增加一個特殊的攔截器，在請求發(fā)送前對其處理，如果攔截器能處理，就不再發(fā)送給后端。

/**
 * 模擬服務器接口
 */
export interface SimServer {
    handleRequest(data: NetData): NetData;
}

對外提供設置接口

public setSimServer(server: SimServer): void {}

針對第五個問題，所有數(shù)據(jù)請求都有序列號，對請求進行記錄，沒有響應的請求包放到一個隊列里，重連后重發(fā)這些包給后端處理

public resendNotRecv(): void {}

看完上述內(nèi)容，你們掌握使用CocosCreator怎么實現(xiàn)網(wǎng)絡通信的方法了嗎？如果還想學到更多技能或想了解更多相關內(nèi)容，歡迎關注億速云行業(yè)資訊頻道，感謝各位的閱讀！