• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

ESA2GJK1DH1K微信小程序篇:小程序MQTT底层优化-支持一次订阅多个主题 ...

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

 

 

说明

  有人做项目发现,底层的MQTT包不支持订阅一次订阅多个主题!

  我看了下官方提供的底层源码,确实是不可以订阅多个主题

  故:我给大家重新完善了一下底层,使其可以一次性订阅多个主题

  为了不改动原先的源码,本人在底层源码的基础上增加了 subscribeMultiple 函数

  

修改说明

  为了可以帮到更多的人,公开添加的支持订阅多个主题的函数部分

  我在底层源码增加了第一部分

  

 

 

 

   源码:

  

    /*
    subscribeMultiple
     */
    ClientImpl.prototype.subscribeMultiple = function (filter, subscribeOptions) {
      this._trace("Client.subscribe", filter, subscribeOptions);
      if (!this.connected)
        throw new Error(format(ERROR.INVALID_STATE, ["not connected"]));
      var wireMessage = new WireMessage(MESSAGE_TYPE.SUBSCRIBE);

      if (typeof filter == "object"){
        if (filter.length>0){
          wireMessage.topics = [];
          wireMessage.requestedQos=[];
          for (var i = 0; i < filter.length ;i++){
            if ((typeof filter[i]) == 'string'){
              wireMessage.topics[i] = filter[i];

              if (subscribeOptions.qos !== undefined){
                if ((typeof subscribeOptions.qos[i]) == 'number'){
                  if (subscribeOptions.qos[i] >= 0 && subscribeOptions.qos[i] <= 2){
                    wireMessage.requestedQos[i] = subscribeOptions.qos[i];
                  }
                  else{
                    throw new Error("Invalid argument: Qos is 0,1,2 Can not be" + subscribeOptions.qos[i]);
                  }
                }
                else{
                  throw new Error("Invalid argument: Qos is 0,1,2 Can not be" + subscribeOptions.qos[i]);
                }
              }
              else{
                wireMessage.requestedQos[i]=0;
              }
            }
            else{
              throw new Error("Invalid argument:" + filter[i]);
            }
          }
        }
      }
      else
      {
        wireMessage.topics = [filter];
        if (subscribeOptions.qos !== undefined)
          wireMessage.requestedQos = [subscribeOptions.qos];
        else
          wireMessage.requestedQos = [0];
      }

      if (subscribeOptions.onSuccess) {
        wireMessage.onSuccess = function (grantedQos) { subscribeOptions.onSuccess({ invocationContext: subscribeOptions.invocationContext, grantedQos: grantedQos }); };
      }

      if (subscribeOptions.onFailure) {
        wireMessage.onFailure = function (errorCode) { subscribeOptions.onFailure({ invocationContext: subscribeOptions.invocationContext, errorCode: errorCode, errorMessage: format(errorCode) }); };
      }

      if (subscribeOptions.timeout) {
        wireMessage.timeOut = new Timeout(this, subscribeOptions.timeout, subscribeOptions.onFailure, [{
          invocationContext: subscribeOptions.invocationContext,
          errorCode: ERROR.SUBSCRIBE_TIMEOUT.code,
          errorMessage: format(ERROR.SUBSCRIBE_TIMEOUT)
        }]);
      }

      // All subscriptions return a SUBACK.
      this._requires_ack(wireMessage);
      this._schedule_message(wireMessage);
    };

 

 我在底层源码增加了第二部分

  

 

 

 

 

 源码:

  

      this.subscribeMultiple = function (filter, subscribeOptions) {
        client.subscribeMultiple(filter, subscribeOptions);
      };

 

 

 

使用说明:

  

 

修改后的底层js文件,导入源文件,替换以前使用的即可

 

  

 

使用本人再次封装的mqtt.js

https://www.cnblogs.com/yangfengwu/p/11832651.html   先看下这一节

 

 

调用:

  

var TopicMultiple = ["1111", "2222"];
var QosMultiple = [0, 0];

MQTT.subscribeTopicMultiple(TopicMultiple, QosMultiple, this.SubscribeTopicSuccess, this.SubscribeTopicFailure);

 

导入源文件替换原先使用的即可

 

 

 

提示

  该函数也支持订阅一个主题

  一,直接用 paho-mqtt.js

  订阅的主题 1111 消息等级 0

client.subscribeMultiple(
"1111"
,
{ 
qos: 0
,
invocationContext: 
{ 
arg: null 
}, 
onSuccess: function()
{
console.log("订阅成功");
},
onFailure: function()
{
console.log("订阅失败");
} 
}
);

 

二,用 mqtt.js

MQTT.subscribeTopicMultiple("1111", 0, this.SubscribeTopicSuccess, this.SubscribeTopicFailure);

 


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap