Spring Cloud Bus

Spring Cloud Bus 通过一个轻量级消息代理连接分布式系统的节点。这可以用于广播状态更改（如配置更改）或其他管理指令。当前唯一的实现方式是通过一个AMQP代理作为消息传输，但相同的基本特征（传输上的一些依赖）是其他传输的路线图

For full documentation visit spring cloud bus.

Quick Start

项目中使用spring-cloud-bus推荐基于一个依赖管理系统 — 下面的代码段可以被复制和粘贴到您的构建。需要帮助吗？看看我们基于Maven和Gradle构建的入门指南。

  1. <dependencyManagement>
  2.     <dependencies>
  3.         <dependency>
  4.             <groupId>org.springframework.cloud</groupId>
  5.             <artifactId>spring-cloud-bus-parent</artifactId>
  6.             <version>1.1.1.BUILD-SNAPSHOT</version>
  7.             <type>pom</type>
  8.             <scope>import</scope>
  9.         </dependency>
  10.     </dependencies>
  11. </dependencyManagement>
  12. <dependencies>
  13.     <dependency>
  14.         <groupId>org.springframework.cloud</groupId>
  15.         <artifactId>spring-cloud-starter-bus-amqp</artifactId>
  16.     </dependency>
  17. </dependencies>
  18. <repositories>
  19.     <repository>
  20.         <id>spring-snapshots</id>
  21.         <name>Spring Snapshots</name>
  22.         <url>https://repo.spring.io/libs-snapshot</url>
  23.         <snapshots>
  24.             <enabled>true</enabled>
  25.         </snapshots>
  26.     </repository>
  27. </repositories>

只要classpath中包含AMQP和RabbitMQ，Spring Boot应用将尝试连接RabbitMQ服务http://localhost:5672（spring.rabbitmq.addresses默认值）

  1. @Configuration
  2. @EnableAutoConfiguration
  3. @RestController
  4. public class Application {
  6.   @RequestMapping("/")
  7.   public String home() {
  8.     return "Hello World";
  9.   }
  11.   public static void main(String[] args) {
  12.     SpringApplication.run(Application.class, args);
  13.   }
  15. }

Sample Projects

Bus Clients