spring-cloud-starter-bus-kafka利用kafka消息总线实现动态刷新配置

利用上一节的config-client，修改依赖为spring-cloud-starter-bus-kafka：

     <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-kafka</artifactId></dependency>

假设kafka，zookeeper，都是运行在本地，都是默认端口，那么不需要增加额外的配置，即可完全模仿上一节的例子：

比如发送刷新配置请求：curl http://127.0.0.1:7002/actuator/bus-refresh/ -d '' -H 'content-type:application/json'

观察到日志：

2019-04-14 20:35:38.067  INFO 73543 --- [container-0-C-1] o.s.cloud.bus.event.RefreshListener      : Received remote refresh request. Keys refreshed []

同时，kafka服务端控制台可见：

RdeMacBook-Pro:kafka r$ ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic springCloudBus --from-beginning
{"type":"RefreshRemoteApplicationEvent","timestamp":1555245081633,"originService":"config-client:7002:108286c6ad0ece8b6a1a52a1990658b2","destinationService":"**","id":"862c45f1-15b9-4eaa-82d0-a54ee8f4f958"}
{"type":"AckRemoteApplicationEvent","timestamp":1555245081732,"originService":"config-client:7002:108286c6ad0ece8b6a1a52a1990658b2","destinationService":"**","id":"5b91765b-9987-4bd5-88b6-9d4fee98a28a","ackId":"862c45f1-15b9-4eaa-82d0-a54ee8f4f958","ackDestinationService":"**","event":"org.springframework.cloud.bus.event.RefreshRemoteApplicationEvent"}
{"type":"AckRemoteApplicationEvent","timestamp":1555245090613,"originService":"config-client:7003:4e14a1a6ed5fa4f2e8a392ae0373d6d3","destinationService":"**","id":"5f65b526-93d9-4f36-a927-967cc4eff5e3","ackId":"862c45f1-15b9-4eaa-82d0-a54ee8f4f958","ackDestinationService":"**","event":"org.springframework.cloud.bus.event.RefreshRemoteApplicationEvent"}

spring-cloud-starter-bus-kafka利用kafka消息总线实现动态刷新配置相关推荐

SpringCloud 入门教程(十)：和RabbitMQ的整合 -- 消息总线Spring Cloud Netflix Bus
在本教程第三讲Spring Cloud 入门教程(三): 配置自动刷新中,通过POST方式向客户端发送/refresh请求, 可以让客户端获取到配置的最新变化.但试想一下, 在分布式系统中,如果存在很 ...
Spring Cloud构建微服务架构：消息驱动的微服务（核心概念）【Dalston版】
通过<Spring Cloud构建微服务架构:消息驱动的微服务(入门)>一文,相信大家对Spring Cloud Stream的工作模式已经有了一些基础概念,比如:输入.输出通道的绑定,通 ...
Spring Cloud Stream消息中间件通过RabbitMQ实现消息推送
一.Spring Cloud Stream是什么 Spring Cloud Stream 是一个构建消息驱动微服务的框架. Spring Cloud Stream解决了开发人员无感知的使用消息中间件的 ...
Spring Cloud构建微服务架构：消息驱动的微服务（消费分区）【Dalston版】
通过上一篇<消息驱动的微服务(消费组)>的学习,我们已经能够在多实例环境下,保证同一消息只被一个消费者实例进行接收和处理.但是,对于一些特殊场景,除了要保证单一实例消费之外,还希望那些具备 ...
spring cloud 入门系列七：基于Git存储的分布式配置中心--Spring Cloud Config
我们前面接触到的spring cloud组件都是基于Netflix的组件进行实现的,这次我们来看下spring cloud 团队自己创建的一个全新项目:Spring Cloud Config. 它用来 ...
Spring Cloud构建微服务架构：消息驱动的微服务（入门）【Dalston版】
之前在写Spring Boot基础教程的时候写过一篇<Spring Boot中使用RabbitMQ>.在该文中,我们通过简单的配置和注解就能实现向RabbitMQ中生产和消费消息.实际上我 ...
Spring Cloud架构教程（六）消息驱动的微服务【Dalston版】
Spring Cloud Stream是一个用来为微服务应用构建消息驱动能力的框架.它可以基于Spring Boot来创建独立的.可用于生产的Spring应用程序.它通过使用Spring Integr ...
Spring Cloud构建微服务架构：消息驱动的微服务（消费组）【Dalston版】
通过之前的<消息驱动的微服务(入门)>一文,相信很多朋友已经对Spring Cloud Stream有了一个初步的认识.但是,对于<消息驱动的微服务(核心概念)>一文中提到的一 ...
Spring Cloud Alibaba 之服务通信 REST消息通信：如何使用 OpenFeign 简化服务间通信
上一讲我们学习了 Ribbon 与 RestTemplate 两个组件.Ribbon 提供了客户端负载均衡,而 RestTemplate 则封装了 HTTP 的通讯,简化了发送请求的过程.两者相辅相成 ...
maven 之 Spring Cloud Starter Alibaba Nacos Discovery
概述版本注意: 孵化版本(groupId为org.springframework.cloud): spring-cloud-alibaba-dependencies版本0.9.0:与 ...

spring-cloud-starter-bus-kafka利用kafka消息总线实现动态刷新配置

spring-cloud-starter-bus-kafka利用kafka消息总线实现动态刷新配置相关推荐

最新文章

热门文章