• [问题求助] 小熊派开发板智慧农业扩展板oc_mqtt工程烧录报错!
    ** Programming Started **Info : device id = 0x10016435Warn : STM32 flash size failed, probe inaccurate - assuming 256k flashInfo : flash size = 256kbytesError: auto_probe failedError: jtag status contains invalid mode value - communication failurePolling target stm32l4x.cpu failed, trying to reexamineExamination failed, GDB will be halted. Polling again in 100ms** Programming Failed **shutdown command invoked[2021/9/7 11:27:58] 烧录成功!
  • [问题求助] 小熊派板子STM32L431RC用于测试和验证mqtt协议咨询
    小熊派板子STM32L431RC用于测试和验证mqtt协议,购买板子给的案例中都用的COAP协议,暂只购买了智慧路灯扩展板和ESP8266 wifi模组,请问想研究测试下mqtt,这个板子哪些案例支持啊?需要额外购买些什么扩展模块么?
  • [容器专区] 【AR502H产品】【mqtt功能】编译
    大家好,请教两个关于MQTT的问题:1. 编译32位失败,请问应该怎么操作?(64位已成功)root@c95abd86cd89:/data/test# arm-linux-gnueabi-gcc MQTTClient_publish.c -o MQTTClient_publish_32 -L/lib -lpaho-mqtt3c -lpaho-mqtt3a/usr/lib/gcc-cross/arm-linux-gnueabi/8/../../../../arm-linux-gnueabi/bin/ld: cannot find -lpaho-mqtt3c/usr/lib/gcc-cross/arm-linux-gnueabi/8/../../../../arm-linux-gnueabi/bin/ld: cannot find -lpaho-mqtt3acollect2: error: ld returned 1 exit statusroot@c95abd86cd89:/data/test# pushd /lib/lib /data/testroot@c95abd86cd89:/lib# lsaarch64-linux-gnu  cpp     ld-linux-aarch64.so.1    libpaho-mqtt3c.so.1  modprobe.d  systemd   udevarm-linux-gnueabi  init  ld-linux.so.3        lsb             modules     terminfo  x86_64-linux-gnuroot@c95abd86cd89:/lib# ls -la libpaho-mqtt3c.so.1lrwxrwxrwx 1 root root 21 Aug 19 07:37 libpaho-mqtt3c.so.1 -> libpaho-mqtt3c.so.1.0root@c95abd86cd89:/lib# ln -sf libpaho-mqtt3c.so.1.0 libpaho-mqtt3c.so.1root@c95abd86cd89:/lib# popd/data/testroot@c95abd86cd89:/data/test# arm-linux-gnueabi-gcc MQTTClient_publish.c -o MQTTClient_publish_32 -L/lib -lpaho-mqtt3c -lpaho-mqtt3a/usr/lib/gcc-cross/arm-linux-gnueabi/8/../../../../arm-linux-gnueabi/bin/ld: cannot find -lpaho-mqtt3c/usr/lib/gcc-cross/arm-linux-gnueabi/8/../../../../arm-linux-gnueabi/bin/ld: cannot find -lpaho-mqtt3acollect2: error: ld returned 1 exit statusroot@c95abd86cd89:/data/test# 2. AR502H上的容器是32位的,请问paho-mqtt是否必须使用32位?以上 谢谢!
  • [问题求助] liteos基于mqtt对接emqx服务器过程中遇到的问题
    求助大神,在对接nbiot时,对接信息怎么配置,感谢
  • [容器专区] 【AR502H】【MQTT功能】MQTT远程通信功能
    华为的各位专家:       关于AR502H设备容器内应用与远端MQTT服务器通信的问题,之前咨询过咱这边,见帖子【AR502H产品】【MQTT功能】连接远程MQTT服务器失败,咱这边的回复是AR502H设备当时是不支持MQTT远程通信方式,我想了解的是目前AR502H是否已经可以支持MQTT远程通信方式,因为我们了解到有其他的厂家意思他们的AR502H支持MQTT远程通信,如果现在可以支持,能否给我们这边也支撑一下,以便满足用户需要,谢谢!
  • [问题求助] 小熊派mqtt demo所使用到的QOS等级使多少呢
  • [问题求助] 小熊派使用ESP8266 通过MQTT上云流程是怎么样的
    使用的OC_MQTT 的demo,想查看一下esp8266使用MQTT协议的传输  mcu需要发一些什么AT指令   看了源码但是没有搜到  主要请教一下 mcu和8266 之间使用到了哪些AT 命令 以及流程顺序
  • [问题求助] 【BearPi-HM_Nano】【mqtt功能】连接一直返回MQTTConnect:-1
    【功能模块】【操作步骤&问题现象】1、2、【截图信息】【日志信息】(可选,上传日志内容或者附件)
  • [问题求助] 求 mqtt 怎么对接华为云IoT 示例代码(java)
    求 mqtt 怎么对接华为云IoT  示例代码(java)
  • [问题求助] mdk开发软件,小熊派智慧农业案例,数据上报问题
    【功能模块】使用mqtt协议,基于esp8266,开发软件:MDK5,代码案例:小熊派智慧农业案例,(设备已经注册并激活)通过mqtt.fx工具测试已经完成(可以成功通过mqtt.fx工具向平台上报数据)【操作步骤&问题现象】1、问题是接下来的一步,如何将我的小熊派开发板上面测出的数值上传到云平台,能在在线应用模拟器中显示?(求助大佬!)【截图信息】【日志信息】(可选,上传日志内容或者附件)
  • [问题求助] bearpi-iot 编译下载mqtt例程不成功
    在开发板上,修改智慧农业例程,改为协议为mqtt,通过WiFi连主站,编译不成功,报NO space……
  • [问题求助] 【IotDA产品】【MQTT功能】没订阅的topic也会收到
    【功能模块】设备没订阅"平台查询设备属性"的topic,应用调用查询设备属性的API,设备却能收到topic【操作步骤&问题现象】1、2、【截图信息】【日志信息】(可选,上传日志内容或者附件)
  • [问题求助] qt使用mqtt连接华为IOT平台
    求助:  社区的大咖们,请问有再QT平台下使用MQTT协议连接华为云IOT的案列吗?请不吝赐教。
  • [技术干货] 深入浅出MQTT协议
    物联网(Internet of Things,IoT)时代机器之间(Machine-to-Machine,M2M)的大规模沟通需要发布/订阅(Publish/Subscribe)模式,轻量级、易扩展的MQTT(Message Queuing Telemetry Transport)顺势推进。MQTT是基于二进制消息的发布/订阅编程模式的消息协议,适合需要低功耗和网络带宽有限的IoT场景。协议就是通信双方的一个约定,即,表示第1位传输的什么、第2位传输的什么……。在MQTT协议中,一个MQTT数据包由:固定头(Fixed header)、 可变头(Variable header)、 消息体(payload)三部分构成。MQTT 数据包结构:固定头部 可变头部 消息体固定头(Fixed header),存在于所有MQTT数据包中,表示数据包类型及数据包的分组类标识可变头(Variable header),存在于部分MQTT数据包中,数据包类型决定了可变头是否存在及其具体内容消息体(Payload),存在于部分MQTT数据包中,表示客户端收到的具体内容MQTT固定头:固定头存在于所有MQTT数据包中,其结构如下:Bit 7 6 5 4 | 3 2 1 0byte 1 MQTT数据包类型 | 不同类型MQTT数据包的具体标识byte 2… 剩余长度MQTT可变头:它驻位于固定的头和负载之间。可变头的内容因数据包类型而不同,较常的应用是做为包的标识:Bit 7 6 5 4 3 2 1 0byte 1 包标签符(MSB)byte 2… 包标签符(LSB)Payload消息体位MQTT数据包的第三部分,CONNECT、SUBSCRIBE、SUBACK、UNSUBSCRIBE四种类型的消息 有消息体:CONNECT,消息体内容主要是:客户端的ClientID、订阅的Topic、Message以及用户名和密码。SUBSCRIBE,消息体内容是一系列的要订阅的主题以及QoS。SUBACK,消息体内容是服务器对于SUBSCRIBE所申请的主题及QoS进行确认和回复。UNSUBSCRIBE,消息体内容是要订阅的主题。MQTT协议特点:轻量级的 machine-to-machine 通信协议。publish/subscribe模式。基于TCP/IP。支持QoS。适合于低带宽、不可靠连接、嵌入式设备、CPU内存资源紧张。是一种比较不错手机APP消息推送方案。主题:1.可以通过反斜杠表示多个层级关系。2.主题可以通过通配符进行过滤,但是不允许使用通配符广播。( 可以过滤一个层级,而*只能出现在主题最后表示过滤任意级别的层级)MQTT支持三种不同级别的服务质量(Quality of Service,QoS)为不同场景提供消息可靠性:级别0:尽力而为。消息发送者会想尽办法发送消息,但是遇到意外并不会重试。级别1:至少一次。消息接收者如果没有知会或者知会本身丢失,消息发送者会再次发送以保证消息接收者至少会收到一次,当然可能造成重复消息。级别2:恰好一次。保证这种语义肯待会减少并发或者增加延时,不过丢失或者重复消息是不可接受的时候,级别2是最合适的。级别2所提供的不重不丢很多情况下是最理想的,不过往返多次的确认一定对并发和延迟带来影响。消息类型:CONNECT:客户端连接到MQTT代理TCP连接建立完毕后,Client向Server发出一个Request。如果一段时间内接收不到Server的Response,则关闭socket,重新建立一个session连接。如果一个ClientID已经与服务器连接,则持有同样ClientID的旧有连接必须由服务器关闭后,新建立才能建立。CONNACK:连接确认PUBLISH:新发布消息关于Topic通配符/:用来表示层次,比如a/b,a/b/c。#:表示匹配>=0个层次,比如a/#就匹配a/,a/b,a/b/c。单独的一个#表示匹配所有。不允许 a#和a/#/c。:表示匹配一个层次,例如a/ 匹配a/b,a/c,不匹配a/b/c。单独的一个 是允许的,a 不允许,a/ /b不允许PUBACK:新发布消息确认,是QoS 1给PUBLISH消息的回复PUBREC:QoS 2消息流的第一部分,表示消息发布已记录PUBREL:QoS 2消息流的第二部分,表示消息发布已释放PUBCOMP:QoS 2消息流的第三部分,表示消息发布完成QoS=0:最多一次,有可能重复或丢失。QoS=1:至少一次,有可能重复。Server向Client发布该确认(Client收到确认后删除),订阅者向Server发布确认。QoS=2:只有一次,确保消息只到达一次(用于比较严格的计费系统)。1. Server->Client发布PUBREC(已收到);2. Client->Server发布PUBREL(已释放);3. Server->Client发布PUBCOMP(已完成),Client删除msg;订阅者也会向Server发布类似过程确认。SUBSCRIBE:客户端订阅某个主题SUBACK:对于SUBSCRIBE消息的确认UNSUBSCRIBE:客户端终止订阅的消息UNSUBACK:对于UNSUBSCRIBE消息的确认PINGREQ:心跳Client有责任发送KeepAliveTime时长告诉给Server。在一个时长内,发送PINGREQ,Server发送PINGRES确认。Server在1.5个时长内未收到PINGREQ,就断开连接。Client在1个时长内未收到PINGRES,断开连接。一般来说,时长设置为几个分钟。最大18hours,0表示一直未断开。PINGRESP:确认心跳DISCONNECT:客户端终止连接前优雅地通知MQTT代理Clean Session如果为false(flag=0),Client断开连接后,Server应该保存Client的订阅信息。如果为true(flag=1),表示Server应该立刻丢弃任何会话状态信息。MQTT提供了多个层次的安全特性:网络层:有条件可以通过拉专线或者使用VPN来连接设备与MQTT代理,以提高网络传输的安全性。传输层:传输层使用TLS加密是确保安全的一个好手段,可以防止中间人攻击(Man-In-The-Middle Attack)。客户端证书不但可以作为设备的身份凭证,还可以用来验证设备。应用层:MQTT还提供客户标识(Client Identifier)以及用户名密码,在应用层验证设备。加密:TLS是非常成熟的安全协议,在握手的时候便可以创建安全连接,使得黑客无法窃听或者篡改内容了。使用TLS的时候有以下注意点:1.尽可能使用高版本的TLS。2.验证X509证书链防止中间人攻击。3.尽量使用有CA发布的证书。4.TLS会增加连接时开销,对低运算能力的设备而言是额外的负担,不过如果设备是长连接的话就会避免反复连接的开销。MQTT支持两种层次的认证:传输层:传输层使用TLS不但可以加密通讯,还可以使用X509证书来认证设备。应用层:MQTT支持客户标识、用户名密码以及X509证书,在应用层验证设备。mosquitto是一个开源的轻量级的C实现的MQTT代理,完全兼容了MQTT 3.1和MQTT 3.1.1。mqtt本身是基于TCP的,但是代理对WebSockets的支持,可以支持http。Mosquitto原生支持了TLS加密,生成证书后再配置一下MQTT代理即可。安装 mosquitto,mosquitto-clients源码安装:wget http://mosquitto.org/files/source/mosquitto-1.4.5.tar.gztar zxfv mosquitto-1.4.5.tar.gzcd mosquitto-1.4.5makemake install订阅消息:mosquitto_sub -d -t 'floor-5/temperature'Received CONNACKReceived SUBACKSubscribed (mid: 1): 0发送消息:mosquitto_pub -d -t 'floor-5/temperature' -m '15'Received CONNACKSending PUBLISH (d0, q0, r0, m1, 'floor-5/temperature', ... (2 bytes))接收消息:Received PUBLISH (d0, q0, r0, m0, 'floor-5/temperature', ... (2 bytes))15Sending PINGREQReceived PINGRESP参数:【-t】指定主题,此处为sensor【-v】打印更多的调试信息【-m】指定消息内容在JAVA环境下:在Maven中引用MQTT-Client<dependency><groupId>org.fusesource.mqtt-client</groupId><artifactId>mqtt-client</artifactId><version>1.0-SNAPSHOT</version></dependency><repositories><repository><id>fusesource.snapshots</id><name>FuseSource Snapshot Repository</name><url>http://repo.fusesource.com/nexus/content/repositories/snapshots</url><snapshots><enabled>true</enabled></snapshots><releases><enabled>false</enabled></releases></repository></repositories>建立连接:MQTT mqtt = new MQTT();mqtt.setHost('localhost', 1883); 或者 mqtt.setHost('tcp://localhost:1883');MQTT设置说明setClientId:用于设置客户端会话的ID。在setCleanSession(false);被调用时,MQTT服务器利用该ID获得相应的会话。此ID应少于23个字符,默认根据本机地址、端口和时间自动生成。setCleanSession:若设为false,MQTT服务器将持久化客户端会话的主体订阅和ACK位置,默认为true。setKeepAlive:定义客户端传来消息的最大时间间隔秒数,服务器可以据此判断与客户端的连接是否已经断开,从而避免TCP/IP超时的长时间等待。setUserName:服务器认证用户名。setPassword:服务器认证密码。setWillTopic:设置“遗嘱”消息的话题,若客户端与服务器之间的连接意外中断,服务器将发布客户端的“遗嘱”消息。setWillMessage:设置“遗嘱”消息的内容,默认是长度为零的消息。setWillQos:设置“遗嘱”消息的QoS,默认为QoS.ATMOSTONCE。setWillRetain:若想要在发布“遗嘱”消息时拥有retain选项,则为true。MQTT.connectBlocking方法建立并返回一个阻塞API连接。BlockingConnection connection = mqtt.blockingConnection();connection.connect();使用publish方法发布消息:connection.publish('foo', 'Hello'.toBytes(), QoS.AT_LEAST_ONCE, false);利用subscribe方法订阅多个主题:Topic[] topics = {new Topic('foo', QoS.AT_LEAST_ONCE)};byte[] qoses = connection.subscribe(topics);利用receive和ack方法,获取并应答消息:Message message = connection.receive();System.out.println(message.getTopic());byte[] payload = message.getPayload();message.ack();结束连接:connection.disconnect();文章转载于http://www.360doc.com/content/17/1109/19/47869400_702448421.shtml
  • [技术干货] MQTT--取消订阅报文和断开连接报文
    取消订阅报文固定报头的结构笔者不都说了。主要记得固定报头的QOS为1就行了。笔者把官方的列表贴过来了。如下我们知道固定报头分三部分,一个是报文类型,一个是报文标示。一个是剩余长度。取消订阅报文类型的值为10。然后我们看QOS 为1。对应的二进制为10100010。Remaining Length为剩余长度,同样子二进制为八位。所以固定报头的二进制一定是10100010  xxxxxxxx。 xxxxxxxx表示剩余长度的二进制。后面笔者还会抓包来看。可变报头里面就一个消息ID的项。没有其他的。有效载何里面存放的是主题列表。就是用于取消订阅的主题列表。如下笔者不知道到现还有没有人看不懂这种列表的。Topic Filter为主题过滤,即是主题名。而byte 1类似这种表示每一元素。比如上面举列中的Topic Filter是有五元素组成的。后面是每一个元素的二进制。MQTT 文档里面对取消订阅报文并没有特别的要求。也只是删除的动作做了一些要求。删除这个订阅的时候,就必须停止发送任何信息了。同时如果有正在分送中的QOS 1 QOS2的信息就必须要完成才行。当然也可以分送准备的缓存信息。上面我们看到了取消订阅报文的QOS为1。所以会有一个回应。即是取消订阅确定报文(UNSUBACK)。取消订阅确定报文(UNSUBACK)只有固定报头和可变报头,可变报头里面只有一个消息ID的项。没有什么可说的。相关的包取消订阅报文取消订阅确定报文我们可以看到取消订阅报文有多么的简单,但是还是不如断开连接报文来的简单。因为断开连接报文没有可变报头,没有有效载荷。就一个固定报头。没有错就是一个固定报头。不多说,笔者把固定报头的列表贴出来。如下上面的列表就是断开连接报文的全部。断开连接报的结构是最简单的。但是文档中还是指出了几点要注意的。1)判断固定报头中的标示部分必须是0000,如果不是0就断开连接。2)客户端不能在通过该连接发送任何信息了。3)服报端要删除与当前连接关联的未发布的遗嘱消息。同时如果客户端没有断开的话,服务端必须断开。断开连接报文转载于http://www.360doc.com/content/18/0320/21/16915_738834856.shtml
总条数:246 到第 页
上滑加载中