Flat Preloader Icon

Implementing Spring Cloud Bus

Spring Cloud Bus is a powerful feature of the Spring Cloud framework that allows you to broadcast distributed configuration changes to multiple microservices in a Spring Cloud environment. It utilizes Spring Cloud Stream and a message broker (e.g., RabbitMQ, Kafka) to propagate configuration updates in a dynamic and scalable way. Here’s how to implement Spring Cloud Bus in a typical Spring Boot microservices architecture:
  • Setup Spring Boot Applications: First, create multiple Spring Boot microservices (e.g., service-A, service-B) that use Spring Cloud Config to fetch their configuration from a central configuration server. Ensure that the microservices have the Spring Cloud Config and Spring Cloud Bus dependencies in their pom.xml files.
  • Spring Cloud Config Server:Set up a Spring Cloud Config Server as a central configuration repository. This server should be responsible for serving configuration properties to the microservices. It should also have Spring Cloud Bus and the appropriate message broker (e.g., RabbitMQ) configured. An example application.properties for the Config Server might look like this

  • Message Broker Setup: Spring Cloud Bus relies on a message broker (e.g., RabbitMQ or Kafka) for communication. Install and configure your chosen message broker according to your requirements.
  • Configure Microservices:In the bootstrap.properties or bootstrap.yml of each microservice, configure the Spring Cloud Bus to use the message broker

    The spring.cloud.bus.refresh.enabled=true property enables the refresh bus feature. This means when a configuration change is made in the configuration repository and the /actuator/refresh endpoint is called on any microservice, all microservices will receive the update.
  • Refresh Endpoints: To trigger a configuration update across microservices, use the /actuator/refresh endpoint of each microservice. For example, make a POST request to http://service-A-host:service-A-port/actuator/refresh and http://service-B-host:service-B-port/actuator/refresh to notify all microservices to refresh their configurations.
  • Publish Configuration Changes:When you want to update configurations for multiple microservices, make the necessary changes to the central configuration repository. After that, use the Spring Cloud Bus to broadcast those changes by hitting the /actuator/bus-refresh endpoint on the Config Server.
					curl -X POST http:

  • Consuming Configuration Changes: Each microservice should be configured to automatically refresh its configuration properties when changes are broadcast via the Spring Cloud Bus. This is achieved by including the @RefreshScope annotation on the configuration classes or specific beans that need to be refreshed.
That’s the basic setup for implementing Spring Cloud Bus in a Spring Boot microservices architecture. When you update configurations in the central repository and trigger a refresh, all subscribed microservices will dynamically update their configuration without requiring a restart. This makes managing and updating configurations in a distributed system more efficient and flexible.

Share on: