xhaskx / luamqtt Goto Github PK

client = mqtt.client{
	debug = client_debug,
	uri = "x.x.x.x:8883",
	auth = {username = "mqtt_user", password = "123456" },
	clean = true,
	ssl = true,
	ssl_params = {	cafile = "/certs/device/cacert.pem",	
			       certificate = "/certs/device/clientcert.pem",
			       key = "/certs/device/clientkey.pem" },
	}	

daniel@memory:~/mqtt $ sudo luarocks install luamqtt
Installing https://rocks.moonscript.org/luamqtt-1.4.3-1.rockspec...
Using https://rocks.moonscript.org/luamqtt-1.4.3-1.rockspec... switching to 'build' mode
Cloning into 'luamqtt'...
remote: Enumerating objects: 29, done.
remote: Counting objects: 100% (29/29), done.
remote: Compressing objects: 100% (26/26), done.
remote: Total 29 (delta 2), reused 18 (delta 1), pack-reused 0
Receiving objects: 100% (29/29), 25.08 KiB | 0 bytes/s, done.
Resolving deltas: 100% (2/2), done.
Checking connectivity... done.
Note: checking out 'e2e16e029ff06f622d4750463ba64c18674d8d1f'.

You are in 'detached HEAD' state. You can look around, make experimental
changes and commit them, and you can discard any commits you make in this
state without impacting any branches by performing another checkout.

If you want to create a new branch to retain commits you create, you may
do so (now or later) by using -b with the checkout command again. Example:

  git checkout -b <new-branch-name>

Updating manifest for /usr/local/lib/luarocks/rocks
luamqtt 1.4.3-1 is now built and installed in /usr/local (license: MIT)

daniel@memory:~/mqtt $ ls /usr/local/lib/luarocks/rocks/
index.html  luabitop  luafilesystem  luamqtt  luasec  luasocket  manifest  manifest-5.1  manifest-5.2  manifest-5.3  penlight
daniel@memory:~/mqtt $ ls /usr/local/lib/luarocks/rocks/luamqtt/
1.4.3-1
daniel@memory:~/mqtt $ ls /usr/local/lib/luarocks/rocks/luamqtt/1.4.3-1/
doc  luamqtt-1.4.3-1.rockspec  rock_manifest
daniel@memory:~/mqtt $

local require = require

local mqtt = require("mqtt")
local ioloop = require("mqtt.ioloop")

local log = require("core.log")

local setmetatable = setmetatable
local timer_at = ngx.timer.at
local str_format = string.format

local function on_timer(premature, ctx)
  if premature then
    log.warn("exit mqtt timer!")
    return
  end

  log.info("starting mqtt client...")
  local loop = ioloop.create{
    timeout = ctx.cli.args.keep_alive,
    sleep_function = ngx.sleep,
  }
  loop:add(ctx.cli)
  ctx.cli:start_connecting()
  loop:run_until_clients()

  timer_at(1, on_timer, ctx)
end

local _M = {}
local mt = { __index = _M }

function _M:new(conf)
  local cli = mqtt.client{
    id = str_format("server/center/%d", ngx.worker.id()),
    uri = conf.broker,
    username = conf.username,
    password = conf.password,
    clean = true,
    connector = require("mqtt.ngxsocket")
  }

  cli:on{
    connect = function(connack)
      if connack.rc ~= 0 then
        log.error("connect mqtt broker failed!")
        return
      end

      log.info("mqtt client connected!")

      cli:publish{
        topic = "luamqtt/simpletest",
        payload = "hello",
        qos = 0
      }
    end,
    message = function(msg)
      cli:acknowledge(msg)
      log.info("receive mqtt message! ", msg)
    end,
    error = function(err)
      log.error("mqtt client error: ", err)
    end,
    close = function(conn)
      log.warn("mqtt conn closed: ", conn.close_reason)
    end
  }

  return setmetatable({
    conf = conf,
    cli = cli
  }, mt)
end

function _M:start()
  return timer_at(1, on_timer, self)
end

function _M:publish()
  timer_at(0, function ()
    self.cli:publish{
      topic = "luamqtt/simpletest",
      payload = "hello",
      qos = 0
    }
  end)
end

return _M

2020/04/24 16:54:17 [error] 2002#2002: *3424 lua entry thread aborted: runtime error: /mnt/d/Workspace/Demo/Openresty/test//lib/mqtt/client.lua:1147: bad request
stack traceback:
coroutine 0:
        [C]: in function 'send'
        /mnt/d/Workspace/Demo/Openresty/test//lib/mqtt/client.lua:1147: in function '_send_packet'
        /mnt/d/Workspace/Demo/Openresty/test//lib/mqtt/client.lua:455: in function 'publish'
        /mnt/d/Workspace/Demo/Openresty/test//lua/core/mqtt.lua:82: in function </mnt/d/Workspace/Demo/Openresty/test//lua/core/mqtt.lua:81>, context: ngx.timer, client: 127.0.0.1, server: 0.0.0.0:7500
2020/04/24 16:54:46 [info] 2004#2004: *3423 client closed connection while waiting for request, client: 127.0.0.1, server: 0.0.0.0:7500

mkdir -p /home/ubuntu/openwrt/dl
SHELL= flock /home/ubuntu/openwrt/tmp/.v3.1.tar.gz.flock -c '  	/home/ubuntu/openwrt/scripts/download.pl "/home/ubuntu/openwrt/dl" "v3.1.tar.gz" "x" "" "https://github.com/xHasKx/luamqtt/archive/"    '
Cannot find appropriate hash command, ensure the provided hash is either a MD5 or SHA256 checksum.
Makefile:49: recipe for target '/home/ubuntu/openwrt/dl/v3.1.tar.gz' failed
make[2]: *** [/home/ubuntu/openwrt/dl/v3.1.tar.gz] Error 255
make[2]: Leaving directory '/home/ubuntu/openwrt/feeds/jng_lua_openwrt/luamqtt'
time: package/feeds/jng_lua_openwrt/luamqtt/download#0.17#0.10#0.27
package/Makefile:111: recipe for target 'package/feeds/jng_lua_openwrt/luamqtt/download' failed
make[1]: *** [package/feeds/jng_lua_openwrt/luamqtt/download] Error 2
make[1]: Leaving directory '/home/ubuntu/openwrt'
make[1]: Entering directory '/home/ubuntu/openwrt'
make[2]: Entering directory '/home/ubuntu/openwrt/target/linux'
make[3]: Entering directory '/home/ubuntu/openwrt/target/linux/ar71xx'
make[3]: Nothing to be done for 'download'.
make[3]: Leaving directory '/home/ubuntu/openwrt/target/linux/ar71xx'
make[2]: Leaving directory '/home/ubuntu/openwrt/target/linux'
time: target/linux/download#0.03#0.03#0.07
make[1]: Leaving directory '/home/ubuntu/openwrt'

function groupcallback(event)
    if event.dst == '1/1/1' then
        local value = knxdatatype.decode(event.datahex, dt.uint16)
        submit_to_mqtt(value)
    end
end
 
lb = require('localbus').new(0.5) -- timeout is 0.5 seconds
lb:sethandler('groupwrite', groupcallback)
 
while true do
    lb:step()
    do_some_other_stuff()
end

local mqtt = require("mqtt")
local json = require("lunajson")

local luasec =  require("ssl")
print("using luasec runtime version: ", luasec._VERSION)
local path_to_root_cert = "<root directory>/src/cert/digicert.crt"
local device_id = "Teltonika02";
local sas_token = "SharedAccessSignature sr=<hostname>.azure-devices.net&sig=xeJT3F1XsYB5uIcbLjW3L9do4NXlUIOC1kBfNZ5zHuQ%3D&skn=iothubowner&se=2045963831";
local iot_hub_name = "<hostname>.azure-devices.net/<device id>/?api-version=2021-04-12";

local client = mqtt.client({
	  uri = "<hostname>.azure-devices.net",
    username = iot_hub_name,
    secure = {
        mode = "client",
        protocol = "tlsv1_2",
        cafile = path_to_root_cert,
        certificate = nil,
        key = nil
     },
    password = sas_token,
    version = mqtt.v50,
    clean = true
});
print(client,  ":  client")
local topic = "devices/" .. device_id .. "/messages/events/$.ct=application%2Fjson%3Bcharset%3Dutf-8"
local payload = [[{'id':123}]]

client:on{
    connect = function(connack)
        print("connack....", connack)
        if connack.rc ~= 0 then
            print("connection to broker failed:", connack:reason_string(), connack)
            return
        end
        print("Now go for subscribe")
        -- connection established, now subscribe to test topic and publish a message after
        assert(client:subscribe{ topic=topic, qos=1, callback=function()
            assert(client:publish{ topic = topic, payload = payload })
        end})
    end,
    message = function(msg)
        print(msg, ": messgae")
        assert(client:acknowledge(msg))

        -- receive one message and disconnect
        print("received message", msg)
        client:disconnect()
    end,
}

-- run ioloop for client
mqtt.run_ioloop(client)
-- Check if the MQTT client is connected
if client.connected then
   print("Connection is established")
else
   print("Connection is not established : ", client.connected)
end

local io = require("ioloop")
local ioloop = require("mqtt.ioloop")

local mq_loop = ioloop.create {
        sleep = 1,
        timeout = 1,
        sleep_function = skynet.sleep
    }

local client = mqtt.client(conn_params)
    client:on{
        connect = function(connack)
            assert(not mqtt_client)

            if not (connack and connack.rc == 0) then
                logger:error("connection to mqtt fail: %s %s", connack and connack:reason_string() or "", connack)
                return
            end

            logger:info("MQTT client connected server success!!!") -- successful connection
            state_table.connect_ok = true
            local response_count = 0
            for _, item in ipairs(topics) do
                local module, topic = item.module, item.topic
                client:subscribe{
                    topic = topic,
                    qos = 0,
                    callback = function(suback, args)
                        response_count = response_count + 1
                        if suback.rc[1] ~= 0 then
                            client:disconnect(0)
                            logger:error("subscribe [%s %s] fail %s", module, topic, suback.rc[1])
                            return
                        end

                        logger:info("subscribe from cloud [%s, %s] ok", module, topic)
                        if response_count >= #topics then
                            mqtt_client = client
                            logger:info("All topic subscribes OK, MQTT client is ready!!!")
                            --Not support, upload software version with 5mins timer.
                            --[[
                            local mqtt_dispatcher = skynet.queryservice("mqtt_dispatcher")
                            skynet.send(mqtt_dispatcher, "lua", "post")
                            ]]
                        end
                    end
                }
            end
        end,
        message = function(msg)
            local err = client:acknowledge(msg)
            if not err then
                logger:error("received a error msg!")
                return
            end
            table.insert(work_queue, {
                msg.topic,
                msg.payload
            })

            logger:info("Recv from cloud, topic: %s, payload: %s", msg.topic, msg.payload)
            skynet.wakeup(work_loop_co)
            skynet.yield()
        end,
        error = function(err, args, connack)
            logger:error("mqtt client err: %s, args: %s, connack: %s", err, args, connack)
            if not connack then
                logger:error("MQTT client error maybe unable to connect to network")
                return
            end

            if connack.rc == 4 then
                state_table.connect_ok = false
                client.args.reconnect = client.args.reconnect + 5
            end
        end,
        close = function()
            state_table.connect_ok = false
            mqtt_client = nil -- set to nil mqtt_client = nil -- set to nil
            client = nil
            logger:error("mqtt client is close, set to not ready!!!")
        end
    }

    mq_loop:add(client)
    client:start_connecting()
    while true do
       if not client then
            break
        end
        mq_loop:iteration()   --------when run here is stuck
        skynet.yield()
    end

daniel@memory:~/mqtt/luamqtt/examples (master)*$ lua simple.lua 
lua: /usr/local/share/lua/5.1/mqtt/init.lua:31: module 'mqtt.protocol4' not found:
	no field package.preload['mqtt.protocol4']
	no file './mqtt/protocol4.lua'
	no file '/usr/local/share/lua/5.1/mqtt/protocol4.lua'
	no file '/usr/local/share/lua/5.1/mqtt/protocol4/init.lua'
	no file '/usr/local/lib/lua/5.1/mqtt/protocol4.lua'
	no file '/usr/local/lib/lua/5.1/mqtt/protocol4/init.lua'
	no file '/usr/share/lua/5.1/mqtt/protocol4.lua'
	no file '/usr/share/lua/5.1/mqtt/protocol4/init.lua'
	no file './mqtt/protocol4.so'
	no file '/usr/local/lib/lua/5.1/mqtt/protocol4.so'
	no file '/usr/lib/x86_64-linux-gnu/lua/5.1/mqtt/protocol4.so'
	no file '/usr/lib/lua/5.1/mqtt/protocol4.so'
	no file '/usr/local/lib/lua/5.1/loadall.so'
	no file './mqtt.so'
	no file '/usr/local/lib/lua/5.1/mqtt.so'
	no file '/usr/lib/x86_64-linux-gnu/lua/5.1/mqtt.so'
	no file '/usr/lib/lua/5.1/mqtt.so'
	no file '/usr/local/lib/lua/5.1/loadall.so'
stack traceback:
	[C]: in function 'require'
	/usr/local/share/lua/5.1/mqtt/init.lua:31: in main chunk
	[C]: in function 'require'
	simple.lua:2: in main chunk
	[C]: ?

# lua simple.lua
created MQTT client     mqtt.client{id="lua-simple-client"}
running ioloop for it
done, ioloop is stopped

        uri = "abcdef.123.iot.us-east-1.amazonaws.com",
        id = "lua-simple-client",
        secure = {
                mode = "client",
                protocol = "tlsv1_2",
                verify = "peer",
                options = "all",
                cafile="/lua/root-CA.pem",
                certificate="/lua/Device.cert.pem",
                key="/lua/Device.private.key"
        },
        version= mqtt.v311,