Paho javascript mqtt压缩有效负载

Question

我正在开发一个网站，可以连接到一个mqtt代理，并获得有效负载消息。

我使用的库是（https://eclipse.org/paho/clients/js/）。

我的问题是以下几点。当我试图获得一个标准压缩消息（gzipped）时，库抛出一个异常“错误:AMQJS0009E Malformed UTF Data:F53-52”。

如何处理压缩消息？

下面是我的代码：

var selected_tags   = '';
var checked_tags    = [];

var hostname        = 'xxx';
var port            = 80;
var qos             = 1;

var user            = 'xxx';
var pass            = 'xxx';

var keepAlive       = 60;
var timeout         = 3;
var ssl             = false;
var cleanSession    = true;
var lastWillTopic   = '';
var lastWillQos     = 1;
var lastWillRetain  = false;
var lastWillMessage = '';
var g_topic;
var client = new Messaging.Client(hostname, port, "myclientid_" + parseInt(Math.random() * 100, 10));

var options = {
    timeout             : 3,
    userName            : user,
    password            : pass,
    keepAliveInterval   : keepAlive,
    cleanSession        : cleanSession,
    useSSL              : ssl,
    onSuccess           : function () {
        console_log('<span style="color:green">Connected</span>');
    },
    onFailure           : function (message) {
        console_log('<span style="color:red">Connection failed: ' + message.errorMessage + '</span>');
        client.connect(options);
    }
};
function _subscribe(){
    g_topic = $("#sel_reader").val();
    console_log('<span style="color:green">subscribe to: ' + g_topic + '</span>');
    client.subscribe(g_topic, {qos: qos});
    $("#_subscribe").addClass('hide');
    $("#_unsubscribe").removeClass('hide');
}
function _unsubscribe(){
    console_log('<span style="color:red">unsubscribe from: ' + g_topic + '</span>');
    client.unsubscribe(g_topic);
    $("#_subscribe").removeClass('hide');
    $("#_unsubscribe").addClass('hide');
}
client.onConnectionLost = function (responseObject) {
    console_log('<span style="color:red">Connection lost: ' + responseObject.errorMessage + '</span>');
    client.connect(options);
};
client.onMessageArrived = function (message) {
    // console.log("message arrived");

    var live_search = [];
    var live_found  = '';
    var json = JSON.parse(message.payloadString);

    console_log('<hr />Message Recieved: Topic: ' + message.destinationName + '<br />' 
                  +message.payloadString + 
                '. QoS: ' + message.qos
    );

};
var publish = function (payload, topic, qos) {
    var message = new Messaging.Message(payload);
    message.destinationName = topic;
    message.qos = qos;
    client.send(message);
}
function console_log(txt){
    $("#console").append('<b>'+txt + "</b><br />");
}
var prev_imei = '';
var find = ':';
var re   = new RegExp(find, 'g');
function SortByRssi(a, b){
    var arssi = a.rssi;
    var brssi = b.rssi; 
    return ((arssi > brssi) ? -1 : ((arssi < brssi) ? 1 : 0));
}
$(document).ready(function(){
    client.connect(options);
});

Answer 1

如果有人需要Python的答案：

import zlib

def _on_message(self, mqttc, obj, msg):
    dec_msg = zlib.decompress(msg.payload)
    # do whatever you need with dec_msg
    print dec_msg