SpringCloud Eureka-服務注冊與發現02
3.搭建EurekaServer集群-實作負載均衡&故障容錯
3.1為什么需要集群EurekaServer？
- 微服務RPC遠程服務呼叫最核心的是高可用
- 如果注冊中心只有1個，如果出現故障，會導致整個服務環境不可用
- 解決辦法就是搭建Eureka注冊中心集群，實作負載均衡和故障容錯（構成集群的幾個主機之間的提供的服務是相同的）
3.2搭建EurekaServer集群
3.2.1搭建第二個注冊中心
搭建 e-commerce-eureka-server-9002 微服務模塊，作為第二個 EurekaServer -注冊中心，
搭建的具體步驟和 e-commerce-eureka-server-9001 一樣，見上篇2.2
（1）創建Module，在pom.xml加入相關依賴（略）
（2）創建組態檔application.yml
server:
port: 9002
#配置Eureka-server
eureka:
instance:
hostname: eureka9002.com #服務實體名
client: #如果Eureka是一個集群，那么相互兩個EurekaServer之間也可以當做對方為客戶端
#配置是否向注冊中心注冊自己
register-with-eureka: false
#表示自己就是注冊中心，作用是維護注冊的服務實體，不需要去檢索服務
fetch-registry: false
service-url:
#當前的注冊中心 需要注冊到 Eureka9001 注冊中心
defaultZone: http://eureka9001.com:9001/eureka/
（3）創建主啟動類
package com.li.springcloud;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
/**
* @author 李
* @version 1.0
*/
@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication9002 {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication9002.class,args);
}
}
3.2.2修改第一個注冊中心
（1）修改 e-commerce-eureka-server-9001 的 application.yml 檔案
server:
port: 9001
#配置Eureka-server
eureka:
instance:
hostname: eureka9001.com #服務實體名
client: #如果Eureka是一個集群，那么相互兩個EurekaServer之間也可以當做對方為客戶端
#配置是否向注冊中心注冊自己
register-with-eureka: false
#表示自己就是注冊中心，作用是維護注冊的服務實體，不需要去檢索服務
fetch-registry: false
service-url: #設定于 Eureka server 的互動模塊，查詢服務和注冊服務都需要依賴這個地址
#EurekaServer之間相互注冊
defaultZone: http://eureka9002.com:9002/eureka/
（2）將e-commerce-eureka-server-9001的主啟動類的名稱修改為 EurekaApplication9001
3.2.3修改host檔案
因為是在一臺電腦上模擬的集群，為了瀏覽器輸入類似eureka9002.com:9002/eureka/的地址，可以直接訪問到，這里修改host檔案，對上述指定域名進行本機的ip映射，
檔案位置：C:\Windows\System32\drivers\etc\hosts
3.2.4完成測驗
分別啟動兩個注冊中心，在瀏覽器中訪問上圖配置的地址：
3.3.5將其他微服務注冊到EurekaServer集群
（1）將member-service-provider-10000注冊到 EurekaServer 集群
部分配置：
eureka:
service-url:
#將本微服務注冊到多個EurekaServer，使用逗號間隔
defaultZone: http://eureka9001.com:9001/eureka,http://eureka9002.com:9002/eureka
（2）將member-service-consumer-80注冊到 EurekaServer 集群：同上，修改位置相同（略），
（3）啟動這些微服務，可以看到在所有EurekaServer的監控頁面中都注冊了上述微服務：
3.3搭建會員中心服務提供方集群
同樣的，為了高可用性，我們不僅在EurekaServer中要使用集群，在服務提供方也要使用集群（構成集群的幾個主機之間的提供的服務是相同的），
3.3.1搭建第二個服務提供方
所以參考 member-service-provider-10000 的代碼來創建 member-service-provider-10002 ，以下簡稱為10000 和 10002
（1）創建Module-member-service-provider-10002
（2）可以將磁盤下10000子模塊的main目錄復制替換10002的main目錄
（3）然后在10002的pom.xml中匯入和10000的pom.xml相同的依賴
（4）最后修改10002的埠和當前應用的名稱，并修改10002的主程式名稱，
（5）測驗
3.3.2注意事項和細節
因為member-service-provider-10000和member-service-provider-10002是作為一個集群對外提供服務的，因為我們需要將兩個微服務的spring.application.name進行統一，這樣消費方可以通過統一的別名進行負載均衡呼叫，
spring:
application:
name: member-service-provider #同一將服務提供方的應用名設定為member-service-provider
設定后，重新啟動服務啟動方，在EurekaServer中可以看到注冊串列中只有一個服務提供名，但是它包含了兩個遠程呼叫的介面：
3.4配置服務消費端使用會員中心服務集群
配置服務消費端 member-service-consumer-80，讓它可以使用會員中心服務集群，
（1）修改MemberConsumerController.java
package com.li.springcloud.controller;
import ...
/**
* @author 李
* @version 1.0
*/
@RestController
@Slf4j
public class MemberConsumerController {
@Resource
private RestTemplate restTemplate;
/**
* 1.MEMBER-SERVICE-PROVIDER 是服務提供方[集群]注冊到EurekaServer的別名
* 2.也是服務提供方[集群]對方暴露的名稱
* 3.這里MEMBER-SERVICE-PROVIDER 目前有兩個可以獲取的區域：
* member-service-provider-10000、member-service-provider-10002
*/
public static final String MEMBER_SERVICE_PROVIDER_URL =
"http://MEMBER-SERVICE-PROVIDER";//改為提供服務模塊的別名
//添加物件到資料庫表中
@PostMapping("/member/consumer/save")
public Result<Member> save(Member member) {
return restTemplate.postForObject
(MEMBER_SERVICE_PROVIDER_URL + "/member/save",
member,
Result.class);
}
//根據id呼叫服務介面，回傳member物件資訊
@GetMapping("/member/consumer/get/{id}")
public Result<Member> getMemberById(@PathVariable("id") Integer id) {
return restTemplate.getForObject
(MEMBER_SERVICE_PROVIDER_URL + "/member/get/" + id,
Result.class);
}
}
（2）修改 CustomInitBean.java
需要增加注解 @LoadBalanced，賦予 RestTemplate負載均衡能力，即選擇 MEMBER-SERVICE-PROVIDER 某一個服務訪問，默認是輪詢演算法
package com.li.springcloud.config;
import ...
/**
* @author 李
* @version 1.0
* 注入RestTemplate Bean
*/
@Configuration
public class CustomInitBean {
@Bean
@LoadBalanced //賦予RestTemplate負載均衡的能力，默認是使用輪詢演算法來訪問遠程呼叫介面
public RestTemplate getRestTemplate() {
return new RestTemplate();
}
}
（3）依次啟動EurekaServer集群、服務提供方集群、服務消費方
為了區分，可以在服務提供方的Controller中列印當前的服務提供方的名稱
-
先用瀏覽器直接訪問服務提供方集群的介面，目的是測驗服務提供方是否正常作業：
注意這里訪問的分別是不同的服務提供方的介面
-
在用瀏覽器訪問服務消費方的介面，測驗服務消費方是否正常作業：
可以看到瀏覽器訪問同一個地址（即只有一個服務消費方模塊），但是底層呼叫的服務提供方是不一樣的（輪詢訪問）
第一次訪問：
第二次訪問：
交替訪問member服務說明：
- 注解 @LoadBalanced底層是Ribbon支持演算法
- Ribbon和Eureka整合后，服務消費方可以直接呼叫服務，而不用再關心服務提供方的地址和埠號
- 該服務還有負載功能
3.5通過DiscoveryClient獲取EurekaServer服務注冊資訊
無論是服務消費方還是服務提供方，它們都是EurekaClient，如果希望獲取到EurekaServer的服務注冊資訊，可以使用DiscoveryClient，
這里以服務消費方為例，獲取EurekaServer的服務注冊資訊：
（1）修改 MemberConsumerController.java
package com.li.springcloud.controller;
import ...
/**
* @author 李
* @version 1.0
*/
@RestController
@Slf4j
public class MemberConsumerController {
@Resource
private RestTemplate restTemplate;
//裝配一個DiscoveryClient，
//注意用的包是 import org.springframework.cloud.client.discovery.DiscoveryClient;
@Resource
private DiscoveryClient discoveryClient;
@GetMapping("/member/consumer/discovery")
public Object discovery() {
List<String> services = discoveryClient.getServices();
for (String service : services) {
log.info("服務名={}", service);
//通過服務名來獲取服務名對應的實體
List<ServiceInstance> instances = discoveryClient.getInstances(service);
for (ServiceInstance instance : instances) {
log.info("id={},host={},port={},uri={}",
instance.getServiceId(), instance.getHost(),
instance.getPort(), instance.getUri());
}
}
return discoveryClient;
}
//其他方法略..
}
（2）修改啟動類，添加注解啟用服務發現
（3）重啟服務消費模塊，瀏覽器訪問 http://localhost/member/consumer/discovery，后臺輸出如下：
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/549398.html
標籤：其他
上一篇：java -- Math、BigInteger、BigDecimal類和基本型別的包裝類、正則運算式
下一篇：MyBatis常見問題