更新记录

1.0.6（2024-03-30）

新增取消订阅、监听连接丢失、自动重新连接等功能

1.0.5（2024-03-30）

删除class的export

1.0.4（2024-03-30）

删除android下的uts导出default

平台兼容性

使用说明

该插件可用于连接mqtt服务端，也可以用于连接rabbitMQ服务端

如果想连接rabbitMQ 请在rabbitMQ官网下开启mqtt插件并且添加对应配置即可

有关于该插件的疑问或者技术探讨可以微信联系作者(备注来源)

微信号：z1003975792y

API 介绍

连接函数connect

import {
    connect
} from "@/uni_modules/zy-mqtt";

let option = {
    host: 'tcp://10.10.xx.xx:1883', // 主机ip
    clientId: 'xxxxx', // 客户端id
    userName: 'xxxx',  // 用户名
    password: 'xxxx',  // 密码
    cleanSession: false // 可选,默认false,是否开启持续会话
    automaticReconnect: true // 可选,默认true,是否自动重连
    heartBeat: 60 // 可选,默认60秒, 心跳
    timeOut: 30 // 可选,默认30秒,连接超时时间
}
// 先连接mqtt
connect(option, (res) => {
    uni.showToast({
        title: res.message
    })
)

订阅主题函数subscribe

import {
    subscribe
} from "@/uni_modules/zy-mqtt";

// 下面是其它客户端或者后端发布消息以json的格式
// 例如 {message:'你好，mqtt'}
subscribe('topic', 2, (res) => {
    uni.showToast({
        title: res.message // 你好，mqtt
    })
})

取消订阅函数unSubscribe

import {
    unSubscribe
} from "@/uni_modules/zy-mqtt";

unSubscribe('topic', (res) => {
    uni.showToast({
        title: res.message
    })
})

发布消息函数publishMessage

import {
    publishMessage
} from "@/uni_modules/zy-mqtt";

var messages = JSON.stringify({
    message: '你好，mqtt',
    phone: '131xxxxxxxx'
})
publishMessage('your/topic', 2, messages, (res) => {
    uni.showToast({
        title: res.message // 发布消息结果的message
    })
})

监听连接丢失函数onConnectLost

import {
    onConnectLost
} from "@/uni_modules/zy-mqtt";

onConnectLost((res) => {
    uni.showToast({
        title: res.message // 连接丢失的原因
    })
})

监听自动重新连接函数onReconnect

automaticReconnect:true的前提下生效

重新连接后，插件自己会将原来已经订阅的主题主动订阅，无需自己重新订阅

import {
    onReconnect
} from "@/uni_modules/zy-mqtt";

onReconnect((res) => {
    uni.showToast({
        title: res.message // 重新连接的结果
    })
})

断开连接函数disConnect

import {
    disConnect
} from "@/uni_modules/zy-mqtt";

disconnectMqtt()

获取配置函数getConfig

import {
    getConfig
} from "@/uni_modules/zy-mqtt";

const config = getConfig()
console.log(getConfig) // 返回连接的所有配置信息