NODEJS API

引入模块

var dms = require('dms')

初始化实例

var client = dms.New(pub_Key,sub_key)
或者
var client = dms.New(pub_Key,sub_key,clientid)

connect 事件

连接成功触发
client.on("connect",function(){
    console.log("connect")
})

offline ,reconnect 事件

连接断开，并进行重连
client.on("reconnect",function(){
    console.log("reconnect")
})
client.on("offline",function(err){
    console.log("offline",err)
})

message 事件

收到话题消息事件
client.on('message', function (topic, message,opts) {
  console.log(topic,"--"+opts.qos+"--",message);
});

error事件

client.on("error",function(err){
    console.log("error",err)
})

close事件

client.on("close",function(err){
    console.log("close",err)
})

推送消息

topic 推送到的话题
msg 推送的消息内容（字符串）
callback推送成功触发
client.publish(topic,msg,function(){
    console.log("send ok")
});

推送话题

topics  (array or string)话题数组
callback 回调，通知成功，失败
client.subscribe(['test_a',"test_b"],function(err,info){
    console.log("subscribe back",err,info)
});
client.subscribe('test_a',function(err,info){
    console.log("subscribe back",err,info)
});

取消关注

topics  (array or string) 话题数组
callback 回调，通知成功，失败
client.unsubscribe(['test_a',"test_b"],function(err,info){
    console.log("subscribe back",err,info)
});
client.unsubscribe('test_a',function(err,info){
    console.log("subscribe back",err,info)
});

断开连接

client.disconnect();