MQTT Client实现消息推送功能的方法详解

MQTTAsync_setCallbacks(mqtt->_client, mqtt->_client, connlost, msgarrvd, NULL);

mqtt->_conn_opts.onSuccess = onConnect;
mqtt->_conn_opts.onFailure = onConnectFailure;

#You can install it as dependency with npm.
$ # save into package.json dependencies with -S 
$ npm install aliyun-iot-mqtt -S

const Mqtt = require('aliyun-iot-mqtt');
const client = Mqtt.getAliyunIotMqttClient({
    productKey: "",
    deviceName: "",
    deviceSecret: "",
    regionId: "cn-shanghai",
    keepalive:120 // mqtt options
});
client.on('connect', function() {
    console.log("connect")
})
client.end(function (){
    console.log("end")
})

var trustedCA = fs.readFileSync(path.join(__dirname, '/aliyun_iot_root.cer'))
var options = {
    productKey: "",
    deviceName: "",
    deviceSecret: "",
    regionId: "cn-shanghai",
    protocol: 'mqtts',
    ca: trustedCA,
    keepalive:120 // mqtt options
};

client.subscribe(topic)

client.publish(topic, 'Hello mqtt')
client.publish(topic, 'Hello mqtt', { qos: 1 })

client.on('message', function(topic, message) {
    console.log(topic+"," + message.toString())
})

var mqtt = require('mqtt');
var opt={
    port:1883
}
var client=mqtt.connect('tcp://10.66.28.51',opt);
client.on('connect',function(){
    console.log("mqtt已连接");
    // client.publish('wks/cim/ASPY/#','需要发送的信息');
    client.subscribe('wks/cim/ASPY/#')
})
client.on('message',function(topic,msg){
    console.log('收到'+topic+"讯息："+msg.toString());
})