Spring Cloud 基於Consul 實現服務註冊與發現

Spring Cloud本身體系中的註冊中心爲Eureka,同時也支持其它服務來進行服務註冊與發現。本文介紹使用Consul來實現服務註冊與發現，並整合進Spring Cloud項目中進行使用。

本文項目依賴環境版本爲：

• Consul → 1.5.0
• Spring Cloud → Edgware.SR5
• Spring Boot → 1.5.21
• 操做系統 → Win10 （PowerShell）

啓動Consul服務

首先啓動Consul服務，使用如下命令：

.\consul.exe agent -server -ui -bootstrap -client 0.0.0.0 -data-dir="d:\consul\data" -bind 127.0.0.1
複製代碼

也可使用開發模式（更加簡單,自動開啓UI服務，可是不能保存數據狀態）

.\consul.exe agent -dev
複製代碼

服務啓動成功後訪問地址：http://localhost:8500 ，看到以下界面說明服務啓動成功

建立Consumer項目

新建Spring Boot項目，指定名稱爲：leon-consumer，在依賴中選擇Web、Consul Discovery,版本選擇爲1.5.21

修改配置文件application.yml,指定服務端口、名稱、Consul服務地址

server:
  port: 8081
spring:
  application:
    name: leon-consumer
  cloud:
    consul:
      host: localhost
      port: 8500
複製代碼

啓動程序，查看Consul web界面：

此時能夠看到服務已經註冊到Consul上，可是發現後紅色X提醒，點擊進入可查看詳細提示信息：

能夠看到錯誤提示是健康檢查方面的提示，這是由於Consul進行健康檢查須要依賴 Actuator 模塊，在pom.xml中添加依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

複製代碼

而後重啓程序，刷新瀏覽器再次觀察，此時發現就已經全是正常狀態

點擊後能夠看到當前服務的具體的名稱、IP、端口等信息。

建立Provider程序

新建Spring Boot項目，指定名稱爲：leon-provider-1，在依賴中選擇Web、Consul Discovery,版本選擇爲1.5.21 修改配置文件application.yml,指定服務端口、名稱、Consul服務地址

server:
  port: 8082
spring:
  application:
    name: leon-provider
  cloud:
    consul:
      host: localhost
      port: 8500
複製代碼

添加監控依賴：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

複製代碼

建立LoginService類，提供login方法供Consumer端調用

@RestController
public class LoginService {

    @RequestMapping("/login")
    public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord) {
        if (userName.equals("leon") && passWord.equals("888")) {
            return "login success";
        }
        return "login fail";
    }
}
複製代碼

改造Consumer服務

爲leon-consumer添加Feign相關依賴，而後調用Provider提供的接口 在leon-consumer項目的pom.xml中添加依賴：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-feign</artifactId>
</dependency>
複製代碼

建立一個接口：UserFeignClient，在裏面定義好須要調用的接口方法（和Provider提供的方法一致），同時添加@FeignClient註解，並經過name指定須要調用的服務名稱：

@FeignClient(name = "leon-provider")
public interface UserFeignClient {
    @RequestMapping(value = "/login", method = RequestMethod.GET)
    public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord);
}

複製代碼

建立Controller類調用Provider服務方法：

@RestController
public class UserController {

    @Autowired
    private UserFeignClient userFeignClient;

    /** * 用戶帳號名和密碼登陸 * * @param userName * @param passWord * @return */
    @RequestMapping("/login")
    public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord) {
        return userFeignClient.login(userName, passWord);
    }

}
複製代碼

在啓動類上添加註解：@EnableFeignClients

@SpringBootApplication
@EnableFeignClients
public class LeonConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(LeonConsumerApplication.class, args);
    }
}
複製代碼

運行測試

分別運行leon-provider、leon-consumer，而後訪問leon-consumer提供的login方法，分別傳入正確、錯誤參數查看效果：

說明服務已經可以經過註冊中心找到對應的服務調用。

服務集羣

複製leon-provider-1項目爲leon-provider-2,而後打開項目，更改項目端口爲8083

server:
  port: 8083
spring:
  application:
    name: leon-provider
  cloud:
    consul:
      host: localhost
      port: 8500
複製代碼

修改leon-provider-一、leon-provider-2的方法，添加識別信息：

@RequestMapping("/login")
public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord) {
    if (userName.equals("leon") && passWord.equals("888")) {
        return "leon-provider-1: login success";
    }
    return "leon-provider-1: login fail";
}
複製代碼

@RequestMapping("/login")
public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord) {
    if (userName.equals("leon") && passWord.equals("888")) {
        return "leon-provider-2: login success";
    }
    return "leon-provider-2: login fail";
}
複製代碼

分別重啓服務，能夠看到新增了同名的服務

而後刷新調用登陸方法，能夠看到會按照Spring Cloud體系中Ribbon的默認負載均衡策略輪詢調用不一樣的服務。

其它配置

服務檢測間隔

cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        health-check-interval: 3s //3秒後若是服務停掉，檢測界面會當即更新爲非正常狀態
複製代碼