@cf-platform/mq NPM

@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;
}

5 days ago

12 days ago

25 days ago

25 days ago

25 days ago