Reference

mqtt.lua

#!/usr/bin/env eco

-- Using emqx for testing
-- docker run -d --name emqx -p 1883:1883 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083 emqx/emqx:latest

local mqtt = require 'eco.mqtt'
local time = require 'eco.time'

local auto_reconnect = false

local function on_conack(ack, client)
    print('conack:', ack.rc, 'reason:', ack.reason, 'session_present:', ack.session_present)

    if ack.rc ~= mqtt.CONNACK_ACCEPTED then
        return
    end

    client:subscribe(
        'test', mqtt.QOS2,
        'tes1', mqtt.QOS1
    )

    client:publish('eco', 'I am lua-eco MQTT', mqtt.QOS2)
end

local function on_suback(ack)
    for _, result in ipairs(ack.results) do
        if result.rc == mqtt.SUBACK_FAILURE then
            print('suback:', result.topic, 'fail')
        else
            print('suback:', result.topic, 'rc:', result.rc)
        end
    end
end

local function on_unsuback(topic)
    print('unsuback:', topic)
end

local function on_publish(msg, client)
    print('message:', msg.topic, msg.payload)
    client:unsubscribe('test')
end

local function on_error(err)
    print('error:', err)
end

local client = mqtt.new({
    ipaddr = '127.0.0.1',
    clean_session = true
})

-- And you can set an option individually
client:set('keepalive', 5)

-- You can add multiple event handlers at once
client:on({
    conack = on_conack,
    suback = on_suback,
    unsuback = on_unsuback,
    publish = on_publish
})

-- Or add one event handler at a time
client:on('error', on_error)

while true do
    -- Start handling events until the network connection is closed
    client:run()

    if not auto_reconnect then
        break
    end

    print('reconnect in 5s...')

    time.sleep(5)
end
lua-eco

Examples

Modules

Topics

mqtt.lua
