мой.брокер.ru,8883
192.168.1.84,1883
mqtt.eclipse.org,1883

-- возвращаем функцию, что принимает номер строки
return function(n)
    local dt
    -- открываем файл с перечнем брокеров и читаем построчно до нужной
    if file.open("brklist.lua", "r") then
        for i = 1, n do
            dt = file.readline()
        end
        file.close()
    end
    if not dt then print('Lost List'); return end
    -- через захваты выделяем брокер и порт
    local brk, port = string.match(dt, "(.+),(%d+)")
    return brk, port
end

brk, port = dofile('brkget.lua')(номерстроки)

do
-- Строка в списке брокеров 
dat.nobrk = 1
-- Количество ошибок подключения к основному брокеру
-- ибо любая случайная ошибка должна приводить к попытке восстановления
-- связи, а не к пререключению на запасной брокер 
dat.erhome = 0
-- Резервируем переменные для реакций, одинаковых для
-- любого брокера
local subscribe, merror, mconnect, msg
-- Что делаем после соединения с брокером 
function subscribe(con)
    dat.broker = true
    con:subscribe(dat.clnt.."/com/#", 0)
    con:publish(dat.clnt..'/state', "ON", 0, 1)
    print("Subscribed to "..dat.clnt.."/com/# Heap: "..node.heap())
    dat.erhome = 0
    -- Если это не первая строка (не главный брокер), то будет попытка
    -- пересоединения, вызывается соответствующий таймер
    if dat.nobrk ~= 1 then dofile('brkkill.lua')(mconnect) end
end
-- Реакция на ошибку одинакова для всех брокеров
-- уничтожение соединения, объекта и повторное его создание
function merror(con, reason)
    con, reason, m = nil,nil,nil
    tmr.create():alarm(10000, tmr.ALARM_SINGLE, mconnect)
    collectgarbage()
end
-- Приход сообщения
function msg(con, top, dt)
    -- Таблица для вставки и передачи топика и даты на обработку
    if not killtop then killtop = {} end
    -- Захват топика из всей подписки
    top = string.match(top, "/(%w+)$")
    print('Got', top, dt)
    if dt then
        -- Вставляем данные в глобльную таблицу и вызываем обработчик
        table.insert(killtop, {top, dt})
        if not dat.analiz then
            dofile("mqttanalize.lua")
        end
    end
end
-- Функция создания соединения и соединение
function mconnect()
    -- Вызываем файл создания соединения и передаем ему ссылки
    -- на общие реакции или функцию обработки ошибки, если нет wifi
    if (wifi.sta.getip()) then   
        return dofile('mqttmake.lua')(subscribe, merror, msg)
    else
        return merror()
    end
end
-- Первый вызов
mconnect()
end

-- Возвращает функцию с аргументами типовых событий
return function(subscribe, merror, msg)
    -- Небольшой счетчик для обеспечения трех попыток соединения с
    -- домашним сервером
    if dat.erhome > 2 then
        dat.nobrk = dat.nobrk == dat.brkn and 1 or dat.nobrk + 1  
    else dat.erhome = dat.erhome + 1 end
    -- Получаем очередного брокера
    local brk, port = dofile('brkget.lua')(dat.nobrk)
    -- Создаем соединение и вызываем его
    m = mqtt.Client(dat.clnt, 25, dat.clnt, 'pass22')
    m:lwt(dat.clnt..'/state', "Off", 0, 1)
    m:on("offline", merror)
    m:on("message", msg)
    print('Connect to', brk, 'Heap', node.heap())
    m:connect(brk, port, false, subscribe, merror)
end

dat = {}
-- Номер строки брокера
dat.nobrk = 1
-- Имя клиента MQTT
dat.clnt = 'test8266/'-- ..node.chipid()
-- Количество строк в файле списка брокеров
dat.brkn = 3
dofile'mqttset.lua'