成果展示：1）可以使用自己的MySQL数据库；2）使用我提供的数据。（免费下载）gmall_report用于可视化的SQL文件-MySQL文档类资源-CSDN下载MySQLIDEAjdk1.8Maven创建springboot项目有二种方式：1）在IDEA中创建2）在官网上创建我喜欢在官网创建官网地址（记得收藏）：https://start.spring.io/​ 注：1）注意红色框框的地方，选择

springboot+echarts +mysql制作数据可视化大屏（六图）

一、前期准备1.1安装了jdk1.2安装了zookeeper分布式​​​​​​zookeeper单机和集群（全分布）的安装过程_一个人的牛牛的博客-CSDN博客1.3配置免密码登录Linux配置免密登录单机和全分布_一个人的牛牛的博客-CSDN博客1.4机器准备主节点从节点hadoop01hadoop02hadoop02hadoop03笔记本性能不够，没有安装多的虚拟机，hadoop02重复使用。

目录一.安装准备二.安装配置三.验证安装一.安装准备1.安装好MySQLLinux安装MySQL5.7（CentOS7）_一个人的牛牛的博客-CSDN博客2.下载安装包点击连接下载Index of /hive3.版本选择我安装的是apache-hive-3.1.2-bin版本！二.安装配置1.上传安装包用MobaXterm_Protable上传，MobaXterm_Protable是Windows

（1）pull（拉）模式：consumer采用从broker中主动拉取数据。Kafka采用了这种方式。（2）push（推）模式：Kafka没有采用这种方式，因为由broker决定消息发送速率，很难适应所有消费者的消费速率。例如推送的速度是50m/s，Consumer1、Consumer2就来不及处理消息。pull模式不足之处是，如果Kafka没有数据，消费者可能会陷入循环中，一直返回空数据。

成果展示：1）可以使用自己的MySQL数据库；2）使用我提供的数据。（免费下载）gmall_report用于可视化的SQL文件-MySQL文档类资源-CSDN下载MySQLIDEAjdk1.8Maven创建springboot项目有二种方式：1）在IDEA中创建2）在官网上创建我喜欢在官网创建官网地址（记得收藏）：https://start.spring.io/​ 注：1）注意红色框框的地方，选择

继承Receiver，实现onStart、onStop方法来自定义数据源采集。//TODO 创建配置环境//采集数据//开始}/*自定义数据采集器1.继承Receiver，定义泛型，传递参数2.重写方法*///最初启动,读数据val message = "采集的数据为：" + new Random().nextInt(10).toString}}}//停止}}}结果：//初始化Spark配置信息/