Spring Boot + Spring Cloud 實現權限管理系統 後端篇(十八):註冊中心(Spring Cloud Consul)

什麼是 Consul

Consul 是 HashiCorp 公司推出的開源工具,用於實現分佈式系統的服務發現與配置。與其它分佈式服務註冊與發現的方案,Consul 的方案更「一站式」,內置了服務註冊與發現框架、分佈一致性協議實現、健康檢查、Key/Value 存儲、多數據中心方案,再也不須要依賴其它工具(好比 ZooKeeper 等)。使用起來也較爲簡單。Consul 使用 Go 語言編寫,所以具備自然可移植性(支持Linux、windows和Mac OS X);安裝包僅包含一個可執行文件,方便部署,與 Docker 等輕量級容器可無縫配合。html

Consul 安裝

訪問 Consul 官網 ,根據操做系統類型,選擇下載 Consul 的最新版本。我這裏選擇windows版本。前端

下載下來是一個zip壓縮包,解壓以後,是一個exe可執行文件。java

 打開CMD終端,進入consul.exe所在目錄,執行以下命令啓動Consul服務。mysql

cd C:\consul_1.3.0_windows_amd64  # 進入consul.exe所在目錄
consul agent -dev # 啓動服務, -dev 表示開發模式運行,另外還有 -server 表示服務模式運行

啓動過程信息以下圖所示。git

啓動成功以後,訪問 http://localhost:8500 , 能夠查看 Consul 管理界面。web

kitty-monitor改造

改造 kitty-monitor 工程,做爲服務註冊到註冊中心。spring

添加依賴

添加Spring Cloud依賴文件,Consul註冊中心依賴。sql

pom.xmlwindows

<!--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/ 版權全部,歡迎轉載,轉載請註明原文做者及出處。

相關文章
相關標籤/搜索