分布式
-
RabbitMQ基本概念与数据结构
1.背景介绍 RabbitMQ是一种开源的消息代理服务，它使用AMQP(Advanced Message Queuing Protocol，高级消息队列协议)协议来实现消息的传输和…
-
【Kafka】生产者Producer详解
目录 消息发送 消息生产流程 ProducerRecord 序列化器 分区器 拦截器 生产者原理剖析 主线程 消息累加器 发送线程 生产者参数 消息发送 消息生产流程 整个流程如下…
-
【Fastdfs】| 入门连续剧——安装
作者：狮子也疯狂 专栏：《spring开发》 坚持做好每一步，幸运之神自然会降临在你的身上 目录 一. 🦁 前言 Ⅰ. 🐇 为什么要使用分布式文件系…
-
Elasticsearch连续剧之分词器
目录 一、前言 二、默认分词器 三、IK分词器 1.主要算法 2.安装IK分词器 2.1 关闭es服务 2.2 上传ik分词器到虚拟机 2.3 解压 2.4 启动ES服务 2.5 …
-
Kafka——两种集群搭建详解
目录 1、简介 1.1、Kafka集群中的节点类型 1.2、两重模式的搭建方式 2、Zookeeper模式集群 3、KRaft模式集群 4、重要配置介绍 4.1、listeners…
-
Kafka生产者发送消息的流程
Kafka 生产者发送消息的流程涉及多个步骤，从消息的创建到成功存储在 Kafka 集群中。以下是 Kafka 生产者发送消息的主要步骤： 1. 创建消息 生产者首先创建一个消息，…
-
Kafka客户端程序无法连接到Kafka集群的解决方法
Kafka是一个高性能、分布式的流式数据平台，广泛用于构建实时数据流处理应用程序。然而，有时候我们可能会遇到Kafka客户端程序无法连接到Kafka集群的问题。在本文中，我将介绍一…
-
使用JAVA & Zookeeper构建分布式键值存储
在这篇文章中，我将使用 JAVA 和网络套接字构建一个简单的分布式键值存储。 我将展示如何在具有多个分区和复制的集群中使用 Zookeeper 作为协调服务。 本系统中Zookee…
-
大数据Hadoop完全分布式及心得体会
文章目录 前言 认识hadoop，根据所学知识完成作业，并总结本学期心得体会。 一、认识hadoop 二、一课一得作业讲解 实现步骤 1. 搭建集群 2. 模拟生成新能源车辆数据编…
-
Kafka错误解决：kafka.zookeeper.ZooKeeperClientTimeoutException：连接超时等待解决方案
在使用Kafka时，有时候会遇到”kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting …
-
hadoop的基础操作——Hadoop中创建、修改、查看、删除文件夹及文件
一、实验目的 熟练掌握常用的hadoop shell命令 二、实验内容 1.学习在开启、关闭Hadoop 2.学习在Hadoop中创建、修改、查看、删除文件夹及文件 3.学习…
-
【HDFS】HDFS 的常用命令
HDFS 的常用命令 1.操作命令1.1 创建文件夹1.2 列出指定的文件和目录1.3 新建文件1.4 上传文件1.5 将本地文件移动到 HDFS1.6 下载文件1.7 查看文件1…
-
rabbitmq如何保证消息的可靠性
RabbitMQ可以通过以下方式来保证消息的可靠性： 1. 持久化消息 在发布消息时，可以设置消息的delivery mode为2，这样消息会被持久化存储在磁盘上，即使Rabbit…
-
2.1、如何在FlinkSQL中读取&写入到Kafka
目录 1、环境设置 方式1：在Maven工程中添加pom依赖 方式2：在 sql-client.sh 中添加 jar包依赖 2、读取Kafka 2.1 创建 kafka表 2.2 …
-
RabbitMQ(二) – RabbitMQ与消息发布确认与返回、消费确认
RabbitMQ消息确认 SpringBoot与RabbitMQ整合后，对RabbitClient的“确认”进行了封装、使用方式与RabbitMQ官网不一致； 消息发布确认 生产者…
