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

    /*
    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);
      };

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

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