About the method of MQTT reconnection

[xrdandy 0]

Hi,

 

I have a HC3L and using MQTT to control Smart Implant and Single Switch.

 

If the network is disconnected or there is no data transmission in MQTT for a long time, the connection seems to be interrupted, but the MQTT client does not have a property to check if it is still connected. I currently put the reconnection on the onError and onClosed events to perform the reconnection. Below is my code...

 

Please login or register to see this code.

 

Are there other options for reconnecting?

 

Andy Chiang

 

 

[zhou_jack 1]

function QuickApp:CheckMqttClientLoop()

    if (self.mqttClient == nil) or (self.mqttReconnect == true) then

        print('start conn mqtt:' .. json.encode(self.gatewayConfig) .. 'param:' .. json.encode(self.mqttParams))

        local mqtt_cli = mqtt.Client.connect('mqtt://' .. self.gatewayConfig.ip .. ':1883', self.mqttParams)

        mqtt_cli._debug = false

        mqtt_cli:addEventListener('closed', function(event)

            -- print('mqtt closed')

            self:handleMqttClosed(event)

        end)

        mqtt_cli:addEventListener('subscribed', function(event)

            -- print('mqtt subscribed')

            self:handleMqttSubscribed(event)

        end)

        mqtt_cli:addEventListener('message', function(event)

            -- print('receive msg')

            self:handleMqttReceiveMessage(event)

        end)

        mqtt_cli:addEventListener('error', function(event)

            -- print('receive err')

            self:handleMqttErr(event)

        end)

        mqtt_cli:addEventListener('connected', function(event)

            -- print('create mqtt connect finish')

            self:handleMqttConnected(mqtt_cli, event)

        end)

        print("mqtt client start conn")

        self.mqttClient = mqtt_cli

    end

    -- self:trace('check mqtt conn')

    hub.setTimeout(6000, function()

        self:CheckMqttClientLoop()

    end)

end

u should use check conn loop function to check mqtt connect,hub.setTimeout() is useful