Spring Cloud消息总线

  • 时间:
  • 浏览:4
  • 来源:uu快3开奖_uu快3娱乐_输钱

2.启动依赖服务

user-service-client依赖:

内控 事件类型

集群传播

POST http://localhost:150150/bus/refresh?destination=user-service-client:**

执行 curl:

kafka

POST请求 /bus/env

咋样定位 Application Context ID

通过访问http://localhost:150150/beans确认当前Application Context ID

RefreshListener监听事件RefreshRemoteApplicationEvent

自定义RefreshRemoteApplicationEven监听器

日志输出:

日志输出:

Spring Cloud Bus

控制台输出:

改造user-service-client:使用 AMQP 整合 Spring Cloud Bus

1.增加 Maven 依赖

EnvironmentChangeListener是默认的EnvironmentChangeRemoteApplicationEvent监听器实现

/trace的变化:

事件跟踪

默认事件跟踪功能是失效,可以通过配置项激活:spring.cloud.bus.trace.enabled=ture

端点:/trace

事件跟踪详情

通过日志可知事件监听器均为:org.springframework.cloud.bus.event.RefreshListener:

POST http://localhost:150150/bus/refresh?destination=user-service-client:150150

执行curl: