uni-app 能够跨端使用的MQTT

能够订阅发送MQTT信息，手机端能够使用的客户机

phonegap100 1楼•8 天前

在 uni-app 中 MQTT.js 可以使用，按小程序写法即可，参考：示例。

vueper 2楼•8 天前

在uni-app中实现跨端使用的MQTT（Message Queuing Telemetry Transport）功能，可以借助一些第三方库来简化开发过程。以下是一个基于Paho MQTT库的示例代码，展示如何在uni-app中实现MQTT客户端的跨端使用。

首先，确保你已经在项目中安装了Paho MQTT库。在HBuilderX中，你可以直接在manifest.json中添加依赖，或者通过npm安装（如果支持）。

1. 安装Paho MQTT（如果支持npm）

npm install paho-mqtt --save

2. 编写MQTT客户端代码

以下是一个简单的MQTT客户端示例，展示如何在uni-app中使用Paho MQTT库进行连接、订阅和发布消息。

// 引入Paho MQTT库
const Paho = require('paho-mqtt');

// 创建客户端实例
const client = new Paho.Client("wss://your-mqtt-broker-url:443/ws", "clientId_" + Math.random().toString(16).substr(2, 8));

// 设置连接丢失的回调函数
client.onConnectionLost = (responseObject) => {
    if (responseObject.errorCode !== 0) {
        console.log("onConnectionLost:" + responseObject.errorMessage);
    }
};

// 设置消息到达的回调函数
client.onMessageArrived = (message) => {
    console.log("onMessageArrived:" + message.payloadString);
};

// 连接到MQTT服务器
const options = {
    timeout: 3,
    onSuccess: () => {
        console.log("Connected to MQTT broker");
        // 订阅主题
        client.subscribe("your/topic");
        // 发布消息
        const message = new Paho.Message("Hello MQTT");
        message.destinationName = "your/topic";
        client.send(message);
    },
    onFailure: (errorMessage) => {
        console.log("Failed to connect: " + errorMessage);
    }
};

// 使用用户名和密码（如果需要）
const clientId = `client-${Math.floor(Math.random() * 1000)}`;
const connectOptions = {
    userName: "your-username",
    password: "your-password",
    onSuccess: options.onSuccess,
    onFailure: options.onFailure,
    timeout: options.timeout
};

// 尝试连接
client.connect(connectOptions);

注意事项

Broker URL：替换wss://your-mqtt-broker-url:443/ws为你的MQTT Broker的WebSocket URL。
Client ID：这里使用了随机生成的Client ID，你可以根据实际需求调整。
用户名和密码：如果你的MQTT Broker需要认证，请提供正确的用户名和密码。
跨端测试：确保在H5、小程序、App等不同平台上测试MQTT功能，以验证跨端兼容性。