【RabbitMQ】交换机详解看这一篇就够了
交换机（Exchange）是消息队列中的一个重要概念，用于实现消息的路由和分发。交换机接收发布到它的消息，并根据特定的规则将消息发送到一个或多个队列中。在消息队列系统中，交换机起到了消息的分发中心的作用。它接收生产者发送的消息，并根据预定义的路由规则将消息发送到符合条件的队列中，然后由消费者从队列中
zookeeper
概念：zookeeper是一个分布式应用程序的协调服务。作用：配置管理、分布式锁、集群管理zookeeper是一个树形数据结构。每一个节点被称为ZNode，每个节点会保存自己的数据和节点信息，并允许少量的数据存储到节点下。节点分为四类：persistent 持久化节点ephemeral 临时节点：-
RabbitMQ初级的部分面试题
RabbitMQ初级的学习心得
[PySpark学习]RDD的转换（Transformation）与动作算子（Action）
RDD（英文全称Resilient Distributed Dataset），即弹性分布式数据集是spark中引入的一个数据结构，是Spark中最基本的数据抽象，代表一个不可变、可分区、里面的元素可并行计算的集合。Resilient弹性：RDD的数据可以存储在内存或者磁盘当中，RDD的数据可以分区。
RabbitMQ之交换机
RabbitMQ 中的交换机（Exchange）是消息的分发中心，负责将消息发送到一个或多个队列。它接收生产者发送的消息并将这些消息路由到消息队列中。
RabbitMQ 常见问题
在RabbitMQ中，消息最终会保存在队列中，在同一个队列中，消息是顺序的，保持先进先出的原则，这个由Rabbitmq保证。如果消息已经被消费者消费了，只是在消费者返回ack确认信息的时候出现异常，导致ack信息未能发送到broker，从而导致RabbitMQ不清楚这条消息到底有没有被消费成功，消息
使用 Kafka 和 CDC 将数据从 MongoDB Atlas 流式传输到 SingleStore Kai
在本文中，我们将了解如何将 Apache Kafka 代理连接到 MongoDB Atlas，然后使用 CDC 解决方案将数据从 MongoDB Atlas 流式传输到 SingleStore Kai。我们还使用 Metabase 创建了一个快速的可视化仪表板，以帮助我们深入了解我们的广告活动。为了
RabbitMQ 部署与配置[CentOS7]
【代码】RabbitMQ 部署与配置[CentOS7]
RabbitMQ高级特性
消息的可靠性保证：保证消息在传输过程中不会出现消息丢失的情况，确保发送的消息至少被消费一次。
消息队列选型：Kafka 如何实现高性能？
在分布式消息模块中，我将对消息队列中应用最广泛的 Kafka 和 RocketMQ 进行梳理，以便于你在应用中可以更好地进行消息队列选型。另外，这两款消息队列也是面试的高频考点。所以，本文我们就一起来看一下，Kafka 是如何实现高性能的。
ELK+kafka+filebeat企业内部日志分析系统
是一个基于Lucene的搜索服务器。提供搜集、分析、存储数据三大功能。它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。Elasticsearch是用Java开发的，并作为Apache许可条款下的开放源码发布，是当前流行的企业级搜索引擎。设计用于云计算中，能够达到实时搜索，
Hadoop3完全分布式搭建
1，Datanode相关界面负载信息2，这个查看 HDFS的相关信息。
【Kafka-3.x-教程】-【七】Kafka 生产调优、Kafka 压力测试
那么当生产者向一个未创建的主题发送消息时，会自动创建一个分区数为 num.partitions（默认值为1）、副本因子为 default.replication.factor（默认值为 1）的主题。：默认是 none，不压缩，但是也可以使用 lz4 压缩，效率还是不错的，压缩之后可以减小数据量，提升
spark-udf函数
from pyspark.sql import SparkSessionfrom pyspark.sql.types import *ss = SparkSession.builder.getOrCreate()df_csv = ss.read.csv(‘hdfs://node1:8020/user
zookeeper 常见客户端介绍和使用 zkCli、自带API、 zkClient、Curator
Zookeeper的基本客户端使用，包括自带的控制台、自带的API、第三方API例如zkClient、Curator等
Kafka（二）【文件存储机制 & 生产者】
Kafka 文件存储机制、生产者发送数据、分区、数据的容错与一致性保证
kafka处理大量消息积压tips —— 筑梦之路
场景：1. 如果是Kafka消费能力不足，则可以考虑增加 topic 的 partition 的个数，同时提升消费者组的消费者数量，消费数 = 分区数 （二者缺一不可）2. 若是下游数据处理不及时，则提高每批次拉取的数量。批次拉取数量过少（拉取数据/处理时间 < 生产速度），使处理的数据小于生产的数
Spark二、Spark技术栈之Spark Core
spark核心：包括RDD、RDD算子、RDD的持久化/缓存、累加器和广播变量。
RabbitMQ 添加用户
虚拟机概念是RabbitMQ的核心,在用户未自定义虚拟机前已经内置有虚拟机,在使用RabbitMQ中,可以进行自定义配置虚拟机.一个虚拟机中可以含有多个队列信息。添加admin用户，设置admin权限，guest不能远程访问。可登陆管理控制台，同时可以查看rabbitmq节点的相关信息(进程数，内存
分布式系统架构设计之分布式消息队列的水平扩展性、安全可用性以及监控与调优
通过分区、副本和负载均衡等关键技术，可以实现分布式消息队列的水平扩展，在实际应用中，还需要根据业务需求和系统环境进行合理的选择和设计，以达到最佳的性能和稳定性，同时，还需要关注网络延迟、数据一致性、运维管理和可扩展性设计等方面的问题，以确保系统的稳定运行和持续发展。然而，随着业务的发展和系统规模的扩
