Spring Boot + Spring Cloud 實現權限管理系統 后端篇（十八）：注冊中心（Spring Cloud Consul）

什么是 Consul

Consul 是 HashiCorp 公司推出的開源工具，用於實現分布式系統的服務發現與配置。與其它分布式服務注冊與發現的方案，Consul 的方案更“一站式”，內置了服務注冊與發現框架、分布一致性協議實現、健康檢查、Key/Value 存儲、多數據中心方案，不再需要依賴其它工具（比如 ZooKeeper 等）。使用起來也較為簡單。Consul 使用 Go 語言編寫，因此具有天然可移植性(支持Linux、windows和Mac OS X)；安裝包僅包含一個可執行文件，方便部署，與 Docker 等輕量級容器可無縫配合。

Consul 安裝

訪問 Consul 官網 ，根據操作系統類型，選擇下載 Consul 的最新版本。我這里選擇windows版本。

下載下來是一個zip壓縮包，解壓之后，是一個exe可執行文件。

 打開CMD終端，進入consul.exe所在目錄，執行如下命令啟動Consul服務。

cd C:\consul_1.3.0_windows_amd64　　# 進入consul.exe所在目錄

consul agent -dev        # 啟動服務, -dev 表示開發模式運行，另外還有 -server 表示服務模式運行

啟動過程信息如下圖所示。

啟動成功之后，訪問 http://localhost:8500 ， 可以查看 Consul 管理界面。

kitty-monitor改造

改造 kitty-monitor 工程，作為服務注冊到注冊中心。

添加依賴

添加Spring Cloud依賴文件，Consul注冊中心依賴。

pom.xml

<!--consul-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>

<!--srping cloud-->
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

配置文件

修改配置文件，添加服務注冊配置。

application.yml

server:
  port: 8000
spring:
  application:
    name: kitty-monitor
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        serviceName: ${spring.application.name}    # 注冊到consul的服務名稱

啟動類

修改啟動類，添加 @EnableDiscoveryClient 注解，開啟服務發現支持。

KittyMonitorApplication.java

package com.louis.kitty.monitor;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

import de.codecentric.boot.admin.server.config.EnableAdminServer;

/**
 * 啟動器
 * @author Louis
 * @date Oct 29, 2018
 */
@EnableAdminServer
@EnableDiscoveryClient
@SpringBootApplication
public class KittyMonitorApplication {

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

測試效果

啟動服務監控服務器，訪問 http://localhost:8500，發現服務已經成功注冊到注冊中心。

訪問 http://localhost:8000，查看服務監控管理界面，看到如下界面就沒問題了。

 

kitty-backup改造

改造 kitty-backup工程，作為服務注冊到注冊中心。

添加依賴

添加Spring Cloud依賴文件，Consul注冊中心依賴。

pom.xml

<!--consul-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>

<!--srping cloud-->
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

配置文件

修改配置文件，添加服務注冊配置，健康檢查接口開放配置。

application.yml

# tomcat
server:
  port: 8002
# spring boot admin
spring:
  application:
    name: kitty-backup
  boot:
    admin:
      client:
        url: "http://localhost:8000"
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        serviceName: ${spring.application.name}    # 注冊到consul的服務名稱
# 開放健康檢查接口
management:
  endpoints:
    web:
      exposure:
        include: "*"
  endpoint:
    health:
      show-details: ALWAYS
# backup datasource
kitty:
  backup:
    datasource:
      host: localhost
      userName: root
      password: 123456
      database: kitty

啟動類

修改啟動類，添加 @EnableDiscoveryClient 注解，開啟服務發現支持。

KittyBackupApplication.java

package com.louis.kitty.backup;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * 啟動器
 * @author Louis
 * @date Oct 29, 2018
 */
@EnableDiscoveryClient
@SpringBootApplication(scanBasePackages={"com.louis.kitty"})
public class KittyBackupApplication {

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

測試效果

啟動服務監控服務器，訪問 http://localhost:8500，發現服務已經成功注冊到注冊中心。

訪問 http://localhost:8000，查看服務監控管理界面，發現服務已經在監控列表里了。

點擊服務，進入詳情頁面，可以看到服務相關的各種指標信息，比如進程、線程、內存使用、垃圾回收等等。

 

kitty-admin改造

同理，改造 kitty-admin工程，作為服務注冊到注冊中心。

添加依賴

添加Spring Cloud依賴文件，Consul注冊中心依賴。

pom.xml

<!--consul-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>

<!--srping cloud-->
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

配置文件

修改配置文件，添加服務注冊配置，健康檢查接口開放配置。

application.yml

server:
  tomcat:
    uri-encoding: UTF-8
    max-threads: 1000
    min-spare-threads: 30
  port: 8001
    #context-path: /kitty-admin
# DataSource
spring:
  datasource:
    name: druidDataSource
    type: com.alibaba.druid.pool.DruidDataSource
    druid:
      driver-class-name: com.mysql.jdbc.Driver
      url: jdbc:mysql://localhost:3306/kitty?useUnicode=true&zeroDateTimeBehavior=convertToNull&autoReconnect=true&characterEncoding=utf-8
      username: root
      password: 123456
      filters: stat,wall,log4j,config
      max-active: 100
      initial-size: 1
      max-wait: 60000
      min-idle: 1
      time-between-eviction-runs-millis: 60000
      min-evictable-idle-time-millis: 300000
      validation-query: select 'x'
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      pool-prepared-statements: true
      max-open-prepared-statements: 50
      max-pool-prepared-statement-per-connection-size: 20
  # spring boot admin
  application:
    name: kitty-admin
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        serviceName: ${spring.application.name}    # 注冊到consul的服務名稱
  boot:
    admin:
      client:
        url: "http://localhost:8000"
# 開放健康檢查接口
management:
  endpoints:
    web:
      exposure:
        include: "*"
  endpoint:
    health:
      show-details: ALWAYS
# pagehelper   
pagehelper:
    helperDialect: mysql
    reasonable: true
    supportMethodsArguments: true
    params: count=countSql

啟動類

修改啟動類，添加 @EnableDiscoveryClient 注解，開啟服務發現支持。

KittyAdminApplication.java

package com.louis.kitty.admin;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * 啟動器
 * @author Louis
 * @date Oct 29, 2018
 */
@EnableDiscoveryClient
@SpringBootApplication(scanBasePackages={"com.louis.kitty"})
public class KittyAdminApplication {

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

測試效果

啟動服務監控服務器，訪問 http://localhost:8500，發現服務已經成功注冊到注冊中心。

 

 

訪問 http://localhost:8000，查看服務監控管理界面，發現服務已經在監控列表里了。

 

但是點擊進入詳情頁，發現並沒有展示上面備份服務一樣的信息，而是顯示“invalid token”信息。

 

那是監控服務器到客戶端獲取健康信息失敗了，因為獲取信息的接口被我們的Shiro給攔截了。

修改Shiro配置，使監控信息獲取接口無需進行登錄認證，添加如下圖所示內容。

ShiroConfig.java

 

修改完成之后，重啟服務，在此查看詳情頁面，終於成功獲取到監控信息了。 

 

 

源碼下載

后端：https://gitee.com/liuge1988/kitty

前端：https://gitee.com/liuge1988/kitty-ui.git

---

作者：朝雨憶輕塵
出處：https://www.cnblogs.com/xifengxiaoma/ 
版權所有，歡迎轉載，轉載請注明原文作者及出處。