原文:EMQ X Enterprise (MQTT Broker) + Apache Kafka 构建高性能物联网消息处理后台

背景 在各类物联网项目中,设备产生的消息不仅仅作用于设备之间,还需要供业务系统使用以实现如安全审计 流量计费 数据统计 通知触发等功能,类似很容易通过以下原型系统完成: 该原型中需要在 EMQ X 上维护多个数据通道,以供每个业务环节按照各自需求从 EMQ X 中获取消息数据。这种解决方案的问题在于: 每个业务需要与 EMQ X 建立数据通道,数据通道的建立与保持需要额外的资源开销,数据同步速度严 ...

2019-12-17 09:47 0 1214 推荐指数:

查看详情

EMQ X 规则引擎系列 (八)桥接消息MQTT Broker

桥接概念 桥接是一种连接多个 EMQ X 或者其他 MQTT 消息中间件的方式。不同于集群,工作在桥接模式下的节点之间不会复制主题树和路由表。桥接模式所做的是: 按照规则把消息转发至桥接节点; 从桥接节点订阅主题,并在收到消息后在本节点/集群中转发该消息。 工作在桥接模式下 ...

Fri Oct 18 17:20:00 CST 2019 0 572
EMQ X+TDengine 搭建 MQTT 联网可视化平台

联网数据采集涉及到大量设备接入、海量的时序数据传输,EMQ X MQTT 服务器 与 TDengine 大数据平台的组合技术栈完全能够胜任场景中的海量时间序列监测数据的传输、存储和计算。 数据入库后,往往需要其他方式如数据可视化系统将数据按照规则统计、展现出来,实现数据的监控、指标统计等业务 ...

Wed Aug 05 21:40:00 CST 2020 0 1365
EMQ X+TDengine 搭建 MQTT 联网可视化平台

联网数据采集涉及到大量设备接入、海量的时序数据传输,EMQ X MQTT 服务器 与 TDengine 大数据平台的组合技术栈完全能够胜任场景中的海量时间序列监测数据的传输、存储和计算。 数据入库后,往往需要其他方式如数据可视化系统将数据按照规则统计、展现出来,实现数据的监控、指标统计等业务 ...

Wed Jan 06 04:27:00 CST 2021 0 380
联网架构成长之路(8)-EMQ-Hook了解、连接Kafka发送消息

1. 前言   按照我自己设计的联网框架,对于MQTT集群中的所有消息,是要持久化到磁盘的,这里采用一个消息队列中间件Kafka作为数据缓冲,缓冲结果存到数据仓库中,以供后续作为数据分析。由于MQTT集群中的消息都是比较分散的,所以使用Kafka来聚合、采集消息。 2. 下载&编译 ...

Tue Jan 09 16:45:00 CST 2018 9 9413
EMQ X 与 RabbitMQ 消息服务器 MQTT 性能对比(上)

本文素材来源于 RabbitMQ Summit 2019 会议上 Erlang Solutions 工程师 Grigory Starinkin 的发言内容。原内容主要对 MQTT 消息服务器 EMQ X 与 RabbitMQ 进行了介绍及压力测试对比。在此基础上,我们对其进行了补充,深入分析 ...

Wed Sep 01 00:17:00 CST 2021 0 223
EMQ X Broker 启动

以下的 shell 命令,都是在 emqx 的安装目录下进行的,因此需要先执行: 一、启停管理 启动 EMQ X Broker 停止 EMQ X Broker 1.1 启动失败 参考自 4.1.x 版本常见错误 我遇到了 EMQ X Broker v4.1.1 ...

Thu Dec 09 18:08:00 CST 2021 0 2404
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM