目录Hadoop：Spark：Hive：HBase：Kafka：Java架构师之路六、高并发与性能优化：高并发编程、性能调优、线程池、NIO、Netty、高性能数据库等。-CSDN博客Java架构师之路八、安全技术：Web安全、网络安全、系统安全、数据安全等-CSDN博客 Hadoop：Hadoop是一个开源的分布式计算平台，它由Apache基金会开发和维护。Hadoop最初是为处理大规模数据集的分布式存储和处理而设计的，目前已成为了大数据领域的重要组成部分之一。Hadoop的核心组件包括：HadoopDistributedFileSystem(HDFS)：一个分布式文件系统，可以在多个节点上
Git官方网站：https://git-scm.com/docsGit在线练习地址：https://learngitbranching.js.org/Git常用命令gitadd.提交当前文件夹下所有修改文件gitstatus查看修改那些文件gitcommit-m"message"提交到在暂存区gitpull拉去当前分支最新代码gitpush推送当前已修改代码到当前远程分支gitpop隐藏修改文件gitresetHEAD^回退一个版本gitresetHEAD^^回退两个版本gitresetHEAD~100回退100个版本gitreset-hardHEAD~1回退上一个版本gitreset-har
使用SpringBoot集成中间件：Kafka的具体使用案例讲解导言在实际应用中，Kafka作为一种强大的分布式消息系统，广泛应用于实时数据处理和消息传递。本文将通过一个全面的使用案例，详细介绍如何使用SpringBoot集成Kafka，并展示其在实际场景中的应用。1.准备工作在开始之前，我们需要确保已经完成以下准备工作：安装并启动Kafka集群创建Kafka主题（Topic）用于消息的发布与订阅2.生产者示例首先，我们来创建一个简单的生产者，将消息发送到Kafka主题。@RestControllerpublicclassKafkaProducerController{@Autowiredpr
文章目录概述消息中间件的优势（异步削峰解耦）消息队列的缺点消息中间件模式分类消息队列使用场景和应用场景消息中间件常用协议消息中间件的组成如何实现高吞吐量MQ如何避免消息堆积消息堆积如何处理如何解决消息队列的延时以及过期失效问题？消息队列满了以后该怎么处理？有几百万消息持续积压几小时，怎么办？消息队列MQ技术选型讲下Kafka、RabbitMQ、RocketMQ之间的区别是什么消息队列的在各种场景下如何选型RabbitMQ和Kafka的显著区别redisZeroMQ消息队列中间件如何设计概述消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一
-学习linux系统操作是因为实验跑代码所使用的服务器是ubuntu系统，-为了能够在linux系统上更高效的修改代码、改error以及完成相应的系统设置，就跟着b站上的《黑马程序员》的课程听了一遍，其中用到了centos,搭配FinalShell。-平时是使用Xshell7和Xftp7SSH远程连接服务器。-写篇博客为了加深学习印象和防止遗忘命令。 1、ls命令ls命令的作用是列出目录下的内容：ls[-a-l-h][linux路径] -a-l-h是可选的选项-a选项：表示all的意思，即列出全部文件（包含隐藏的文件，文件夹）图片中以.开头的，表示Linux系统的隐藏文件/文件夹-l选
目录一、kafka基础概念了解二、下载安装Kafka三、KafkaTool可视化工具四、python操作kafka1、生产者代码2、消费者代码一、kafka基础概念了解Kafka是一种高吞吐量、持久性、分布式的发布订阅的消息队列系统kafka文档为什么应该学习KafkaKafka里面的信息是如何被消费的？使用生成器把Kafka写入速度提高1000倍Kafka名词概念producer：消息生产者，向KafkaBroker发消息的客户端broker:一台Kafka机器就是一个broker。一个集群由多个broker组成。一个broker可以容纳多个topictopic:可以理解为一个队列，topi
安装并运行node_exporter下载 node_exporter解压到指定/app/exporter编写管理脚本control_node_exporter.sh，并给予权限 chmod+xcontrol_node_exporter.sh，脚本内容如下：#!/bin/bashPID_FILE="node_exporter.pid"LOG_FILE="node_exporter.log"###这个路径是解压以后这个文件的路径，这个根据每个人路径不同，填入的也不同CMD="/opt/module/exporter/node_exporter"functionstart{nohup$CMD>$LO
目录一、安装JDK二、安装kafka_2.12-3.6.11.下载kafka2.启动zookeeper3.启动kafka4.测试kafka(1).创建Topic(2).查看topic列表(3).查看描述topics信息(4).启动生产者（窗口不要关闭）(5).启动消费者（窗口不要关闭）在生产者窗口输入内容，消费者端可查看到输入的内容三、kafka查看消费数据1.查看所有组2.查看消费情况一、安装JDK 文章中已提供了jdk的安装包，有兴趣的可以下载下来。rpm-ivhjdk-8u401-linux-x64.rpm二、安装kafka_2.12-3.6.11.下载kafka http
此文基于debian12，centos也适用因为zookeeper依赖jdk环境预先安装好jdk安装zookeeper1.下载zookeeper安装包ApacheZooKeeperhttps://zookeeper.apache.org/releases.html选择最新3.9.1下载可以自行选择2.将压缩包上传到服务器并解压至/usr/local/路径下，重命名为zookeepertar-zxfapache-zookeeper-3.9.1-bin.tar.gz-C/usr/local/cd/usr/local/重命名mvapache-zookeeper-3.9.1-bin./zookeepe
部分知识（可略过） Kafka Kafka是一种分布式流处理平台，它是一个高吞吐量、可扩展、持久化的消息队列系统，用于处理实时数据流。Kafka的核心概念包括生产者（Producer）、消费者（Consumer）和主题（Topic）。生产者负责将数据发布到Kafka集群，消费者则从Kafka集群中订阅并消费数据。主题是数据的分类或者分区，每个主题可以有多个分区，而每个分区又可以有多个副本。这种分区和复制的机制使得Kafka具备了高可用性和容错性。同时，Kafka还提供了丰富的API和生态系统，使得开发者可以方便地构建基于Kafka的实时数据处理应用。 Redis
