帮助列表
帮助列表
NODEJS API 文档

目录[+]


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();



2006 - 2023 aodianyun.com, All Rights Reserved. 奥点科技 版权所有 增值电信业务经营许可证:浙B2-20110306 浙ICP备07500424号 |

  • 电话

    X

    售前咨询:

    400-663-6063

    售后服务:

    400-663-6063

  • 客服

  • 建议

    咨询留言 X
    提  交

在线QQ

售前咨询400-663-6063

售后服务400-663-6063