二次开发了一个可以在小程序里连接MQTTbroker的websocket库-微信小程序俱乐部 www.wxappclub.com

原创声明:本文为作者原创，未经允许不得转载，经授权转载需注明作者和出处

https://github.com/w3hacker/paho.mqtt.javascript

var app = getApp();
var Paho = require('../../utils/mqttws31.js');

// Create a client instance
var client = new Paho.MQTT.Client('192.168.1.101', 8883, "clientId");

Page({
    publishMessage: function() {
        var message = new Paho.MQTT.Message('hello world');
        message.destinationName = "test/topic";
        client.send(message);
    },
    onLoad: function() {

        client.onMessageArrived = function(msg) {
            wx.showToast({
                title: msg.payloadString
            });
        }

        client.onConnectionLost = function(responseObject) {
            if (responseObject.errorCode !== 0) {
                console.log("onConnectionLost:" + responseObject.errorMessage);
            }
        }

        client.connect({
            useSSL: true,
            cleanSession: false,
            keepAliveInterval: 60,
            onSuccess: function() {
                console.log('connected');

                client.subscribe("test/topic", {
                    qos: 1
                });
            }
        });
    }
});