mqtt_udp下载mqtt_udp源代码下载

mqtt_udp

其他类别

Packages

下载

MQTT/UDP

UDP上的MQTT的Simpified版本：网络是经纪人！

注意其他回购：https：//gitverse.ru/dzavalishin/mqtt_udp

参见俄语版本 /存在

MQTT是一种可爱的简单协议，非常适合物联网和类似内容。

但这可能更简单，并且仍然非常有用：MQTT/UDP只是在UDP上广播的MQTT发布数据包。

MQTT/UDP是

非常简单
非常快，最小的潜伏期
不包括经纪人（单点失败）
降低网络流量（每个套管完全发送给全部一次）
合理可靠的（如果我们将其用于传感器，通常每隔几秒钟左右重新安装数据）
即使在无法支持TCP的硬件上也可以支持 - 实际上，只需要发送UDP
零配置 - 传感器节点不需要设置，它只是广播数据。（而且，如果您仍然需要它，MQTT/UDP支持通过网络的远程配置。）
支持数字签名

用于进一步阅读

MQTT/UDP Wiki
文档

此存储库包含

一种简单的MQTT/UDP实现，以某些流行的编程语言实现。
Pyton中最简单的MQTT/UDP桥实现。
将数据从MQTT/UDP发送到OpenHab的工具
一个调试应用程序，用于转储MQTT/UDP流量（工具/查看器）。
其他工具和公用事业

如果您想帮助一个项目

随意：

用您喜欢的编程语言添加实现
写一座经典MQTT协议的桥梁（我们在这里用Python编写了非常简单的桥梁）
使用MQTT/UDP支持扩展您喜欢的MQTT经纪人或IoT系统（OpenHab？）
根据MQTT规格检查MQTT/UDP规范/实现。我们必须在可能的情况下兼容。

这真的很容易。

避免MQTT/UDP的原因

您需要转移长时间有效载荷。在某些系统大小上，UDP数据报是有限的。
您需要知道是否肯定交付了数据报。 UDP是不可能的。但是，可靠的交付子系统正在开发，并将很快使用。

扩展MQTT/UDP的方法

在数据包中添加某种签名以防止数据欺骗似乎是合理的。实际上，已经为Java实施了，C和Pythin很快就会出现。
广播不是传输数据的最佳方法。多播要好得多。尽管多播在IoT OS或监视器中没有得到很好的支持。

快速开始说明

克隆存储库到本地磁盘
阅读howto文件

支持工具

该存储库包含支持MQTT/UDP集成和测试的工具：

GUI工具以显示工具/查看器目录中传输的数据的当前状态；另请参见查看器帮助页面。
python3/示例目录中的随机数据生成器（Random_to_udp.py）
发送/检查工具，以序列编号的数据包。请参阅seq_storm_send.py和seq_storm_check.py in lang/python3/示例目录目录
Wireshark解剖器查看Lang/Lua/Wireshark目录中网络上的协议数据

代码示例

Python

发送数据：

 import mqttudp . engine

if __name__ == "__main__" :
    mqttudp . engine . send_publish ( "test_topic" , "Hello, world!" )

听数据：

 import mqttudp . engine

def recv_packet ( ptype , topic , value , pflags , addr ):
    if ptype != "publish" :
        print ( ptype + ", " + topic + " t t " + str ( addr ) )
        return
    print ( topic + "=" + value + " t t " + str ( addr ) )

if __name__ == "__main__" :
    mqttudp . engine . listen ( recv_packet )

下载PYPI软件包

爪哇

发送数据：

 PublishPacket pkt = new PublishPacket ( topic , value );
pkt . send ();

听数据：

 PacketSourceServer ss = new PacketSourceServer ();
ss . setSink ( pkt -> { System . out . println ( "Got packet: " + pkt ); });

下载jar

c

发送数据：

 int rc = mqtt_udp_send_publish ( topic , value );

听数据：

 int main ( int argc , char * argv [])
{
    ...

    int rc = mqtt_udp_recv_loop ( mqtt_udp_dump_any_pkt );

    ...
}

int mqtt_udp_dump_any_pkt ( struct mqtt_udp_pkt * o )
{

    printf ( "pkt %x flags %x, id %d" ,
            o -> ptype , o -> pflags , o -> pkt_id
          );

    if ( o -> topic_len > 0 )
        printf ( " topic '%s'" , o -> topic );

    if ( o -> value_len > 0 )
        printf ( " = '%s'" , o -> value );

    printf ( "n" );
}

卢阿

发送数据：

 local mq = require " mqtt_udp_lib "
mq . publish ( topic , val );

听数据：

 local mq = require " mqtt_udp_lib "

local listener = function ( ptype , topic , value , ip , port )
    print ( " ' " .. topic .. " ' = ' " .. val .. " ' " .. "	from: " , ip , port )
end

mq . listen ( listener )