Java三种输出语句，全网疯传

消息中间件是分布式系统中的重要组件&＃xff0c;在实际工作中常用消息中间件进行系统间数据交换&＃xff0c;从而解决应用解耦、异步消息、流量削峰等问题&＃xff0c;实现高性能、高可用、可伸缩和最终一致性架构。目前市面上可供选择的消息中间件有RabbitMQ、ActiveMQ、 Kafka、 RocketMQ、ZeroMQ、MetaMQ等。

本文总结了近年来在实际项目中使用消息中间件的经历和踩过的一些坑&＃xff0c;可为你**在实际工作中进行产品选型、业务场景方案制定、性能调整等提供明确的思路。**由于是基于Java语言开发&＃xff0c;因此它非常适合Java初中级程序员阅读&＃xff0c;学习。

正文

ZooKeeper 很流行&＃xff0c;有个基本的疑问&＃xff1a;

• ZooKeeper 是用来做什么的&＃xff1f;
• 之前没有ZK&＃xff0c;为什么会诞生 ZK&＃xff1f;

OK&＃xff0c;解答一下上面的疑问&＃xff1a;&＃xff08;下面是凭直觉说的&＃xff09;

• ZooKeeper 是用于简化分布式应用开发的&＃xff0c;对开发者屏蔽一些分布式应用开发过程中的底层细节
• ZooKeeper 对外暴露简单的 API&＃xff0c;用于支持分布式应用开发
• ZooKeeper 在提供上述功能的同时&＃xff0c;其还是一个 高性能、高可用、高可靠的分布式集群

上面说这么多&＃xff0c;总结一下&＃xff0c;ZK 能解决分布式应用开发的问题&＃xff0c;ZK 能很好的解决问题。到这一步&＃xff0c;疑问就更多了&＃xff1a;

1. 分布式应用开发&＃xff0c;有哪些常见问题&＃xff1f;ZK 是如何屏蔽这些底层细节的&＃xff1f;
2. ZooKeeper 对外暴露了那些 API&＃xff1f;这些 API 如何支持分布式应用开发的&＃xff1f;这些 API 还能简化吗&＃xff1f;API 的语义性怎么样&＃xff1f;
3. ZooKeeper 自身是一个高性能、高可用、高可靠的分布式集群&＃xff0c;那有个简单的问题&＃xff1a;

• 高性能是指什么&＃xff1f;ZooKeeper 为了达到高性能&＃xff0c;做了哪些工作&＃xff1f;
• 高可用同上
• 高可靠同上

Note&＃xff1a;本篇 wiki 就是为了解决上述第一个疑问的。&＃xff08;其他疑问会在其他 blog 中逐步解答&＃xff09;

为什么有 ZooKeeper

一个应用程序&＃xff0c;涉及多个进程协作时&＃xff0c;业务逻辑代码中混杂有大量复杂的进程协作逻辑。

上述多进程协作逻辑&＃xff0c;有 2 个特点&＃xff1a;

• 处理复杂
• 处理逻辑可重用

因此&＃xff0c;考虑将多进程协作的共性问题拎出&＃xff0c;作为基础设施&＃xff0c;让 RD 更加专注业务逻辑开发&＃xff0c;即&＃xff1a;

ZooKeeper 就是上述多进程协作基础服务的一种。

ZooKeeper 的特点

ZooKeeper 有几个简单特点&＃xff1a;

• ZooKeeper 的 API&＃xff1a;从 文件系统 API 得到的启发&＃xff0c;提供简单的 API
• ZooKeeper 运行在专用服务器上&＃xff0c;跟业务逻辑分离&＃xff0c;保证了高容错性和可扩展性

ZooKeeper 是存储设施&＃xff0c;但特别注意

• ZK上存储的数据聚焦为&＃xff1a;协作数据&＃xff08;元数据&＃xff09;&＃xff0c;而不是应用数据&＃xff0c;应用数据有自己的存储方案&＃xff0c;例如 HDFS 等
• ZK 本质上&＃xff0c;可以看作一种特殊的 FS

特别说明&＃xff1a;

应用数据和元数据&＃xff0c;由于使用场景不同&＃xff0c;对一致性和持久性的要求有差异&＃xff0c; 因此&＃xff0c;架构设计、数据治理过程中&＃xff0c;应将 2 类数据独立看待、独立存储。

ZooKeeper 的使命

ZK 要解决的核心问题&＃xff1a;

ZK 目标&＃xff1a;简化分布式应用开发中&＃xff0c;多进程协作问题。为分布式应用&＃xff0c;提供高效、可靠的分布式协调服务&＃xff08;基础服务&＃xff09;&＃xff0c;例如&＃xff1a;

• 统一的命名服务
• 分布式锁
• 进程崩溃检测
• Leader 选举
• 配置管理&＃xff1a;配置变更时&＃xff0c;及时下发到各个 Client。

一个简单的问题&＃xff1a;多进程的协作是什么&＃xff1f;尼玛呀&＃xff0c;有完没完&＃xff0c;啥问题你都有&＃xff0c;面对这个掉咋天的脑壳&＃xff0c;还是回答一下。

多进程协作&＃xff0c;整体分为 2 类&＃xff1a;

1. 协作&＃xff1a;多进程需要一同处理某些事情&＃xff0c;一些进程采取行动是的其他进程能够正常工作&＃xff0c;例如&＃xff1a;主从结构&＃xff0c;M 向 S 分配任务&＃xff0c;S 才会执行&＃xff0c;否则 S 就保持空闲状态
2. 竞争&＃xff1a;两个进程不能同时工作&＃xff0c;一个进程必须等待另个进程执行完毕&＃xff0c;例如&＃xff1a;主从结构&＃xff0c;M 节点失效后&＃xff0c;很多 S 都想成为 M&＃xff0c;这时&＃xff0c;就需要互斥锁&＃xff0c;只有第一个获得锁的 S 成为 M

特别说明&＃xff1a;

1. 不跨网络协作&＃xff1a;多进程&＃xff0c;可以在同一台物理主机上&＃xff0c;同步原语很方便(比如&＃xff1f;管道、共享内存、消息队列、信号量)
2. 跨网络协作&＃xff1a;多进程&＃xff0c;分布在不同的物理主机上&＃xff0c;ZK 关注这一类

跨网络多进程协作&＃xff0c;进程通信&＃xff0c;基本思路有 2 个&＃xff1a;

1. 消息机制&＃xff1a;通过网络&＃xff0c;直接信息交换&＃xff0c;多消息传递算法&＃xff0c;实现同步原语
2. 共享存储&＃xff1a;利用外部共享存储&＃xff0c;实现多进程协作&＃xff0c;要求共享存储提供有序访问&＃xff0c;ZK 采用这种方式

真实系统中&＃xff0c;跨网络通信&＃xff0c;有几个共性问题&＃xff1a;

1. 消息延迟&＃xff1a;由于网络原因&＃xff0c;后发送先到达
2. 处理器性能&＃xff1a;由于系统调度原因&＃xff0c;消息到达后&＃xff0c;延迟处理
3. 时钟偏移&＃xff1a;不同物理主机&＃xff0c;时钟发生偏移

ZK 精心设计用于屏蔽上述 3 个共性问题&＃xff0c;使得这些问题在应用服务层面完全透明化。

ZooKeeper 特性

ZooKeeper 解决的本质问题

分布式系统的一致性问题&＃xff1a;

1. 消息传递&＃xff1a;延迟性&＃xff0c;先发送的消息&＃xff0c;不一定先到达&＃xff1b;
2. 消息传递&＃xff1a;丢失性&＃xff0c;发送的消息&＃xff0c;可能丢失&＃xff1b;
3. 节点崩溃&＃xff1a;分布式系统内&＃xff0c;任何一个节点都可能崩溃&＃xff1b;

在这种情况下&＃xff0c;如何保证数据的一致性&＃xff1f;

1. 提案投票&＃xff1a;基于投票策略&＃xff0c;2PC
2. 选举投票&＃xff1a;基于投票策略&＃xff0c;投出优先级最高的节点&＃xff08;包含最新数据的节点&＃xff09;

Paxos 目标&＃xff1a;解决分布式一致性问题&＃xff0c;提高分布式系统容错性的一致性算法。

Paxos 本质&＃xff1a;基于消息传递的高度容错的一致性算法

ZooKeeper 定位

ZooKeeper 是&＃xff1a;

1. 分布式协调服务
2. 高效、可靠
3. 方便应用程序&＃xff0c;聚焦业务逻辑开发&＃xff0c;而不需要过多关注分布式进程间协作细节

ZooKeeper 不直接暴露原语&＃xff0c;而是&＃xff0c;暴露一部分调用方法组成的 API&＃xff0c;类似文件系统的 API&＃xff0c;支持应用程序实现自己的原语。

ZooKeeper 特性

ZooKeeper 可以保证如下分布式一致性特性&＃xff1a;

• 顺序一致性&＃xff1a;同一个 Client 发起的事务请求&＃xff0c;严格按照发起顺序执行
• 原子性&＃xff1a;事务请求&＃xff0c;要么应用到所有节点&＃xff0c;要么一个节点都没有应用
• 单一视图&＃xff1a;Client 无论连接到哪个节点&＃xff0c;看到的服务端数据都是一致的&＃xff08;Note&＃xff1a;不准确&＃xff0c;其实是最终一致性&＃xff09;
• 可靠性&＃xff1a;事务一旦执行成功&＃xff0c;状态永久保留
• 实时性&＃xff1a;事务一旦执行成功&＃xff0c;Client 并不能立即看到最新数据&＃xff0c;但 ZooKeeper 保证最终一致性

ZooKeeper 设计目标

ZooKeeper 致力于提供高性能、高可用、顺序一致性的分布式协调服务&＃xff0c;保证数据最终一致性。

目标一&＃xff1a;高性能&＃xff08;简单的数据模型&＃xff09;

1. 采用树形结构组织数据节点&＃xff1b;
2. 全量数据节点&＃xff0c;都存储在内存中&＃xff1b;
3. Follower 和 Observer 直接处理非事务请求&＃xff1b;

目标二&＃xff1a;高可用&＃xff08;构建集群&＃xff09;

1. 半数以上机器存活&＃xff0c;服务就能正常运行
2. 自动进行 Leader 选举

目标三&＃xff1a;顺序一致性&＃xff08;事务操作的顺序&＃xff09;

1. 每个事务请求&＃xff0c;都会转发给 Leader 处理
2. 每个事务&＃xff0c;会分配全局唯一的递增id&＃xff08;zxid&＃xff0c;64位&＃xff1a;epoch &＃43; 自增 id&＃xff09;

目标四&＃xff1a;最终一致性

1. 通过提议投票方式&＃xff0c;保证事务提交的可靠性
2. 提议投票方式&＃xff0c;只能保证 Client 收到事务提交成功后&＃xff0c;半数以上节点能够看到最新数据

ZooKeeper 出现之前

ZK 出现之前&＃xff0c;分布式系统常用两种方式&＃xff0c;实现多进程协作&＃xff1a;

1. 分布式锁管理器
2. 分布式数据库

ZK 更专注于进程协作&＃xff0c;而不提供任何锁接口和通用的存储数据接口。&＃xff08;疑问&＃xff1a;ZK 也可以提供啊&＃xff0c;我们不使用就行了&＃xff09;

应用服务器&＃xff0c;常见的 2 种需求&＃xff1a;

1. Master-Slave Leader 选举&＃xff1a;要求提供Master节点选举功能
2. 进程响应跟踪 崩溃检测&＃xff1a;要求提供进程存活状态的跟踪
3. 分布式锁&＃xff1a;互斥排它锁

ZK 为上述 2 种策略提供了基础 API。

ZooKeeper 不适用的场景&＃xff1a;

1. 海量数据存储&＃xff1a;ZK 本质是特殊的 FS&＃xff0c;但 ZK 用于存储元数据&＃xff0c;需要单独存储应用数据

ader 选举**&＃xff1a;要求提供Master节点选举功能
2. 进程响应跟踪 崩溃检测&＃xff1a;要求提供进程存活状态的跟踪
3. 分布式锁&＃xff1a;互斥排它锁

ZK 为上述 2 种策略提供了基础 API。

ZooKeeper 不适用的场景&＃xff1a;

1. 海量数据存储&＃xff1a;ZK 本质是特殊的 FS&＃xff0c;但 ZK 用于存储元数据&＃xff0c;需要单独存储应用数据