一、Kafka 生产者发送原理 在消息发送的过程中，涉及到了两个线程 一一 main 线程和 Sender 线程。在 main 线程中创建了一个双端队列 RecordAccumulator。main 线程将消...

一、Kafka 概述 1.1、定义 Kafka传统定义：Kafka是 一个分布式的基于发布/订阅模式的消息队列(MessageQueue)，主要应用于大数据实时处理领域。发布/订阅：消息的发布者不...

一、环境搭建 前提：保证三个节点服务器上 Zookeeper 集群服务端启动。 1.1、创建工程：zookeeper 1.2、引入依赖 <dependencies> <dependency> <gr...

一、集群安装 这里由于是测试环境，直接在一台服务器上启动三个节点，如果是多台服务器，部署到多台不同服务器即可 1.1、解压 $ tar -zxvf apache-zookeeper-3.5.7-bin.t...

一、介绍 1.1、概述 Zookeeper 是一款开源的分布式的，为分布式框架提供协调服务的 Apache 项目。 Zookeeper 工作机制： [图片] Zookeeper 从设计模式角度来理解：是一个...

一、介绍 1.1、什么是 Canal Canal 是用 Java 开发的基于数据库增量日志解析，提供增量数据订阅&消费的中间件。目前。Canal 主要支持了 MySQL 的 Binlog 解析，解析...

Redisson分布式锁一致性问题 对于主从结构的 redis 集群，如果在同步锁的过程中，主节点宕机，会将从节点中的某个节点选举为主节点，但是如果此时，锁没有同步成功，会导...

一、基于 Redis 分布式锁优化 基于 setnx 实现的分布式锁存在下面问题： 不可重入: 同一个线程无法多次获取同一把锁(例如方法A执行前需要获取锁，然后调用方法B，方法B中...

什么是分布式锁 分布式锁：满足分布式系统或集群模式下多进程可见并且互斥的锁 一般至少要满足如下几点 多进程可见互斥高可用高性能安全性 分布式锁的实现 分布式锁的核...

一、分布式事务实现方式 1.1、两阶段提交(2PC) 需要数据库厂商的支持，java组件有atomikos等 两阶段提交（Two-phase Commit，2PC），通过引入协调者（Coordinator）来协...

一、配置 消息发送者和消费者注意： 若使用 confirm-callback 需要配置 publisher-confirm-type: correlated 若使用 return-callback 需要配置 publisher-returns: true...

一、PC 端配置 1.1、这里以 Mac OS 为例，访问官网进行下载 下载地址 [图片] 1.2、安装完成之后，进行激活 下载地址 随便输入 RegisterName，生成之后，对 Charlse 进行...

引入依赖 <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId&gt...

一、RabbitMQ 集群介绍 普通集群镜像集群 1.1、普通镜像模式 普通集群模式，就是将 RabbitMQ 部署到多台服务器上，每个服务器启动一个 RabbitMQ 实例，多个实例之间进行...

RDB（Redis DataBase Backup file） Redis 数据备份文件，也被叫做 Redis 数据快照。简单来说就是把所有记录都记录到磁盘中。当 Redis 实例故障重启后，从磁盘读取快照文...