@cf-platform/mq

一、初始化

1. 初始化参数 MqOptions

取值为*号的参数为必填参数

| 参数名 | 描述 | 类型 | 取值 | |-----------------|-------|----------------|--------| | url | 地址 | string | * | | restartInterval | 重启间隔 | number | 3000 | | loginParams | 登录参数 | LoginParams | * | | customEvents | 自定义事件 | CustomEvents | null |

2. 登录参数 MqLoginParams

取值为*号的字段为必填字段

| 名称 | 描述 | 类型 | 取值 | |-------------|--------|----------|-----------------------------| | uid | 用户ID | string | * | | channel | 通道 | string | web | | appVersion | 系统ID | string | * | | osVersion | 设备版本号 | string | browser.version | | packageName | 包名 | string | com.farsunset.cim | | language | 语言 | string | window.navigator.language | | deviceId | 设备唯一ID | string | * | | deviceName | 设备名称 | string | browser.name | | custom | 自定义参数 | string | |

3. 自定义事件 MqEvents

| 方法名 | 描述 | 类型 | 是否必须 | |------------------------|-----------------|--------------------------|------| | onSocketOpen | socket连接成功时触发方法 | Function | 否 | | onSocketConnect | socket连接时触发方法 | Function(url: string) | 否 | | onSocketClose | socket连接关闭时触发方法 | Function | 否 | | onSocketError | socket连接错误时触发方法 | Function | 否 | | onSendPong | 发送心跳时触发方法 | Function | 否 | | onMessage | 收到消息时触发方法 | Function(message: any) | 否 | | onReply | 收到回复时触发方法 | Function(reply: any) | 否 | | onLoginSuccess | 回复登录成功时触发方法 | Function(reply: any) | 否 | | onLoginDisconnected | 回复登录断开时触发方法 | Function(reply: any) | 否 | | onAuthenticationFailed | 回复鉴权失败时触发方法 | Function(reply: any) | 否 |

4. 初始化方法

new Mq(<CIMOptions>{
    url: 'wss://127.0.0.1:8080',
    restartInterval: 0,
    loginParams: {
      uid: 'xxxxxxx',
      appVersion: 'xx',
      deviceId: 'xxxxxxxx'
    }
});

二、发送消息

1. 发送参数 MqMessage

| 参数名 | 描述 | 类型 | 可选值 | |----------|-------|----------|----------------------------------------------------| | key | 消息标识 | string | client_closed、send_message、broadcast_message | | custom | 自定义参数 | any | |

2. 发送方法

Mq.sendMessage(data: CIMMessage);

Mq

declare class Mq {
    /**
     * @param options Mq参数
     */
    constructor(options: MqOptions);
    
    /** 连接 */
    connect(): void;
    
    /** 重新连接 */
    reconnect(): void;
    
    /** 关闭 */
    close(): void;
    
    /**
     * 发送消息
     * @param MqMessage
     */
    sendMessage(data: CIMMessage): void;
}