MQTT (Message Queuing Telemetry Transport) 是一种轻量级的消息传输协议，专为受限网络环境下的设备通信而设计。Apache Kafka 是一个分布式流处理平台，旨在处理大规模的实时数据流。
MQTT 与 Kafka 是完全不同的两个东西， MQTT 是协议，是一个技术标准，由 OASIS 技术委员会的成员（其成员多数为 IBM 和微软的顶级工程师）制订。而 Kafka 是已经实现的开源流处理平台，最早由 LinkedIn 开发，于2011年开源后交给 Apache Incubator 孵化后成为了 Apache 软件基金会的顶级项目。
MQTT与Kafka完全不同。MQTT是由OASIS技术委员会的成员（大多数是IBM和Microsoft的高级工程师）开发的协议和技术标准。Kafka是LinkedIn首次实现的开源流平台。2011年开放源码后被Apache孵化器孵化，成为Apache软件基金会的顶级项目。
MQTT协议简介 MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议，该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，被用来当做传感器和致动器（比如通过Twitter让房屋联网）的通信协议。 虽然HTTP是网页的事实标准，不过机器之间（Machine-to-Machine，M2M）的大规模沟通需要不同的模式：之前的请求/回答（Request/Response）模式不再合适，取而代之的是发布/订阅（Publish/Sub
今年早些时候，云原生计算基金会（CNCF）宣布 了 CloudEvents 的毕业。CloudEvents 是一个旨在以标准化的方式来公开事件元数据的规范，这有助于确保跨平台、服务和系统的互操作性。
导语 2022腾讯全球数字生态大会已圆满落幕，大会以“数实创新、产业共进”为主题，聚焦数实融合，探索以全真互联的数字技术助力实体经济高质量发展。大会设有29个产品技术主题专场、18个行业主题专场和6个生态主题专场，各业务负责人与客户、合作伙伴共同总结经验、凝结共识，推动数实融合新发展。 本次大会设立了微服务与中间件专场，本专场从产品研发、运维等最佳落地实践出发，详细阐述云原生时代，企业在开发微服务和构建云原生中间件过程中应该怎样少走弯路，聚焦业务需求，助力企业发展创新。 随着大数据时代的到来，企业在生产和经
EMQ X (Erlang/Enterprise/Elastic MQTT Broker) 是基于 Erlang/OTP 平台开发的开源物联网 MQTT 消息服务器。
在之前的文章中，我们提到车联网 TSP 平台拥有很多不同业务的主题，并介绍了如何根据不同业务场景进行 MQTT 主题设计。车辆会持续不断产生海量的消息，每一条通过车联网上报的数据都是非常珍贵的，其背后蕴藏着巨大的业务价值。因此我们构建的车辆 TSP 平台也通常需要拥有千万级主题和百万级消息吞吐能力。
论文 《分布式系统的现代消息传递》Modern Messaging for Distributed Sytems
随着整个汽车出行领域新四化（电气化、智能化、网联化和共享化）的推进，各个汽车制造厂商正逐步构建以智能驾驶和智能网联为核心的车联网系统。新一代的车联网系统对于底层消息采集、传输和处理的平台架构提出了更高的要求。
物联网市场在2018年第一季度/第二季度出现了意想不到的加速，并将使用的物联网设备总数提升至7B。这是IoT Analytics最新“ 物联网和短期展望状态 ”更新中的众多发现之一。
Websocket和HTTP都是基于TCP协议的，所以使用抓包工具可以抓到websocket的数据
消息队列：多个生产者可以向同一个消息队列发送消息，但是一个消息只能被一个消费者消费。
在车联网生态中，TSP（Telematics Service Provider）平台在产业链中居于核心地位，上接汽车、车载设备制造商与网络运营商，下接内容提供商，是主机厂车辆与服务的核心数据连接平台。随着智能汽车的发展和车主用户对应用场景需求的不断提升，主机厂对 TSP 平台的设备与应用承载能力需求将不断增加。
消息队列是一种将消息从发送者传递到接收者的机制，被广泛应用于分布式系统、异步处理等场景。 例如，在电商网站上，当顾客下订单时，订单信息被发送到一个消息队列，消费者可以从这个队列读取订单信息并处理，这样可以提高订单处理的效率和灵活性，并且系统可以自动处理过载情况。
如果你正在考虑是否卡夫卡RabbitMQ最适合你的用例,请继续阅读,了解这些工具背后的不同的架构和方法,如何处理信息不同,和他们的性能优缺点。我们将讨论的最佳用例的每个工具,当它可能比依赖于一个完整的端到端流处理的解决方案。
MQTT 是物联网消息传输标准协议，其采用极其轻量级的发布订阅消息模型，以可扩展、可靠且高效的方式连接物联网设备。
RocketMq作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。
这是一个自定义注解 @Log，用于在方法上进行注解。以下是对该注解的逐行详细说明：
工业4.0即第四次工业革命: 由自动化和数据驱动的下一阶段工业发展。它是物联网、工业物联网、大数据、云计算、网络物理系统、人工智能和机器学习等各种技术的统称。预计这些技术将导致下一代工厂被称为“智能工厂”，其中机器(“智能资产”或“智能机器”)应能够彼此“交谈”并“独立做出决定”基于他们收集和交流的数据对人的影响。这将减少浪费，缩短生产时间，并有助于实现成本效益和质量。
在过去的几周中，我进行了四个现场的NiFi演示会议，在不同地理区域有1000名与会者，向他们展示了如何使用NiFi连接器和处理器连接到各种系统。我要感谢大家参与和出席这些活动！如今，当在家中远程工作成为一种规范时，我们都需要交互式的演示会议和实时问答。如果您还没有看过我的现场演示会议，可以在这里观看，视频还没有过期。
物联网+大数据+机器学习将会是以后的趋势，这里介绍一篇这方面的文章包含源码。 混合机器学习基础架构构建了一个场景，利用Apache Kafka作为可扩展的中枢神经系统。 公共云用于极大规模地训练分析模型（例如，通过Google ML Engine在Google Cloud Platform（GCP）上使用TensorFlow和TPU，预测（即模型推断）在本地Kafka基础设施的执行（ 例如，利用Kafka Streams或KSQL进行流分析）。 本文重点介绍内部部署。 创建了一个带有KSQL UDF的Github项目，用于传感器分析。 它利用KSQL的新API功能，使用Java轻松构建UDF / UDAF函数，对传入事件进行连续流处理。 使用案例：Connected Cars - 使用深度学习的实时流分析 从连接设备（本例中的汽车传感器）连续处理数百万个事件：
导语 本文梳理笔者 MQ 知识，从消息中间件的基础知识讲起，在有了基础知识后，对市面上各主流的消息中间件进行详细的解析，包括 RabbitMQ、RocketMQ、Kafka、Pulsar，最后再横向对比这几款主流的消息中间件。 消息中间件历史 介绍 MQ 的文章网上千千万，最好的学习途径还是官方文档，文中介绍的这几款 MQ 都在努力推广自己，所以文档在权威性、全面性、专业性、时效性都是无人能及其左右，现在的官网文档甚至自己做竞品比对，比如 RocketMQ 就自己放了比对表格在首页。所以要学好哪一款MQ，
我们之前已经说了这个SSL 和 TCP/IP 协议了，我们今天就来详细的说说这个 MQTT 协议，因为很多消息现在都是支持 MQTT 协议的，比如 RabbitMQ ，还有 Kafka 等，今天我们就来详细的介绍 MQTT 协议到底是个什么。
老师好，我有一个疑问：在互联网项目中，为什么很多使用rabbitMQ或者是kafka或者是rocketMQ而很少使用MQTT？
数据网格（Data Mesh）是近来受到广泛重视的一种新型架构范式。每家数据和平台提供商都说明了怎样使用自己的平台来构建最好的数据网格。数据网格的故事包括像亚马逊云科技这样的云计算提供商，像 Databricks 和 Snowflake 这样的数据分析提供商，以及像 Confluent 这样的事件流解决方案。本文详细讨论了这一原理，并探索了为何没有一种技术最适合构建数据网格。本文列举的例子表明，为何像 Apache Kafka 这样的开放和可扩展的分布式实时平台一般都是数据网格基础设施的核心，而其他数据平台则是为了解决业务问题而提供支持。
MQTT 协议早已是物联网领域当之无愧的主流协议，其凭借轻巧高效、可靠安全、双向通讯等特性在诸多行业物联网平台搭建中得到了广泛的应用。那么 MQTT 协议在车联网场景中的应用情况如何呢？
本文梳理笔者的MQ知识，从消息中间件的基础知识讲起，在有了基础知识后，对市面上各主流的消息中间件进行详细的解析，包括 RabbitMQ、RocketMQ、Kafka、Pulsar，最后再横向对比这几款主流的消息中间件。
如果你问自己是否Apache Kafka比RabbitMQ更好或RabbitMQ是否比Apache Kafka更可靠，我想在这里阻止你。本文将从更广泛的角度讨论这两种情况。它关注的是这两个系统提供的功能，并将指导您做出正确的决定，决定何时使用哪个系统。
长城汽车是一家全球化智能科技公司，业务包括汽车及零部件设计、研发、生产、销售和服务，旗下拥有魏牌、哈弗、坦克、欧拉及长城皮卡。2022年，长城汽车全年销售1,067,523辆，连续7年销量超100万辆。长城汽车面向全球用户提供智能、绿色出行服务，加速向全球化智能科技公司进阶，智能化车型渗透率达86.17%，车联网作为智能化两大应用方向之一，在这个过程中快速发展。
在这一部分中，我们将探讨RabbitMQ和Apache Kafka以及它们的消息传递方法。每种技术在设计的每个方面都做出了截然不同的决定，每种方面都有优点和缺点。我们不会在这一部分得出任何有力的结论，而是将其视为技术的入门，以便我们可以深入探讨该系列的后续部分。
本文我们来探讨如何在 Java 框架——Spring 中整合 Apache Pulsar。文章阐述如何在 Java 中构建基于 Spring 的微服务。在正文内容开始前，我们先介绍 Spring。Spring 是 Java 生态中鼎鼎有名的技术框架，自诞生已有近 20 年历史。Spring 提供了极为方便的装配与控制机制，极大地降低了构建应用的难度。有了 Spring，开发者无需堆砌非业务相关的重复模板代码。基于 Spring，开发者可以如鱼得水般快速开发微服务应用，包括各类 REST API、Web 应用程序、控制台应用程序等。推荐大家深入研究 Spring。
长城汽车是一家全球化智能科技公司，业务包括汽车及零部件设计、研发、生产、销售和服务，旗下拥有哈弗、魏牌、欧拉、坦克及长城皮卡。2022年，长城汽车全年销售1,067,523辆，连续7年销量超100万辆。长城汽车面向全球用户提供智能、绿色出行服务，加速向全球化智能科技公司进阶，智能化车型渗透率达86.17%，车联网作为智能化两大应用方向之一，在这个过程中快速发展。
近期正在探索前端、后端、系统端各类常用组件与工具，对其一些常见的组件进行再次整理一下，形成标准化组件专题，后续该专题将包含各类语言中的一些常用组件。欢迎大家进行持续关注。
Mosquitto 是一个小型轻量的开源 MQTT 服务器，由 C/C++ 语言编写，采用单核心单线程架构，支持部署在资源有限的嵌入式设备，接入少量 MQTT 设备终端，并实现了 MQTT 5.0 和 3.1.1版本协议。Mosquitto 完整支持了 MQTT 协议 特性，但基础功能上 Mosquitto 集群功能羸弱，官方和第三方实现的集群方案均难以支撑物联网大规模海量连接的性能需求。
我们很高兴地宣布：EMQX Enterprise 4.4.15 和 4.4.16 版本现已正式发布！
各位老师大家上午好，我们组的题目是智能网联汽车大数据基础平台的构建。我们的指导企业是西部智联。我们的汇报将从这五个方面进行展开，第一个方面是项目背景与需求分析。
ThingsBoard 是一个备受瞩目的开源物联网平台，其优秀的性能和高效的性能得到了广大开发者的认可。ThingsBoard 是用于数据收集、处理、可视化和设备管理的开源物联网平台。它通过行业标准的物联网协议 - MQTT、CoAP 和 HTTP 实现设备连接，并支持云和本地部署。Thingsboard 具有可伸缩性、容错性和性能优越的特点。
说到消息中间件，估计大伙多多少少都能讲出来一些，ActiveMQ、RabbitMQ、RocketMQ、Kafka 等等各种以及 JMS、AMQP 等各种协议，然而这些消息中间件各自都有什么特点，我们在开发中又该选择哪种呢？今天松哥就来和小伙伴们梳理一下。
Spring Cloud Stream 消息桥接（Message Bridge）是一种将消息从一个消息代理传递到另一个消息代理的高级特性。消息桥接通常用于将消息从一个环境（例如开发环境）中的消息代理传递到另一个环境（例如生产环境）中的消息代理，或者将消息从一个协议（例如 AMQP）转换为另一个协议（例如 MQTT）。本文将详细介绍 Spring Cloud Stream 中的消息桥接特性，并给出示例代码。
MQTT Broker 是用于连接物联网设备，完成消息传递的重要组件。MQTT Broker 的选型，是物联网应用构建过程中最为基础也是最为关键的一步。本文将从物联网应用普遍场景和项目需求出发，提供一些通用的选型思路和关注点，帮助读者了解如何选择一款最适合自己的 MQTT Broker。
Kafka在大数据流式处理场景当中，正在受到越来越多的青睐，尤其在实时消息处理领域，kafka的优势是非常明显的。相比于传统的消息中间件，kafka有着更多的潜力空间。今天的大数据开发分享，我们就主要来讲讲Apache Kafka分布式流式系统。
但是在回调函数中，我们只能知道消息的主题名是什么。如果是非通配符订阅，订阅时使用的主题过滤器将和消息中的主题名完全一致，所以我们可以直接建立订阅主题与回调函数的映射关系。然后在消息到达时，根据消息中的主题名查找并执行对应的回调函数。
clickhouse是一款强大的数据仓库选择，不需要额外的依赖；兼容SQL，还提供了许多引擎。我们考虑使用，kafka作为分析数据的收集，各个服务节点只要向kafka发送数据，而无需关心数据的落地。
首先，确保边缘设备上有合适的Modbus主站实现。这可以是使用现有的Modbus库或者根据需要自行开发。主站负责与Modbus从站通信，发起读取和写入操作，并处理Modbus响应。
拥有工业物联网（IIoT）系统的制造商可以以此参考架构为模型，推动创新、适应性和持续改进。
我们往kafka集群中发送数据的时候，kafka是怎么感知到需要发送到哪一台节点中呢？其实这其中的奥秘就在kafka的Metadata中。这一篇我们就来看看kafka中的Metadata管理。
本文分别从性能、架构和功能方面比较 Pulsar 和 Kafka 的区别，并且介绍 Pulsar 的用例、支持与社区等。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
