RabbitMQ 消费者
消费者就是针对某个队列进行消息监听和消息消费的。消费者消费消息存在拉模式和推模式，推模式的是使用场景相对比较多。为确保消息被合法的消费，RabbitMQ提供了消费确认机制，投递的消息并不能被理解完成了消费，仅消费者确认消费该消息才会被移除队列。默认的消息投递机制时轮询，轮询的消息分发并会关系消费者的
kafka 集群企业部署最佳实践
Kafka 是一款高性能、高可靠性、可水平扩展的分布式消息队列系统
Spark Streaming实战
作者：禅与计算机程序设计艺术 1.简介Apache Spark™作为世界上最流行的开源大数据计算框架之一，在近几年越来越受到大家的关注。基于Spark的分布式计算能力和速度的突飞猛进，使其成为许多企业应用中不可或缺的一环。但Spark本身所提供的高级特性如：SQ
qt Rabbitmq 下载、连接、使用
【代码】qt Rabbitmq 下载、连接、使用。
RabbitMQ详细教程以及SpringBoot集成RabbitMQ
RabbitMQ详细教程、SpringBoot集成RabbitMQ、RabbitMQ Windows、Mac、Linux搭建以及Linux搭建RabbitMQ集群模式
Apache Zookeeper 快速入门 极客时间
作者：禅与计算机程序设计艺术 1.简介Apache Zookeeper 是一种分布式协调服务，它是一个基于 CP（一致性和容错）的系统，用来维护配置信息、命名数据、状态信息等；同时也提供分布式锁和 leader 选举等高可用功能。Zookeeper 的架构设计目
hive分位函数percentile和percentile_approx误区和解决方案
percentile和percentile_approx对分位数的计算
【大数据】HDFS客户端命令行(hdfs dfs)详细使用说明
Hadoop dfs 客户端命令ls/count/du/mv等使用详解
实战大数据项目
存储日志数据集（HDFS）数据仓库构建（Hive）数据分区表构建数据预处理 （Spark计算引擎）-使用Zeppelin进行写SQL订单指标分析Sqoop数据导出到传统数据库（Mysql）Superset数据可视化项目架构架构方案：1、基于Hadoop的HDFS（数据存储）文件系统来存储数据2、为
8-1HBase的安装与简单操作
delete删除指定对象的值（可以为表，行，列对应的值，另外也可以指定时间戳的值）先disable表，然后再drop表，最后重新create表。表名’, ‘行键’, ‘列族名:列名’, ‘列值’表名’, ‘行键’, ‘列族名’, ‘列值’表名’, ‘行键’, ‘列族名：列名’表名’, ‘行键’, ‘
Spark 增量抽取 Mysql To Hive
【代码】Spark 增量抽取 Mysql To Hive。
java连接zookeeper
curator-framework是基础的依赖，一些特定的使用方式需要添加不同的依赖，有curator-recipes、curator-x-discovery、curator-x-async等。提供了连接重试、分布式锁、选举、队列等多种实际场景的用例。这里先简单搞个使用例子。zkclient对节点数
java操作kafka
一.本地连接kafka发送消息：生产者同步发送消息和异步发送消息。
18、Flink的SQL 支持的操作和语法
20、Flink SQL之SQL Client: 不用编写代码就可以尝试 Flink SQL，可以直接提交 SQL 任务到集群上与所有 SQL 引擎一样，Flink 查询操作是在表上进行。与传统数据库不同，Flink 不在本地管理静态数据；相反，它的查询在外部表上连续运行。Flink 数据处理流水线
使用 pyspark 进行 Clustering 的简单例子 -- KMeans
K-means算法适合于简单的聚类问题，但可能不适用于复杂的聚类问题。此外，在使用K-means算法之前，需要对数据进行预处理和缩放，以避免偏差。K-means是一种聚类算法，它将数据点分为不同的簇或组。原理简介：K-Means算法通过迭代寻找数据集中的k个簇，每个簇内的数据点尽可能相似（即，簇内距
kafka和rocketMq的区别
1、RocketMQ 和 Kafka 都使用了顺序写机制，但相比 Kafka，RocketMQ 在消息写入时追求极致的顺序写，会在同一时刻将消息全部写入一个文件，这显然无法压榨磁盘的性能。而 Kafka 是分区级别顺序写，在分区数量不多的情况下，从所有分区的视角来看是随机写，但这能重复发挥 CPU
[超详细]RabbitMQ安装延迟消息插件
下载插件版本需要注意,要跟你安装的RabbitMQ版本基本一样(我的RabbitMQ版本是3.10.1),插件我就用3.10.0,我试其他插件版本都不行,(可能是版本不兼容的原因吧),就这个3.10.0可以.然后再sbin目录下运行 rabbitmq-plugins enable rabbitmq_
hadoop namenode -format报错显示：命令未找到
这个bug很搞笑，我做分布式搭建时，slaver1和slaver2都可以hadoop name -format，就是master不可以，配置都是一样的，这个第一时间也是想到了环境配置问题。这里的/apps/hadoop是我的hadoop安装路径（根据实际情况改动）然后再执行hadoop nameno
rabbitMq虚拟主机概念
在RabbitMQ中，交换机（Exchange）用于接收生产者发送的消息，并根据特定的路由规则将消息分发到相应的队列中。而虚拟主机则是一种更高级的概念，它提供了一个逻辑上的隔离环境，使得不同的应用或不同的业务可以在同一个RabbitMQ服务器上独立操作，彼此互不干扰。通过使用不同的虚拟主机，可以将不
