SpringCloud系列——Bus 消息總線

本文轉載自查看原文 2018-12-21 12:29 3699 springcloud

　　前言

　　SpringCloud Bus使用輕量級消息代理將分布式系統的節點連接起來。然后可以使用此代理廣播狀態更改(例如配置更改)或其他管理指令。本文結合RabbitMQ+GitHub的Webhook實現上篇博客Config配置中心（SpringCloud系列——Config 配置中心）的自動刷新

　　官方文檔：https://cloud.spring.io/spring-cloud-static/spring-cloud-bus/2.1.0.RC3/single/spring-cloud-bus.html

　　RabbitMQ安裝

　　參考：https://www.cnblogs.com/zhangweizhong/p/5689209.html

　　大概步驟：

　　1、先去下載Erlang、RabbitMQ

　　2、先安裝Erlang環境、配置ERLANG_HOME環境變量、安裝RabbitMQ

　　3、激活RabbitMQ 管理插件，登錄http://localhost:15672，使用默認賬號登錄，用戶名、密碼都是：guest

　　代碼編寫

　　確保RabbitMQ中間件可用之后我們開始對上一篇的項目進行調整，我這里直接使用默認賬號連接RabbitMQ，5672是RabbitMQ的監聽端口

　　Config Server

　　maven引入bus-amqp

        <!-- bus-RabbitMQ -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>

　　配置文件添加對RabbitMQ的相關配置

#bus-rabbitMQ
spring.cloud.bus.trace.enabled=true
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

　　同時，配置中心擔任調用/bus-refresh的任務

#暴露端點
management.endpoints.web.exposure.include=bus-refresh

　　Config Client

　　客戶端同時也要連接到消息總線

　　maven引jar

        <!-- bus-RabbitMQ -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>

　　配置文件添加

#bus-rabbitMQ
spring.cloud.bus.trace.enabled=true
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest