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