此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 spring-cloud-bus 4.1.3spring-doc.cn

配置

自定义 Message Broker

Spring Cloud Bus 使用 Spring Cloud Stream 广播消息。因此,要使消息流向,您只需包含 Binder 在 Classpath 中选择的实现。巴士有方便的Starters 使用 AMQP (RabbitMQ) 和 Kafka ()。一般 说来,Spring Cloud Stream 依赖于 Spring Boot 自动配置约定 配置中间件。例如,可以使用配置属性更改 AMQP 代理地址。Spring Cloud Bus 有少量 native configuration properties in (例如,是要用作外部 中间件)。通常,默认值就足够了。spring-cloud-starter-bus-[amqp|kafka]spring.rabbitmq.*spring.cloud.bus.*spring.cloud.bus.destinationspring-doc.cn

要了解有关如何自定义消息代理设置的更多信息,请参阅 Spring Cloud 流文档。spring-doc.cn

跟踪总线事件

总线事件( 的子类 )可以通过设置 来跟踪。如果这样做,Spring Boot(如果存在)将显示发送的每个事件以及来自每个服务实例的所有 ack。这 以下示例来自终端节点:RemoteApplicationEventspring.cloud.bus.trace.enabled=trueTraceRepository/tracespring-doc.cn

{
  "timestamp": "2015-11-26T10:24:44.411+0000",
  "info": {
    "signal": "spring.cloud.bus.ack",
    "type": "RefreshRemoteApplicationEvent",
    "id": "c4d374b7-58ea-4928-a312-31984def293b",
    "origin": "stores:8081",
    "destination": "*:**"
  }
  },
  {
  "timestamp": "2015-11-26T10:24:41.864+0000",
  "info": {
    "signal": "spring.cloud.bus.sent",
    "type": "RefreshRemoteApplicationEvent",
    "id": "c4d374b7-58ea-4928-a312-31984def293b",
    "origin": "customers:9000",
    "destination": "*:**"
  }
  },
  {
  "timestamp": "2015-11-26T10:24:41.862+0000",
  "info": {
    "signal": "spring.cloud.bus.ack",
    "type": "RefreshRemoteApplicationEvent",
    "id": "c4d374b7-58ea-4928-a312-31984def293b",
    "origin": "customers:9000",
    "destination": "*:**"
  }
}

前面的跟踪显示 a 是从 发送到所有服务的,并由 和 接收 (acked)。RefreshRemoteApplicationEventcustomers:9000customers:9000stores:8081spring-doc.cn

要自己处理 ack 信号,你可以为应用程序添加 for the 和 类型(并启用 跟踪)。或者,您可以利用 并从中挖掘数据 那里。@EventListenerAckRemoteApplicationEventSentApplicationEventTraceRepositoryspring-doc.cn

任何 Bus 应用程序都可以跟踪 ack。然而,有时,它是 在可以执行更复杂的 查询数据或将其转发到专门的跟踪服务。