oops-plugin-framework/assets/libs/network/NetManager.ts

import type { CallbackObject, IRequestProtocol, NetData } from './NetInterface';
import type { NetConnectOptions, NetNode } from './NetNode';

/**
 * 使用流程文档可参考、简化与服务器对接、使用新版API体验，可进入下面地址获取新版本，替换network目录中的内容
 * https://store.cocos.com/app/detail/5877
 */

/*
 * 网络节点管理类
 */
export class NetManager {
    private static _instance: NetManager;
    protected _channels: { [key: number]: NetNode } = {};

    /** 网络管理单例对象 */
    static getInstance(): NetManager {
        if (!this._instance) {
            this._instance = new NetManager();
        }
        return this._instance;
    }

    /**
     * 添加网络节点
     * @param node       网络节点
     * @param channelId  通道编号
     * @example
    // 游戏服务器心跳协议
    class GameProtocol extends NetProtocolPako {
        // 自定义心跳协议
        getHearbeat(): NetData {
            return '{"action":"LoginAction","method":"heart","data":"null","callback":"LoginAction_heart"}';
        }
    }

    var net = new NetNodeGame();
    var ws = new WebSock();        // WebSocket 网络连接对象
    var gp = new GameProtocol();   // 网络通讯协议对象
    var gt = new NetGameTips()     // 网络提示对象
    net.init(ws, gp, gt);
    NetManager.getInstance().setNetNode(net, NetChannelType.Game);
     */
    setNetNode(node: NetNode, channelId = 0) {
        this._channels[channelId] = node;
    }

    /** 移除Node */
    removeNetNode(channelId: number) {
        delete this._channels[channelId];
    }

    /**
     * 网络节点连接服务器
     * @param options      连接参数
     * @param channelId    通道编号
     * @example
    var options = {
        url: 'ws://127.0.0.1:3000',
        autoReconnect: 0            // -1 永久重连，0不自动重连，其他正整数为自动重试次数
    }
    NetManager.getInstance().connect(options, NetChannelType.Game);
     */
    connect(options: NetConnectOptions, channelId = 0): boolean {
        if (this._channels[channelId]) {
            return this._channels[channelId].connect(options);
        }
        return false;
    }

    /** 节点连接发送数据*/
    send(buf: NetData, force = false, channelId = 0): number {
        const node = this._channels[channelId];
        if (node) {
            return node!.send(buf, force);
        }
        return -1;
    }

    /**
     * 发起请求，并在在结果返回时调用指定好的回调函数
     * @param reqProtocol 请求协议
     * @param rspObject   回调对象
     * @param showTips    是否触发请求提示
     * @param force       是否强制发送
     * @param channelId   通道编号
     * @example
    let protocol: IRequestProtocol = {
        action: action,
        method: method,
        data: JSON.stringify(data),
        isCompress: this.isCompress,
        channelid: netConfig.channelid
    }
    return this.request(protocol, rspObject, showTips, force);
     */
    request(reqProtocol: IRequestProtocol, rspObject: CallbackObject, showTips = true, force = false, channelId = 0) {
        const node = this._channels[channelId];
        if (node) {
            node.request(reqProtocol, rspObject, showTips, force);
        }
    }

    /**
     * 同request功能一致，但在request之前会先判断队列中是否已有rspCmd，如有重复的则直接返回
     * @param reqProtocol 请求协议
     * @param rspObject   回调对象
     * @param showTips    是否触发请求提示
     * @param force       是否强制发送
     * @param channelId   通道编号
     * @example
    let protocol: IRequestProtocol = {
        action: action,
        method: method,
        data: JSON.stringify(data),
        isCompress: this.isCompress,
        channelid: netConfig.channelid
    }
    return this.request(protocol, rspObject, showTips, force);
     */
    requestUnique(reqProtocol: IRequestProtocol, rspObject: CallbackObject, showTips = true, force = false, channelId = 0): boolean {
        const node = this._channels[channelId];
        if (node) {
            return node.requestUnique(reqProtocol, rspObject, showTips, force);
        }
        return false;
    }

    /**
     * 节点网络断开
     * @param code        关闭码
     * @param reason      关闭原因
     * @param channelId   通道编号
     * @example
     * NetManager.getInstance().close(undefined, undefined, NetChannelType.Game);
     */
    close(code?: number, reason?: string, channelId = 0) {
        if (this._channels[channelId]) {
            return this._channels[channelId].closeSocket(code, reason);
        }
    }
}