MQTT客户端工具：MQTT Explorer: http://mqtt-explorer.com/(可模拟设备端)MQTTX: https://github.com/emqx/MQTTX （可模拟平台）

mqtt 有许多实现的产品，这里使用国内使用比较多的emqx，可以参考 emqx安装 来安装环境emqx 官方有提供java示例来连接mqtt：传送门下面我使用springboot 来优雅的整合下创建springboot 工程pom<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.o

为了使消息传递可靠并能够承受正常和异常的网络中断以及客户端和服务器中断，客户端必须在传递消息时使用持久存储来保存消息。MQ遥测传输(MQTT)是一种基于代理的轻量级发布/订阅消息传递协议，旨在开放、简单、轻量级且易于实现。每个连接到MQTT服务器的客户端实例都必须具有唯一的客户端标识符。如果具有相同ID的客户端的第二个实例连接到服务器，则第一个实例将断开连接。连接时的cleansession选项对

环境搭建windowsIDE下载链接：https://developer.harmonyos.com/cn/develop/deveco-studio?&ha_source=csdn&ha_sourceid=9005安装包解压后，点击exe程序，一路傻瓜式安装。安装好后，任意新建应用或者打开后面提供源码中应用，首先需要设置 tools—>HVDmanager 选择需要的模拟器

完整配置文件：# Licensed to the Apache Software Foundation (ASF) under one or more# contributor license agreements.See the NOTICE file distributed with# this work for additional information regarding copyrig

kafka-topics.sh 脚本使用参数列表：[vagrant@localhost kafka_2.12-3.0.0]$ bin/kafka-topics.shCreate, delete, describe, or change a topic.OptionDescription-----------

下载kafka: https://archive.apache.org/dist/kafka/2.8.1/kafka_2.13-2.8.1.tgztar -xzf kafka_2.13-2.8.1.tgzcd /Users/wushanghui/Downloads/kafka_2.13-2.8.1# Start the ZooKeeper service# Note: Soon, ZooKeepe

1 Kafka Broker 工作流程1.1 Zookeeper 存储的 Kafka 信息[vagrant@localhost bin]$ ./zkCli.sh....[zk: localhost:2181(CONNECTED) 1] ls /kafka[admin, brokers, cluster, config, consumers, controller, controller_epoch

生产者消息发送流程发送原理在消息发送的过程中，涉及到了两个线程——main 线程和 Sender 线程。在 main 线程中创建了一个双端队列 RecordAccumulator。main 线程将消息发送给 RecordAccumulator，Sender 线程不断从 RecordAccumulator 中拉取消息发送到 Kafka Broker。batch.size：只有数据积累到batch.s

使用Web APIWeb API 是网站的一部分, 用于与使用非常具体的URL请求特定信息的程序交互. 下面通访问github API来演示怎么使用python调用API.安装 requests# -i https://pypi.mirrors.ustc.edu.cn/simple/ 临时访问国内镜像源pip3 install --user requests -i https://pypi.mir