Kafka3.0 命令行操作
Kafka3.0 安装镜像下载阿里云镜像Kafka配置在kafka2.8中就已经开始弃用外部的zookeeper依赖了，而在内部集成了高适配的zk内置的zk端口默认是2181，而kafka broker默认的端口是9092这里需要区分# The id of the broker. This must be set to a unique integer for each broker. br...
Kafka3.0 安装镜像下载阿里云镜像Kafka配置在kafka2.8中就已经开始弃用外部的zookeeper依赖了，而在内部集成了高适配的zk内置的zk端口默认是2181，而kafka broker默认的端口是9092这里需要区分# The id of the broker. This must be set to a unique integer for each broker. br...
Kafka 3.x 基本概念1、Kafka 传统定义Kafka是一个分布式的基于发布/订阅模式的消息队列，主要用于大数据实时处理领域。消息的发布者不会将消息直接发送给订阅者，而是将消息分成不同的类别，订阅者只接受自己感兴趣的消息2、Kafka最新定义Kafka是一个开源的分布式事件流平台，被数千家公司用于高性能数据管道、流分析、数据集成和关键人物应用。在我们常见使用的电商平台如淘宝，京东中，...
一、CAP定理百度百科：CAP原则又称CAP定理，指的是在一个分布式系统中， 一致性（Consistency）、可用性（Availability）、 分区容错性（Partition tolerance）。CAP 原则指的是，这三个要素最多只能同时实现两点，不可能三者兼顾分区容错性分区指的是由于网络或者一些不可控因素导致集群中某些节点不连通的情况，而分区容错性指的是当我们的分布式系...
数据模型NameSpace，Group，Service/DataId目的是为了将数据模型分类，从而形成一定的效果，比如服务隔离，不同的NameSpace中的服务不能够相互访问数据模型的最佳实践NameSpace：代表不同的运行环境，Dev/Test/ProdGroup：代表某一类配置，如中间件配置，数据库配置等Service/DataId：代表某服务的具体配领域模型Nacos的三层分级模型（...
微服务中的配置在我们的微服务的运行环境中，每一个微服务往往不会只有一套环境，在企业中往往存在至少三套运行环境：开发、测试、生产在这套微服务系统中，会存在三个问题：配置文件的数量会随着微服务的增多而增多单个配置文件无法区分多个运行环境配置文件无法动态更新，修改配置文件后需要重启对应的微服务当我们引入配置中心，它能解决什么问题？统一的配置文件的管理提供统一的服务标准接口，服务根据标准接口拉去对应...
高可用性（High Availability，HA）是你在系统设计时经常会听到的一个名词，它指的是系统具备较高的无故障运行的能力。通常来讲，一个高并发大流量的系统，系统出现故障比系统性能低更损伤用户的使用体验。想象一下，一个日活用户过百万的系统，一分钟的故障可能会影响到上千的用户。而且随着系统日活的增加，一分钟的故障时间影响到的用户数也随之增加，系统对于可用性的要求也会更高。所以今天，我们就...
在设计一个微服务的时候，一般会遵守4个原则AKF微服务拆分前后端分离无状态服务RestFul服务通信一、AKF扩展立方体微服务的拆分原则主要参考立方体中的Y轴，根据不同的业务划分微服务拆分的要点：高内聚，低耦合，每个服务完成具体的功能根据团队划分，一个团队负责1-2个服务模块，进行快速的更新迭代Y轴Y轴扩展将一个庞大的业务拆分成多个具体的服务，前端通过客户端或者PC端通过服务网关的治理请求到...
原子性带来的并发安全问题在并发编程中，产生并发安全问题主要有三个源头，可见性，原子性，有序性可见性与有序性都可以使用volatile关键字解决，下面我们来分析下原子性带来的并发安全问题由于IO太慢，在早期的操作系统中就发明了多进程，操作系统允许某个进程执行一小段时间，例如过了50毫秒，过了50毫秒后，操作系统就会重新选择一个新的进程来执行（也就是“任务切换”），这个50毫秒也就是操作系统中的...
一、CountDownLatchCountDownLatch是一个同步工具类，它允许一个或多个线程一直等待，直到其他线程执行完后再执行。CountDownLatch是通过一个计数器来实现的，计数器的初始化值为线程的数量。每当一个线程完成了自己的任务后，计数器的值就相应得减1。当计数器到达0时，表示所有的线程都已完成任务，然后在闭锁上等待的线程就可以恢复执行任务。现在有这样一个运动会场景，总共...