硬件设备如何订阅mqtt的topic

如题,我已经在某云开发平台通过模拟测试发布和订阅流程,采用mqtt协议。现在我要如何和设备开发那边人说让他们也订阅topic?

0

4个回答

设备里面 嵌入 C 代码,通过 C 代码里面的 MQTT 协议来实现主题订阅功能

1
u013430758
王玉石深海殇 回复long361800: 已采纳
11 个月之前 回复
long361800
龙鑫科技 回复u013430758: 您好,能不能采纳我的答案? 我也是很用心的在回答你的问题哦。
大约一年之前 回复
u013430758
王玉石深海殇 感谢您的解答!
大约一年之前 回复

我最近在做类似的项目,用的是阿里云平台,topic添加可以在阿里云平台自己添加,建议你仔细研读一下控制台手册。

1
 你把 主题名 告诉他, 他里面用 C 函数就能实现订阅功能
1
u013430758
王玉石深海殇 谢谢
大约一年之前 回复
0
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
MQTT topic匹配规则基础
主题层级分隔符  / :     用于分割主题层级,/分割后的主题,这是消息主题层级设计中很重要的符号。   比方说: aaa/bbb和  aaa/bbb/ccc 和aaa/bbb/ccc/ddd  ,这样的消息主题格式,是一个层层递进的关系,可通过多层通配符同时匹配两者,或者单层通配符只匹配一个。  这在现实场景中,可以应用到:公司的部门层级推送、国家城市层级推送等包含层级关系的场景。
MQTT主题Topic讲解
参考:https://www.cnblogs.com/hayasi/p/7792191.html 如果传统的通信方式是客户端和服务端之间一般就直接传输信息。但是MQTT的通信方式是通过发布/订阅的方式进行的。笔者不知道他是否跟设计模式中的发布订阅模式有没有关系。可是他们思想却有一点相似之处。 客户端知道服务上有很多个主题。就好比如说有很多消息的分类一样子。有社会新闻、体育讲坛等。那么客户端只要...
利用MQTT一次订阅多个主题
利用MQTT一次订阅多个主题 在做智能家居相关的应用时候,需要利用订阅所有设备的主题。这个时候我们需要利用mqtt的通配符的功能,一个订阅可能包含特殊字符,允许你一次定义多个主题。主题层次分隔符被用来在主题中引入层次。多层的通配符和单层通配符可以被使用,但他们不能被使用来做发布者的消息。 1.主题层级分隔符/ /被用来分割主题树的每一层...
Flask--Javascript订阅多个主题
一、JavaScript基础知识:对象(object) 在获取到MQTT服务通过websocket推送过来的message之后:<script src="https://cdn.bootcss.com/paho-mqtt/1.0.2/mqttws31.min.js"></script> <script type="text/javascript"> client = new Pa
node.js实现mqtt 发布/订阅 消息到主题
node.js实现mqtt 发布/发送 消息到主题 mqtt是啥?我的博客有写这个东西:传送门 安装 首先你要安装node.js和npm 教程传送门 随后找个文件夹执行 命令行 安装mqtt模块; npm install mqtt 如果需要服务端 执行 npm install mosca 使用 mqtt的文档 以下代码中有些参数...
Android MQTT 发布订阅多个主题
 公司是做Zwave智能家居的,以前和服务器连接是TCP长连接,最近想将服务器切换为MQTT服务器,做到主机与主机之间实现数据互通,这样就能以组网的方式,灵活的搭建使用场景,做到从家装到工装的转变,甚至跨平台的控制。从理论上是可行的,实际上又要开始填坑了。 先说下大概的使用场景,如一个家庭A(别墅型),面积大,有五台用来控制设备的主机(ABCDE),每台主机有属于其自己的设备,目前的是可以直接控...
MQTT学习笔记(5)报文分析之SUBSCRIBE
SUBSCRIBE(订阅主题) 含义:客户端向服务器该报文用于订阅一个或者一类topic或者多类tpoic。 一.固定报头 0x82 剩余长度 二.可变报头 报文标识符 三.payload 主体过滤器(Tpoic Filter) 服务质量要求(Qos) … 注:payload可以是多个Tpoic Filter,但是每个Tpoic Filter后面要有一个Qos ...
MQTT topic 设计实践
参考: MQTT Essentials Part 5: MQTT Topics &amp;amp; Best Practices 5 Best Practices for Creating Topic Structure - Xively Blog 结合参考和自己的实践: 不要在最前面加 / 比如: /home/device/light, 等于在最前面有...
如何实现ActiveMq的Topic的持久订阅
原文地址:http://www.mytju.com/classcode/news_readNews.asp?newsID=486   (1)使用queue,即队列时,每个消息只有一个消费者,所以,持久化很简单,只要保存到数据库即可。然后,随便一个消费者取走处理即可。某个消费者关掉一阵子,也无所谓。(2)使用topic,即订阅时,每个消息可以有多个消费者,就麻烦一些。首先,假设消费者都是普通...
ESP8266通过MQTT订阅主题并推送数据到ONENET
板子自带: 三颗按钮【1.flash, 2.reset, 3.user】 DHT11 温湿度传感器 / DHT12 RGB 三色LED 单色LED 蜂鸣器 ESP8266-12E/F 固件下载:http://www.micropython.org/download#esp8266 源代码仓库:https://github.com/mokton/ESP8266_MQTT_OneNet 【最新】 请移步Github查看源代码,持续更新中,欢迎 Star 主要使用了两个库: 1. urequests.py 实现 HTTP 协议 2. simple.py 实现 MQTT 协议 其他文件: 1. boot.py 2. main.py 应用入口文件,启动服务 3. chipid.py 获取ESP8266EX芯片的ID号 4. wifi.py 设置WIFI连接 5. register.py 注册设备并返回设备PID和APIKEY 6. mqtt.py MQTT业务封装 功能说明: 1. 连接OneNet并自动注册设备 2. 自动订阅主题 “PID-FlashID-sub",PID和FlashID会被替换成设备ID和Chipid 3. 自动上传板载DHT11温湿度传感器的值 4. mqtt指令主要用来控制Pin的高低电平 格式: pin n state n 有效值为 0、1、2、3、4、5、12、13、14、15、16 state 有效值为 on、off、toggle 举例: pin 4 off 将给pin4引脚置低电平,可以看到ESP8266板载的LED灯点亮了(pin4默认被拉高,led低电平点亮)
mqtt+ActiveMQ用发布订阅实现点对点推送
使用语言:java 消息中间件:activemq 用到工具:git、maven、任意文本编辑器 目录 目录 发布到订阅流程图 实现点对点 点对点测试程序 发布到订阅流程图 Created with Raphaël 2.1.2开始消息生产者通过session发送到指定topicbroker根据subscriber的id找出订阅者,并推送消息过去订阅者监听到数据并执...
MQTT topic匹配规则
主题层级分隔符 “/”: 表示层级关系 单层通配符 “+”: 订阅消息时使用,匹配一层主题如 a/+ 匹配诸如 a/b a/c 但是不能匹配 a/b/c,特别的单独的+可以匹配所有单层主题 多层通配符”#”: 订阅消息时使用,匹配零或层主题如 a/# 匹配诸如 a/b a/b/c a ,特别的#单独使用匹配所有。 &amp;nbsp; 注:使用通配符时需要保证创建的policy里有相...
MQTT订阅发布
使用C#语言,实现了MQTT的发布和订阅,订阅后可与自动接收信息;点击发布按钮可以发布对应信息
专用于MQTT发布/订阅规则专用数据结构SDK(发布/订阅规则匹配目录树)
   概述 本文讲述我公司MQTT订阅规则目录树SDK的技术特点、功能描述、应用领域等内容。    版权说明 本开发包的32位版本免费,用户可用于学习、测试、商业用途,没有功能、性能上的限制,可自由复制、传播。   本开发包的64位版本收费,需要向我公司购买使用授权,未经授权不得使用。   Windows 32位SDK下载地址: https://download.csdn.net/...
我的mqtt协议和emqttd开源项目个人理解(18) - 一个客户端sub很多主题和数据,出现宕机?使用本地共享订阅解决!
EMQ中CPU是公平分配给MQTT会话,大量pub消息到一个订阅,订阅不会拿到更多cpu,最终导致消息累积,内存溢出宕机。 最好的解决办法是分组订阅,把消息打散,多个客户端订阅。 问:请问一下,我现在的业务就是只使用一个sub,主题是\hello\#,去订阅数万个终端消息。请问针对这个问题,如何来优化业务逻辑?可以通过增加sub的方式吗?即把数万终端分成几个小组,每小组往一个主题p...
Apollo如何通知/订阅主题topic
How to advertise and subscribe a topic 导读 众所周知,Apollo是基于ROS开发的,所以其底层也是基于消息的机制进行节点通信的。但是它在ROS的基础上做了一些改动,如下: P2P——由于原生ROS的消息机制是通过主节点(Master)分发数据来实现的,这样一个强中心化的结构始终存在一个Master意外导致系统奔溃的隐患,为了解决这个问题,A...
MQTT+springboot 订阅/发布 多主题
Springboot集成MQTT,订阅发布一体,提供接口可发布随意主题。
Android使用MQTT实现消息发布与订阅
关于MQTTMQTT中文文档MQTT GitHubMQTT协议规范MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议,有可能成为物联网的重要组成部分。该协议支持所有平台,几乎可以把所有联网物品和外部连接起来,被用来当做传感器和制动器(比如通过Twitter让房屋联网)的通信协议。MQTT应用通过MQTT协议,目前已经扩...
mqtt基于paho的消息订阅接收的JAVA代码
看到网上的部分代码,对于订阅主题后,使用mqttCallBack接口来接收消息,虽然这种方法也可以接收到消息,但是mqtt Paho提供了正规的方法去接收消息,这里分享一下自己的demo。 使用callback接口订阅类: import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken; import org.eclipse.paho.cl...
springboot activemq 2 持久化消息 与 持久化订阅
接着上一节http://blog.csdn.net/cons_step_by_step/article/details/78300427。 改动1.减少springboot重复创建session的问题 jmsTemplate的地方加入了CachingConnectionFactory,这样配置可以 @Bean(name = "myJmsTemplate") public JmsTem
阿里云MQTT 客户端收发 MQTT 消息(使用一个设备控制另一个设备)
https://help.aliyun.com/document_detail/44874.html?spm=a2c4g.11186623.6.721.qxegRK 1保证只有一组用户AccessKey,怕冲突其他的可暂时禁用 (踩过的坑:域名必须是这个格式tcp://mqtt-cn-4590pc20t03.mqtt.aliyuncs.com:1883) (踩过的坑:发送的消息分为两种,一是...
ro接收两个topic并发布消息
有两个sub,同时发布一个topic,采用ros多线程方式解决。
JMS学习十一(Spring+ActiveMQ消息持久化,Topic持久化订阅)
消息持久化就是将消息保存到磁盘,这样的好处就是如果服务挂了,则消息还保存在磁盘不会丢失,服务起来后还能找到消息并在此发送,消息的持久化和消息的发送模型是没有关系的。 消息持久化的配置很方便的,所以其他的那些就不写出来了,可以看看上一篇文章中的同步异步实现方式。这里只把持久化配置的列出来。 <bean class="org.springframework.j
MQTT 客户端收发 MQTT 消息
本文主要介绍如何使用 MQTT 客户端收发 MQTT 消息,并给出示例代码供前期开发测试参考,包括资源创建、环境准备、示例代码、注意事项等。 注意: 本文给出的实例均基于 Eclipse Paho Java SDK 实现,SDK 下载请参见 MQTT 接入准备。如使用其他第三方的客户端,请适当修改。 1. 资源创建 使用 MQ 提供的 MQTT 服务,首先需要核实应用中使用的 Topic ...
MQTT--Python进行发布、订阅测试
http://blog.csdn.net/yannanxiu/article/details/52716997
mosquitto 基于MQTT消息推送
mosquitto note 基于MQTT消息推送[https://mosquitto.org] 目的 * 要解决的问题是:给Android手机做消息推送 * 不使用第三方的SDK,如极光推送,百度云推送,信鸽 这些都不能用 * 自已搭建消息推送后台 模块 * 代理端(中转消息,守护进程) mosquitto * 发送消息客户端 mosquitto_pub * 接收消息客户端 m...
MQTT订阅主题就会收到消息的问题--Retained
MQTT订阅主题就会收到消息的问题–Retained 之前的项目使用了mqtt消息队列作为第三方消息的接收和发送,本地作为mqtt的订阅者也作为发送者。 本地接受到mqtt订阅的消息,作处理后再重新发送到云服务端。这里遇到一个坑(其实是自己造成的),在订阅主题后就会收到mqtt服务器发送的消息,查找资料后发现是在publish某条数据时,设置了Retained(默认是ture,这里选择后为fals...
paho mqtt 重连后无法订阅问题
参考代码 https://github.com/eclipse/paho.mqtt.c/blob/master/src/samples/paho_c_sub.c 方法1: conn_opts.cleanstart = 0; 缺点: 当我把mqtt server 清除数据重新部署后,mqtt client reconnect后,无法自动订阅;   方法2:   conn_opts...
c#版MQTT客户端
c#版MQTT客户端,包含topic订阅及消息发布。
SpringBoot2.0集成MQTT功能之消息订阅处理
       距离上一篇【SpringBoot2.0集成MQTT消息推送功能】https://blog.csdn.net/qq_41018959/article/details/80592444博客已经过去有一段时间了,最近比较忙,也没时间整理【SpringBoot2.0集成MQTT消息之消息订阅处理】篇章,刚好早上闲下来,就趁这个机会整理一下。        网上资料还是蛮多的,但也不是很全面...
使用MQTT协议的订阅发布模式,实现从服务器推送消息到客户端功能。
1、服务端需要先使用Apollo作为代理服务器来发消息,参考此文即可搭建: https://blog.csdn.net/marrn/article/details/71141122?utm_source=itdadao&amp;amp;utm_medium=referral 2、PC端通过java代码,通过MQTT协议来连接服务器,然后在根据界面动作 ,发布消息; 3、手机端设置相同的连接主题参数,订阅消...
通俗的来理解MQTT中的发布和订阅
通俗的来理解MQTT中的发布和订阅 刚开始接触物联网,IOT,MQTT,感觉傻傻的什么都分不清楚,对于MQTT各方的身份和功能也无法理解,直到有一天,真正亲自去使用了MQTT服务器,才理解其中的奥妙。 在不了解MQTT通信原理以及程序架构的情况下,不要先看代码,否则会无比痛苦,还是先通过MQTT通信工具测试一遍通信过程。这样理解起来就比较直观。 ...
mqtt订阅和发送及mqttws31.js
mqtt一次订阅多个主题,及发送的,分装函数。以及所需要的js
7/5 javaweb里运行mqtt,订阅推送
1、之前用http发送设备数据的时候,用到的证书路径:当web发布后是默认从tomcat/bin为根路径去找文件的,然而在eclipse调试时,默认的根路径是eclipse的安装位置,所以要更改一下根路径双击server——在overview里找到open launch configuration——Arguments——WorkingDirectory的Other更改一下,改成tomcat/bi...
MQTT之阿里云接受推送消息
在做项目时遇到阿里云的MQTT信息接受和推送服务,整了好久没正好,最后一位大神给了一个他新写的DEmo,一用就OK,和大家分享下。 大神的MQTT库的github地址https://github.com/ckrey/MQTT-Client-Framework,你把它用Cocoapods编译一下就行了。 下面是代码的注册信息,特别提示我这里的self.KClientID,self.KTo
MQTT调试工具
MQTT调试工具,可以十六进制显示和ASCII显示,可以订阅MQTT topic
MQTT发布订阅程序完整代码
工具类,包含有发布者方法和订阅者方法。 package cn.com.bonc.wholeCode; import org.eclipse.paho.client.mqttv3.*; import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence; import java.util.UUID; /** * mqtt的发布和...
esp8266创建MQTT任务,订阅(接收)和发布(发送)信息
1、本例程所用的SDK版本:ESP8266_RTOS_SDK-1.4.x 2、创建MQTT任务,连接MQTT服务器,订阅(接收)和发布(发送)信息 3、具有UART发送和接收功能 4、具有Smartconfig功能,可通过按键和UART命令触发一键配置连接WIFI
用MQTT.fx检查发布和订阅的mqtt消息
使用方法 使用方法 MQTT.fx是一个简单的测试mqtt通信的工具,有美观的图形化操作界面。 实际上MQTT.fx并不是一个抓包工具,它也是通过一对账户名和密码连接到mqtt broker,扮演一个mqtt client的角色。不过通常让它使用管理员账号,有权限订阅所有topic,监听mqtt broker上传输的所有消息。 安装该软件后,点击齿轮按钮添加一个mqtt broke...
Nodejs使用MQTT做客户端订阅与发布
Nodejs使用MQTT做客户端订阅与发布,以下为示例代码 var mqtt = require('mqtt'); var url="mqtt://"+myconfig.msgCenter.host+":"+myconfig.msgCenter.port; var options={ username:myconfig.msgCenter.username, password:myc