在之前的文章中我演示了如何搭建服务注册中心和服务提供者，本文接着演示如何构建一个服务消费者，它主要完成两个目标：发现服务以及消费服务。其中发现服务的任务由 Eureka 的客户端完成，而服务消费的任务由 Ribbon 完成。 Ribbon 是一个基于 HTTP 和 TCP 的客户端负载均衡器......
在之前文章中我们都是使用单节点的服务注册中心，这个在生产环境下显然并不合适，本文接着介绍如何构建高可用的服务注册中心以增强系统的可用性。 三、构建高可用注册中心 1，Eureka Server 的高可用 Eureka Server 在设计的时候就考虑了高可用设计......
前文演示了如何搭建一个服务注册中心，本文接着演示如何将一个既有的 Spring Boot 应用加入 Eureka 的服务治理体系中去。 二、创建并注册服务提供者 1，添加依赖 首先创建一个 Spring Boot 工程，然后在 pom 文件中引入相关依赖. 2，Eureka Client 相关配置......
序：基本概念介绍 1，服务治理 （1）服务治理是微服务架构中最为核心和基础的模块，它主要用来实现各个微服务实例的自动化注册和发现。 服务注册：在服务治理框架中，通常都会构建一个注册中心，每个服务单元向注册中心登记自己提供的服务，包括服务的主机与端口号......
默认情况下，当项目启动时，监听器就开始工作（监听消费发送到指定 topic 的消息）。如果我们不想让监听器立即工作，想在程序运行的过程中能够动态地开启、关闭监听器，可以借助 KafkaListenerEndpointRegistry 实现，下面通过样例进行演示......
在实际开发中，我们常常需要使用转发功能实现业务解耦。比如：应用 A 从 topic1 获取到消息，经过处理后转发到 topic2。应用 B 监听 topic2 获取消息再次进行处理。 十一、消费者6：消息转发 （1）Spring-Kafka 只需要通过一个 @SendTo 注解即可以实现消息的转发......
消息过滤器可以让消息在抵达监听容器前被拦截，过滤器根据系统业务逻辑去筛选出需要的数据交由 KafkaListener 处理，不需要的消息则会过滤掉。 十、消费者5：消息过滤器 1，配置消息过滤器 配置消息过滤器十分简单，只需要为监听容器工厂配置一个......
通常来说 KafkaListener 要做的事只是监听 Topic 中的数据并消费，如果在 KafkaListener 中还需要对异常进行 try catch 捕获并处理的话，则会显得代码块非常臃肿不利于维护。 好在 spring-kafka 为我们提供了专门的异常处理器（ConsumerAwareListenerErrorHandler......
由于 Kafka 的写性能非常高，因此项目经常会碰到 Kafka 消息队列拥堵的情况。遇到这种情况，我们可以通过并发消费、批量消费的方法进行解决。 八、消费者3：并发、批量消费 1，批量消费 （1）首先我们在项目 application.properties 文件中添加如下配置......
之前的样例中消费者这边都直接获取消息内容并使用，如果我们还想要获取分区信息、消息头等其他内容的话，有如下两种方式。 七、消费者2：获取消息头和消息体 1，使用 ConsumerRecord 类方式 （1）使用 ConsumerRecord 类接收有一定的好处......