javascript
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-consumercloud:consul:host: localhostport: 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-providercloud:consul:host: localhostport: 8500 復制代碼添加監控依賴:
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId> </dependency>復制代碼創建LoginService類,提供login方法供Consumer端調用
public class LoginService {("/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指定需要調用的服務名稱:
(name = "leon-provider") public interface UserFeignClient {(value = "/login", method = RequestMethod.GET)public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord); }復制代碼創建Controller類調用Provider服務方法:
public class UserController {private UserFeignClient userFeignClient;/*** 用戶賬號名和密碼登錄** @param userName* @param passWord* @return*/("/login")public String login(@RequestParam("userName") String userName, @RequestParam("passWord") String passWord) {return userFeignClient.login(userName, passWord);}} 復制代碼在啟動類上添加注解:@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-providercloud:consul:host: localhostport: 8500 復制代碼修改leon-provider-1、leon-provider-2的方法,添加識別信息:
("/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"; } 復制代碼("/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: localhostport: 8500discovery:health-check-interval: 3s //3秒后如果服務停掉,檢測界面會立即更新為非正常狀態 復制代碼轉載于:https://juejin.im/post/5d00c19be51d454f723024e3
與50位技術專家面對面20年技術見證,附贈技術全景圖總結
以上是生活随笔為你收集整理的Spring Cloud 基于Consul 实现服务注册与发现的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 一条数据的漫游 -- X-Engine
- 下一篇: 一次失败的尝试,h5+Api 结合 re