Java

消息中间件：Kafka

我们作为Kafka在使用Kafka是，必然考虑消息消费失败的重试次数，重试后仍然失败如何处理，要么阻塞，要么丢弃，或者保存Kafka3.0 ...

kafka-消费者服务搭建&配置（SpringBoot整合Kafka）

Kafka是一个开源的流式平台，用于构建实时数据流应用程序和实时数据管道。Kafka旨在处理大规模的数据流，具有高吞吐量、可扩展性、持久性和...

Leader选举的大体流程都是一样的，这里将不再赘述，当完成选举以后，每个服务端实例按照自身的角色，将自身的状态修改为对应的角色状态，这个时...

1.背景介绍1. 背景介绍Apache Zookeeper是一个开源的分布式协调服务，它为分布式应用提供一致性、可靠性和原子性的数据管理。Z...

工作内容：事务请求的唯一调度和处理者，保证集群事务处理的顺序性；集群内部各服务器的调度者；ZooKeeper使用责任链模式来处理客户端请求P...

修改 Logstash 配置文件，让其收集系统日志/var/log/messages，并将其输出到 elasticsearch 中。chmo...

CAP理论CAP理论告诉我们，一个分布式系统不可能同时满足以下三种这三个基本要求，最多只能同时满足其中的两项，因为P是必须的，因此往往选择就...

Zookeeper Watcher机制原理与代码实例讲解1.背景介绍Zookeeper是一个分布式协调服务，广泛应用于分布式系统中，用于实现...

ZooKeeper保证了一系列强一致性的特性，包括顺序一致性、原子性、单一视图、可靠性和实时性（或最终一致性）。这些保证使得ZooKeepe...

如果能登录ssh，那么ssh到zk所在服务器，然后输入echo stat|nc localhost 2181，结果如下如果不能登录ssh（例...

现在，Kafka和Zookeeper已经启动成功。完美，可以使用Java代码进行Kafka相关的操作。使用Java编写代码安装Kafka并启...

在传统的单体应用中，我们可以很容易地将所有的组件都部署在同一台服务器上。但是在分布式系统中，我们需要将应用程序的不同部分分散在多个服务器上。...

Spring Cloud Eureka是一个基于REST的服务治理组件，主要用于实现服务注册与发现。它由Netflix开源，是Spring ...

在本篇博客中，我们深入探讨了Docker镜像的概念。我们学习了如何获取和管理Docker镜像，包括拉取镜像、构建自定义镜像以及导出和导入镜像...

Eureka 是 Netflix 开发的一款服务发现（Service Discovery）工具，它是 Spring Cloud Netfli...

自我保护机制是，当在短时间内，统计续约失败的比例，如果达到一定阈值，则会触发自我保护的机制，在该机制下，Eureka Server不会剔除任...

每当Docker客户端接收到一个层的数据，它就会显示 "Pulling fs layer" 的信息，这里的 "...

微服务架构已在云原生架构中发挥着举足轻重的作用，而SpingCloud无疑是微服务架构的集大成者，云计算最佳业务实践。服务注册与发现：如Eu...

1.执行命令，在ExecStart配置的后面追加保存后，执行命令重启docker然后查看端口是否开启，开启则表示成功。

Dockerfile 是用于构建 Docker 镜像的文本文件。它包含了一系列的指令，用于描述如何构建镜像的步骤和配置。通过编写 Docke...

上一章我们讲到，利用 RestTemplate 发送 http 请求时，将 url 写成了 "http://localhost:8...

在我们前面进行搭建微服务，在进行远程调用时进行远程调用的时候，我们发现我们的远程调用URL是写死的。当更换机器，或者新增机器时，这个URL就...

其实，“通过Redis手动更新Ribbon缓存来解决Eureka微服务架构中服务下线感知的问题”是一种解，但不是最优解

SpringBoot 集成 Flink CDC 实现对数据库表中数据变动的监听，源码中实现简易版增量迁移。

本文将展示如何在flink-connector-jdbc中增加对国产数据库达梦(V8)的支持。演示基于Java语言，使用Maven。

这是一段 Maven 依赖配置，它引入了 Flink Connector Base、CDC MySQL Source、Flink Strea...

RabbitMQ可以实现可靠的异步通信，解耦系统中的组件，以及处理高并发和大规模的消息流。它在许多领域，如微服务架构、日志处理、任务调度等方...

AMQP：Advanced Message Queueing Protocol，是用于在应用程序或之间传递业务消息的开放标准，该协议与语言平...