Spring Cloud(七)《基於RabbitMQ消息總線方式刷新配置服務》

微信公衆號：bugstack蟲洞棧 沉澱、分享、成長，專一於原創專題案例，以最易學習編程的方式分享知識，讓本身和他人都能有所收穫。目前已完成的專題有；Netty4.x實戰專題案例、用Java實現JVM、基於JavaAgent的全鏈路監控、手寫RPC框架、架構設計專題案例[Ing]等。

前言介紹

在微服務架構中，爲了更方便的向微服務實例廣播消息，咱們一般會構建一個消息中心，讓全部的服務實例都鏈接上來，而該消息中心所發佈的消息都會被微服務實例監聽和消費，咱們把這種機制叫作消息總線(SpringCloud Bus)

當咱們的微服務達到是幾個到百個以上，在更新配置時，不太可能一個個刷新或者重啓，這樣既不能保證效率也容易致使遺漏形成事故。所以咱們須要SpringCloud Bus 提供總線服務，在咱們push代碼到Git的時候，經過Webhooks（http://localhost:port/actuator/bus-refresh/）執行刷新，消息總線會通知各個實例更新配置，以達到自動更新全服務配置。

環境準備

1. jdk 1.八、idea201八、Maven3
2. Spring Boot 2.0.6.RELEASE
3. Spring Cloud Finchley.SR2
4. 須要有一個Git賬號，用來建立配置中心以及開啓Webhooks服務，添加回調
5. RabbitMQ服務端環境安裝
   1. 下載Erlang；www.erlang.org/downloads ｛安裝後配置環境變量：D:\Program Files\erl10.5｝
   2. 下載rabbitMQ；www.rabbitmq.com/download.ht… ｛安裝後CMD依次執行｝
      • cd D:\Program Files\RabbitMQ Server\rabbitmq_server-3.8.1\sbin
      • rabbitmq-plugins.bat enable rabbitmq_management
      • rabbitmq-service.bat stop
      • rabbitmq-service.bat start
      • 瀏覽器訪問；http://127.0.0.1:15672
      • 服務端口5672

代碼示例

itstack-demo-springcloud-07
├── itstack-demo-springcloud-config-client
│   └── src
│       └── main
│           ├── java
│           │   └── org.itstack.demo
│           │        ├── web
│           │        │   └── ConfigClientController.java      
│           │        └── ConfigClientApplication.java
│           └── resources   
│               ├── application.yml
│               └── bootstrap.yml
├── itstack-demo-springcloud-config-server
│   └── src
│       └── main
│           ├── java
│           │   └── org.itstack.demo   
│           │        └── ConfigServerApplication.java
│           └── resources   
│               └── application.yml
└── itstack-demo-springcloud-eureka-server
     └── src
        └── main
            ├── java
            │   └── org.itstack.demo   
            │        └── EurekaServerApplication.java
            └── resources   
                └── application.yml
複製代碼

完整代碼歡迎關注公衆號：bugstack蟲洞棧 回覆「SpringCloud專題」進行下載

itstack-demo-springcloud-config-client | 配置獲取客戶端方，提供自動刷新Http

web/ConfigClientController.java & 添加註解@RefreshScope自動刷新配置

/** * 微信公衆號：bugstack蟲洞棧 | 沉澱、分享、成長，專一於原創專題案例 * 論壇：http://bugstack.cn * Create by 付政委 on @2019 */
@RestController
@RefreshScope
public class ConfigClientController {

    @Value("${info.profile:error}")
    private String profile;

    @GetMapping("/config")
    public Mono<String> config() {
        return Mono.justOrEmpty(profile);
    }

}
複製代碼

ConfigClientApplication.java & 普通配置便可

/** * 微信公衆號：bugstack蟲洞棧 | 沉澱、分享、成長，專一於原創專題案例 * 論壇：http://bugstack.cn * Create by 付政委 on @2019 */
@SpringBootApplication
public class ConfigClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConfigClientApplication.class, args);
    }

}
複製代碼

application.yml & 須要配置endpoints，這樣才能夠暴漏刷新服務

spring:
  application:
    name: itstack-demo-springcloud-config-client
  cloud:
    bus:
      trace:
        enabled: true
      enabled: true
server:
  port: 9001

# 若是不使用消息總線，則開啓以下配置 /actuator/refresh 這個 Endpoint 暴露出來
#management:
#  endpoints:
#    web:
#      exposure:
#        include: refresh
複製代碼

bootstrap.yml & 配置中心服務配置，http://localhost:7397 添加配置服務

spring:
  cloud:
    config:
      name: config-client         # 對應 {application} 部分，例如；config-client-dev = 只取最後一個符號'-'以前的
      profile: dev                # 對應 {profile} 部分
      label: master               # 對應 {label} 部分，即 Git 的分支。若是配置中心使用的是本地存儲，則該參數無用
      discovery:
        enabled: true             # 開啓 config 服務發現支持
        service-id: itstack-demo-springcloud-config-server        # 配置服務name

#配置文件會被轉換成 Web，訪問規則以下；
#/{application}/{profile}[/{label}]
#/{application}-{profile}.yml
#/{label}/{application}-{profile}.yml
#/{application}-{profile}.properties
#/{label}/{application}-{profile}.properties

eureka:
  client:
    service-url:
      defaultZone: http://localhost:7397/eureka/
複製代碼

itstack-demo-springcloud-config-server | 配置提供服務端方，連接Git配置工程地址

ConfigServerApplication.java & 添加註解@EnableConfigServer設置成配置服務中心

/** * 微信公衆號：bugstack蟲洞棧 | 沉澱、分享、成長，專一於原創專題案例 * 論壇：http://bugstack.cn * Create by 付政委 on @2019 */
@SpringBootApplication
@EnableConfigServer
public class ConfigServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConfigServerApplication.class, args);
    }

}
複製代碼

application.yml & 配置信息，消息總線刷新

server:
  port: 8080

spring:
  application:
    name: itstack-demo-springcloud-config-server
  cloud:
    config:
      server:
        git:
          uri: https://github.com/fuzhengwei/itstack-demo-config  # 換成本身的配置Git倉庫的地址，若是沒有能夠新建工程地址，也能夠克隆個人；https://github.com/fuzhengwei/itstack-demo-config
          search-paths: config-repo                               # Git倉庫地址下的底層配置文件名稱，若是配置多個用逗號','分割。

# 若是配置中心須要訪問權限，則開啓配置
# spring.cloud.config.server.git.username：Github帳戶
# spring.cloud.config.server.git.password：Github密碼

eureka:
  client:
    service-url:
      defaultZone: http://localhost:7397/eureka/
management:
  endpoints:
    web:
      exposure:
        include: bus-refresh
複製代碼

itstack-demo-springcloud-eureka-server | 服務註冊發現

EurekaServerApplication.java & 添加註解@EnableEurekaServer啓動服務發現

/** * 微信公衆號：bugstack蟲洞棧 | 沉澱、分享、成長，專一於原創專題案例 * 論壇：http://bugstack.cn * Create by 付政委 on @2019 */
@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {

    public static void main(String[] args) {
        SpringApplication.run( EurekaServerApplication.class, args );
    }

}
複製代碼

application.yml & 配置信息

server:
  port: 7397

eureka:
  instance:
    hostname: localhost
  client:
    registerWithEureka: false
    fetchRegistry: false
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

spring:
  application:
    name: itstack-demo-springcloud-eureka-server
複製代碼

測試驗證

1. 準備好本身Github的配置倉庫，也能夠克隆個人Git；github.com/fuzhengwei/… ｛有一組配置配置文件｝

2. 配置Webhooks，在https://github.com/換你本身的fuzhengwei/換你本身的itstack-demo-netty/settings/hooks/new

3. 分別啓動服務

   1. 啓動RabbitMQ服務；http://127.0.0.1:15672/#/
   2. itstack-demo-springcloud-eureka-server 服務註冊發現
   3. itstack-demo-springcloud-config-server 配置Server
   4. itstack-demo-springcloud-config-client 配置Client

4. 訪問配置服務，端口7397；http://localhost:8080/config-client/dev

   1. 訪問結果

   {
   	"name": "config-client",
   	"profiles": [
   		"dev"
   	],
   	"label": null,
   	"version": "ea0b1a1017595d542aa01b8b2bda68f9620dd81a",
   	"state": null,
   	"propertySources": [
   		{
   			"name": "https://github.com/fuzhengwei/itstack-demo-config/config-repo/config-client-dev.yml",
   			"source": {
   				"info.profile": "dev bus"
   			}
   		}
   	]
   }
   複製代碼

   2. 訪問規則｛配置文件會被轉換成 Web 接口，規則以下｝
   • /{application}/{profile}[/{label}]
   • /{application}-{profile}.yml
   • /{label}/{application}-{profile}.yml
   • /{application}-{profile}.properties
   • /{label}/{application}-{profile}.properties
   3. 訪問配置文件；http://localhost:8080/config-client-dev.yml ｛能夠直接訪問查看配置信息｝

   info:
   	profile: dev bus
   複製代碼

5. 訪問使用配置的客戶端

   1. 訪問端口9001；http://localhost:9001/config

      dev bus
      複製代碼

   2. 更改配置，POST請求刷新配置總線；http://localhost:8080/actuator/bus-refresh/ ｛若是配置Git的Webhooks則更新代碼自動刷新｝
   3. 訪問端口9001；http://localhost:9001/config

      dev
      複製代碼

綜上總結

1. Spring Cloud Bus 能夠更加方便的控制全局信息，用於統一刷新並經過MQ方式經過客戶端
2. 若是你的內網想進行Git的Webhooks配置，可使用http://natapp.cn進行內網穿透映射，他會給你提供免費外網調用服務
3. 消息總線方式不僅是應用於配置刷新，在一塊兒同步信息請求中均可以使用，以及本身的項目架設上

---