首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

如何在EMQTT 2.0.7中进行“共享”订阅?

在EMQTT 2.0.7中进行"共享"订阅,可以通过使用EMQTT的订阅插件来实现。EMQTT是一个开源的MQTT消息代理服务器,用于实现物联网设备之间的通信。

"共享"订阅是指多个客户端可以共享同一个订阅主题,当有消息发布到该主题时,所有共享订阅的客户端都会收到该消息。下面是在EMQTT 2.0.7中进行"共享"订阅的步骤:

  1. 安装EMQTT服务器:首先,需要安装和配置EMQTT服务器。可以参考EMQTT官方文档进行安装和配置。
  2. 启用订阅插件:EMQTT提供了一个订阅插件(emq_auth_shared_sub),用于实现"共享"订阅功能。在EMQTT配置文件中,找到plugins部分,并确保订阅插件已启用。
  3. 配置共享订阅规则:在EMQTT配置文件中,找到auth.shared_sub.rules部分,并配置共享订阅规则。共享订阅规则定义了哪些主题可以进行共享订阅。可以使用通配符来匹配多个主题。
  4. 重启EMQTT服务器:完成配置后,需要重启EMQTT服务器使配置生效。
  5. 客户端进行共享订阅:在客户端代码中,使用EMQTT的订阅API进行共享订阅。客户端可以订阅共享订阅规则中定义的主题,以接收相关消息。

EMQTT的共享订阅功能适用于需要多个客户端同时接收同一主题消息的场景,例如实时监控系统、群聊应用等。

腾讯云提供了物联网通信(IoT Hub)产品,可以与EMQTT集成,实现设备与云端的消息通信。您可以通过腾讯云物联网通信产品了解更多相关信息:腾讯云物联网通信产品介绍

请注意,本回答仅针对EMQTT 2.0.7版本中的"共享"订阅功能,其他版本可能存在差异。

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

原 荐 EMQ百万级MQTT消息服务(小技巧)

附上: 喵了个咪的博客:w-blog.cn EMQ官方地址:http://emqtt.com/ EMQ中文文档:http://emqtt.com/docs/v2/guide.html 1.ACL鉴权规则化...,并且也可以监听消息/A/get 2.共享订阅 关于队列常见的使用中也有这样的场景,一条消息希望被多个监听程序接收到,可能的场景如下: 一个程序处理,一个程序记录日志分别处理 批量推送...| --Msg3--> Subscriber3 --------- 在默认情况下有多个客户端监听一个事件时会受到同样的消息,但是怎么共享订阅呢...EMQ共享订阅支持两种使用方式: $queue/ :$queue/topic $share// :$share/group/...topic 以上两种都可以实现共享订阅(笔者测试下来值通过了share来完成了订阅),订阅和监听 多个服务端监听 $share/group/topic 客户端向 topic 发送消息 3.Qos 0

1.4K40

EMQ百万级MQTT消息服务

EMQ官方地址:http://emqtt.com/ EMQ中文文档:http://emqtt.com/docs/v2/guide.html 1.ACL鉴权规则化 在正常业务使用下对于客户端的行为可以使用...ACL进行限制,比如A客户端只能订阅 /A/get 队列消息和向 /A/set 发布内容 但是在MYSQL里面处理这样的鉴权就需要写入两条记录,如果设备量有一百万数据库就要承担两百万条鉴权数据量会大大影响数据库的性能...,并且也可以监听消息/A/get 2.共享订阅 关于队列常见的使用中也有这样的场景,一条消息希望被多个监听程序接收到,可能的场景如下: 一个程序处理,一个程序记录日志分别处理 批量推送...| --Msg3--> Subscriber3 --------- 在默认情况下有多个客户端监听一个事件时会受到同样的消息,但是怎么共享订阅呢...EMQ共享订阅支持两种使用方式: $queue/ :$queue/topic $share// :$share/group/topic 以上两种都可以实现共享订阅(笔者测试下来值通过了

2.3K40

EMQ百万级MQTT消息服务(介绍和搭建)

先上节了解完MQTT之后我们需要选择一个MQTT服务端,在MQTT官方推荐下找了找最后选择了使用EMQ来进行服务端实现,EMQ有什么优势可以在官方推荐的那么多的服务器实现中脱颖而出,本章就来和大家一起慢慢了解...EMQ相关的特性 附上: 喵了个咪的博客:w-blog.cn EMQ官方地址:http://emqtt.com/ EMQ中文文档:http://emqtt.com/docs/v2/guide.html...MQTT 是轻量的(Lightweight)、发布订阅模式(PubSub) 的物联网消息协议。...当笔者要选择一个服务端的时候考虑了如下几点: 能够集群化来应对大量的设备 能够进行精细的权限控制(MQTT不管是对于服务器和终端来说都是发布和订阅所以需要进行权限的限制不是所有人都能给设备发送消息) 社区完善有团队持续支持...> mkdir -p /app/install && cd /app/install > wget http://emqtt.com/static/brokers/emqttd-centos7-v2.3.5

2.7K50

从零开始上手 MQTT over QUIC:快速体验下一代物联网标准协议

with NanoSDKnng_mqtt_quic_client_open(&socket, url);消息示例代码请参考:NanoSDK 编译后可以通过以下命令连接 EMQX 5.0 的 14567 端口进行测试...图片在需要与云端 MQTT 服务进行数据同步的各种物联网场景中,通过 NanoMQ 的多协议接入能力,您可以将其作为边缘消息总线和统一的数据空间,统一汇聚诸如 HTTP、MQTT 3.1.1/5.0、WebSocket...选项以使用 QUIC 协议发起连接并进行订阅,此处使用 10 个客户端订阅 t/1 主题:..../emqtt_bench sub -p 14567 --quic -t t/1 -c 10新开另一个窗口,同样使用 QUIC 协议连接并进行发布测试:....在后续的推送中,我们也将对这些特性背后的技术原理以及最佳实践进行详细解读,敬请关注。版权声明: 本文为 EMQ 原创,转载请注明出处。

87740

原 EMQ百万级MQTT消息服务(分布式集群)

EMQ的集群模式很粗暴,只需要把EMQ服务关联在一起然后负载均衡就可以达到集群的效果,这样就算面对1000CK问题也迎刃而解 附上: 喵了个咪的博客:w-blog.cn EMQ官方地址:http://emqtt.com.../ EMQ中文文档:http://emqtt.com/docs/v2/guide.html 1.集群方式接受 Erlang/OTP 最初是爱立信为开发电信设备系统设计的编程语言平台,电信设备(路由器、接入网关...,所在节点订阅成功后广播通知其他节点:某个主题(Topic)被本节点订阅。...MQTT 客户端发布消息时,所在节点会根据消息主题(Topic),检索订阅并路由消息到相关节点。...static node list cluster.static.seeds = emq@192.168.2.111,emq@192.168.2.112 为了安全Erlang 节点间通过一个相同的 cookie 进行互连认证

2.4K80

规则引擎集成新的可观测性框架

十月,EMQX 在产品质量和用户体验方面进行了进一步提升,同时 QUIC 相关开发工作也在持续进行中。此外,EMQX Cloud 在订阅渠道、部署地区、操作体验等方面均有更新。...我们解决了共享订阅的问题,以及 HTTP auth 与 Webhook 中 HTTPS 长期连接时可能导致的请求大量超时问题。...QUIC 更新quicer 中多条流(Stream)传输的开发工作已经接近尾声,经过一些调整后我们会将其引入 EMQX 以及 EMQ 开发的 Erlang 客户端库 emqtt。...完成注册开通之后,EMQX Cloud 会将账单发送到 AWS 进行记账和扣费。通过 AWS Marketplace 开通的账号依然可以获取 14 天的免费部署试用。...控制台功能优化新增在客户端详情中管理订阅的功能。在监控 - 客户端,点击客户端名称进入详情,可以在详情下方看到订阅管理显示了当前客户端订阅的主题,可进行添加和删除。

52750

【玩转ESP32】13、esp32 mqtt基础

1、前言 MQTT(消息队列遥测传输)是ISO 标准(ISO/IEC PRF 20922)下基于发布/订阅范式的消息协议。...MQTT是一个基于客户端-服务器的消息发布/订阅传输协议。MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛。...在很多情况下,包括受限的环境中,:机器与机器(M2M)通信和物联网(IoT)。其在,通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。 2、 架构 ?...服务器的消息接收由PUBACK消息进行确认,如果通信链路或发送设备异常,或者指定时间内没有收到确认消息,发送端会重发这条在消息头中设置了DUP位的消息。 QoS 2:只分发一次。...MQTTPacket/ ESP8266/ESP32的客户端:https://github.com/tuanpmt/esp_mqtt 基于elang的客户端:https://github.com/emqx/emqtt

1.2K40

动手写物联网平台(二、物联网和MQTT协议简介)

虽然HTTP是网页的事实标准,不过机器之间(Machine-to-Machine,M2M)的大规模沟通需要不同的模式:之前的请求/回答(Request/Response)模式不再合适,取而代之的是发布/订阅...MQTT是一个基于客户端-服务器的消息发布/订阅传输协议。MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛。...在很多情况下,包括受限的环境中,:机器与机器(M2M)通信和物联网(IoT)。其在,通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。 ? ?...常用MQTT服务器有:EMQTT,Mosquitto,Apollo,EMQ,EMQX apache的ActiveMQ,emtqqd,HiveMQ,Emitter,Mosquitto,Moquette等等...或者现成的MQTT服务器,阿里云,百度云,华为云等公用的云平台提供的MQTT服务。 EMQ是目前开源社区最为流行的MQTT Broker。

1.5K10

MQTT协议,终于有人讲清楚了

在很多情况下,包括受限的环境中,:机器与机器(M2M)通信和物联网(IoT)。 其在,通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。...除标准版外,还有一个简化版MQTT-SN,该协议主要针对嵌入式设备,这些设备一般工作于TCP/IP网络,:ZigBee。...SUBACK,消息体内容是服务器对于SUBSCRIBE所申请的主题及QoS进行确认和回复。 UNSUBSCRIBE,消息体内容是要订阅的主题。...:http://emqtt.io/ 本文将使用 Mosquitoo 进行测试,进入到安装页面,下载自己电脑的系统所适配的程序; ?...3.2 MQTT Client 服务器搭建好了,下面就是开启客户端,进行发布和订阅,这样就可以传输相应的消息。

2.9K70

原 EMQ百万级MQTT消息服务(ACL鉴权)

但是投入到业务使用中还面临着一些问题,当然MQTT设计之初也考虑了这一点,比如不是任何一个客户端都能链接到服务器和限制客户端能够对topic操作的权限 附上: 喵了个咪的博客:w-blog.cn EMQ官方地址:http://emqtt.com.../ EMQ中文文档:http://emqtt.com/docs/v2/guide.html 1.ACL鉴权 先说实际场景,我们需要监听每一台设备的链接和断开事件等EMQ的系统行为,这样的事件当然不是任何一个连接到服务器的终端..."}, pubsub, ["$SYS/#", "#"]}. %% 拒绝用户订阅'$SYS#'与'#'主题 {deny, all, subscribe, ["$SYS/#", {eq, "#"}]}....V10115125355235","username":"cline","reason":"normal","ts":1521689801} 2.MYSQL实时配置ACL 一般来说我们不会使用外网IP来进行限制...,有限会选择用户来进行限制行为,官方提供如下方式来进行用户和ACL验证的存储: (对应的配置方式可以参考官网文档) 配置文件和命令 LDAP HTTP MySQL Postgre Redis MongoDB

2.2K40

没想到学了 MQTT 后,竟然有那么多疑问

在 AI 和区块链的热潮过去之后,物联网很有可能成为下一个风口,在风口到来之前,提前进行一些知识储备,是很有必要的。 纵观人工智能的发展路线我们可以看到,人工智能近年来之所以能够突飞猛进。...当有新订阅者的时候, Broker 会把保存的这条消息发给新订阅者(Retained 标识为 1)。 Q4. 怎么能让发送数据的一方快速收到指定设备的回应数据?...在服务器端创建一个 Subscriber 订阅相应主题,然后打印收到的消息。 Q7. 如果订阅者重复订阅一个主题,也会被当作新的订阅者。那何时会被当作旧的订阅者?...我使用过的有 EMQTT 和 Mosquitto,我推荐 EMQTT。 Q10. 目前国内的智慧社区具体案例有哪些? 应该不少了, 推荐一个我公司的成都保障房智慧小区。 Q11....有很多,除了我在课程里面提到的,拿我公司做个例子:通过摄像头和智能门禁作为前端的数据采集,在后端对采集到的数据进行学习,可以做出一些分析。比如,发现哪栋楼、哪个单元可能存在群租等。

2.1K20

Mosquitto源码分析及用go语言的重新实现(一、开篇)

物联网最近乃至以后都会很火,业余时间计划对Mosquitto源码进行一个研究分析以及用go语言按着Mosquitto的思路去重新实现一遍MQTTv3.1协议,作为一个学习和提高的过程。...MQTT是一个基于客户端-服务器的消息发布/订阅传输协议。MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛。...在很多情况下,包括受限的环境中,:机器与机器(M2M)通信和物联网(IoT)。其在,通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。 ? ? ?...可参照网上博文:常见MQTT服务器搭建与试用https://www.jianshu.com/p/e5cf0c1fd55c 常用客户端测试工具还有:MQTTBox和MQTT.fx 常用MQTT服务器有:EMQTT...或者现成的MQTT服务器,阿里云,百度云,华为云等公用的云平台提供的MQTT服务。

1.5K20

如何用Java实现一个基于MQTT协议的发布订阅示例

换句话说,消息的发布者和订阅者都是客户端,消息代理是服务器(例如EMQTT、Mosquitto、Apollo等),消息发布者可以同时是订阅者。...Topic,可以理解为消息的类型,订阅订阅(Subscribe)后,就会收到该主题的消息内容。而Payload可以理解为消息的内容,是指订阅者具体要使用的内容。...,下载地址为http://www.eclipse.org/paho/components/tool 可以下载org.eclipse.paho.mqtt.utility-1.0.0.jar这个Jar包,进行双击运行...: 3 MQTT Java实现 ----       首先保证Mosquitto Broker运行,否则无法进行客户端的消息发布和订阅。...System.out.println(e.getMessage()); } } }   MqttClient是MQTT客户端的抽象,它需要指定Broker地址,"

2.5K20

常见MQTT服务器搭建与试用(亲测通过)

服务器搭建与试用(亲测通过) 简介 MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议,它比较适合于在低带宽、不可靠的网络的进行远程传感器和控制设备通讯等...Windows搭建 1)点击这里,下载EMQ windows版 2)解压emqttd-windows7-v2.3.9.zip(我下载的是这个版本,这里是解压到D盘) 3)打开 Windows 命令行窗口,进入emqtt...客户端测试 – MQTTBox 在安装好服务器端之后,我们使用MQTT的客户端对MQTT服务器的基本功能进行相关的测试。...MQTT客户端有不少,比如mosquito提供了命令行,通过命令行工具可以方便地进行测试;最简单的方式可能还是通过可视化的界面对其进行测试,EMQ君建议用MQTTBox。...保存成功后进入如下的界面,接下来可以开始测试消息发布和订阅。如下图所示,绿色“Connected”按钮表明当前MQTT连接已经成功 3)首先我们开启一个订阅,如下图所示。

8.2K10

两款常用的 MQTT 调试工具

发布者发送某个主题的数据给经纪人,发布者不知道订阅者。 Subscriber(订阅者):消息的订阅者,订阅经纪人管理的某个或者某几个主题。...接下来对 MQTT 客户端进行配置,主要是配置好协议端口、连接用户名密码和 QoS 即可; ?...点击顶部 Connection 按钮进行连接,绿色表示连接上了,红色是连接断开。你也可以添加更多的发布者和订阅者。 发布者向主题中发布消息,订阅者可以实时接收到。 ? 4、负载测试 测试参数: ?...操作便捷 不支持WebSocket协议 基于java开发 支持代理 通过 Nashorn Engine 的 JS 脚本支持 全平台支持 Broker状态检测(HiveMQ & mosquitto),并没有 emqtt...接下来对 MQTT 客户端进行配置,主要是配置好协议端口、连接用户名密码和 QoS 即可; ? ? 再配置一个订阅者,订阅订阅 testTopicA 这个主题,我们会向这个主题发送消息; ?

10.6K30

EasyCVR平台级联支持开启向下级的订阅功能

EasyCVR支持安防主流标准协议,国标GB28181协议、RTMP/RTSP/Onvif协议,以及厂家私有协议,海康Ehome、海康SDK、大华SDK等,并提供RTSP、HLS、FLV、WebRTC...我们也在不断对EasyCVR平台进行升级迭代,现在新版本的EasyCVR在和各大厂商平台对接级联的功能已经越来越完善。EasyCVR 2.0.3版本现已经支持对下级发送订阅。...今天我们来介绍一下如何在EasyCVR中设置开启向下级的订阅功能。...1)在easycvr.ini里的SMS配置subscribe的时间(输入时间代表每隔几秒发送一次订阅) 2)保存easycvr.ini后重启服务,通过抓包就可以看到EasyCVR已经开始向下级发送订阅消息了...订阅功能的开启,能够及时获取下级平台的相关信息,目录消息、告警消息等信息,加快平台之间的信令交互速度,从而使数据的互联互通、资源共享更加实时、迅速,提高上级平台对下级平台的监管效率。

54420
领券