MQTT lua例子
2015-09-02 15:53
579 查看
-- init mqtt client with keepalive timer 120sec
m = mqtt.Client("clientid", 120, "user", "password")
-- setup Last Will and Testament (optional)
-- Broker will publish a message with qos = 0, retain = 0, data = "offline"
-- to topic "/lwt" if client don't send keepalive packet
m:lwt("/lwt", "offline", 0, 0)
m:on("connect", function(con) print ("connected") end)
m:on("offline", function(con) print ("offline") end)
-- on publish message receive event
m:on("message", function(conn, topic, data)
print(topic .. ":" )
if data ~= nil then
print(data)
end
end)
-- for secure: m:connect("192.168.16.9", 1880, 1)
m:connect("192.168.16.9", 1883, 0, function(conn) print("connected") end)
-- subscribe topic with qos = 0
m:subscribe("/topic",0, function(conn) print("subscribe
success") end)
-- publish a message with data = hello, QoS = 0, retain = 0
m:publish("/topic","hello",0,0, function(conn) print("sent") end)
m:close();
-- you can call m:connect again
m = mqtt.Client("clientid", 120, "user", "password");
m:lwt("/lwt", "offline", 0, 0);
m:on("message", function(conn, topic, data) print(topic .. ":" ) if data ~= nil then print(data) end end);
m:connect("192.168.16.9", 1883, 0, function(conn) print("connected") end);
m:connect("impkd.com", 1883, 0, function(conn) print("connected") end);
m:subscribe("/topic",0, function(conn) print("subscribe
success") end);
m:publish("/topic","hello",0,0, function(conn) print("sent") end);
m = mqtt.Client("clientid", 120, "user", "password")
-- setup Last Will and Testament (optional)
-- Broker will publish a message with qos = 0, retain = 0, data = "offline"
-- to topic "/lwt" if client don't send keepalive packet
m:lwt("/lwt", "offline", 0, 0)
m:on("connect", function(con) print ("connected") end)
m:on("offline", function(con) print ("offline") end)
-- on publish message receive event
m:on("message", function(conn, topic, data)
print(topic .. ":" )
if data ~= nil then
print(data)
end
end)
-- for secure: m:connect("192.168.16.9", 1880, 1)
m:connect("192.168.16.9", 1883, 0, function(conn) print("connected") end)
-- subscribe topic with qos = 0
m:subscribe("/topic",0, function(conn) print("subscribe
success") end)
-- publish a message with data = hello, QoS = 0, retain = 0
m:publish("/topic","hello",0,0, function(conn) print("sent") end)
m:close();
-- you can call m:connect again
m = mqtt.Client("clientid", 120, "user", "password");
m:lwt("/lwt", "offline", 0, 0);
m:on("message", function(conn, topic, data) print(topic .. ":" ) if data ~= nil then print(data) end end);
m:connect("192.168.16.9", 1883, 0, function(conn) print("connected") end);
m:connect("impkd.com", 1883, 0, function(conn) print("connected") end);
m:subscribe("/topic",0, function(conn) print("subscribe
success") end);
m:publish("/topic","hello",0,0, function(conn) print("sent") end);
相关文章推荐
- Lua初步
- lua中的逻辑运算符
- lua中的table总结
- lua面向对象编程
- Lua语言初识
- Lua5.0 词法分析
- lua类对象创建继承和使用
- Lua和C++交互详细总结
- Using an LPC-Link2 as an LPC4370 evaluation board
- Lua从入门到精通
- MAC 上搭建lua环境
- lua与C的互相调用
- ulua源码分析
- Lua5.0 语法解析之路
- lua字符串操作
- Lua中的元表与元方法
- Lua 通过 alien 库调用 zlib 压缩/解压
- Lua直接调用动态链接库(DLL或so文件)
- vs2013配置lua lua-5.2.3.tar.gz
- Windows下用vs编译lua