1. 程式人生 > >eureka分割槽的深入講解

eureka分割槽的深入講解

背景

使用者量比較大或者使用者地理位置分佈範圍很廣的專案,一般都會有多個機房。這個時候如果上線springCloud服務的話,我們希望一個機房內的服務優先呼叫同一個機房內的服務,當同一個機房的服務不可用的時候,再去呼叫其它機房的服務,以達到減少延時的作用。

概念

eureka提供了region和zone兩個概念來進行分割槽,這兩個概念均來自於亞馬遜的AWS:

  • region:可以簡單理解為地理上的分割槽,比如亞洲地區,或者華北地區,再或者北京等等,沒有具體大小的限制。根據專案具體的情況,可以自行合理劃分region。
  • zone:可以簡單理解為region內的具體機房,比如說region劃分為北京,然後北京有兩個機房,就可以在此region之下劃分出zone1,zone2兩個zone。

分割槽服務架構圖

如圖所示,有一個region:beijing,下面有zone-1和zone-2兩個分割槽,每個分割槽內有一個註冊中心Eureka Server和一個服務提供者Service。
我們在zone-1內建立一個Consumer-1服務消費者的話,其會優先呼叫同一個zone內的Service-1,當Service-1不可用時,才會去呼叫zone-2內的Service-2。

配置

  1. Eureka Server-1:

    spring:
      application:
        name: Server-1
    server:
      port: 30000
    eureka:
      instance:
        prefer-ip-address: true
        status-page-url-path: /actuator/info
        health-check-url-path: /actuator/health
        hostname: localhost
      client:
        register-with-eureka: true
        fetch-registry: true
        prefer-same-zone-eureka: true
        #地區
        region: beijing
        availability-zones:
          beijing: zone-1,zone-2
        service-url:
          zone-1: http://localhost:30000/eureka/
          zone-2: http://localhost:30001/eureka/

     

  2. Eureka Server-2:

    spring:
      application:
        name: Server-2
    server:
      port: 30001
    eureka:
      instance:
        prefer-ip-address: true
        status-page-url-path: /actuator/info
        health-check-url-path: /actuator/health
        hostname: localhost
      client:
        register-with-eureka: true
        fetch-registry: true
        prefer-same-zone-eureka: true
        #地區
        region: beijing
        availability-zones:
          beijing: zone-2,zone-1
        service-url:
          zone-1: http://localhost:30000/eureka/
          zone-2: http://localhost:30001/eureka/

     

  3. Service-1:

    測試程式碼:

    @RestController
    public class HiController {
        @Value("${zone.name}")
        private String zoneName;
        
        @RequestMapping(value = "/hi", method = RequestMethod.GET)
        public String hi() {
            return zoneName;
        }
    }

     

    配置檔案:

    spring:
      application:
        name: service
    server:
      port: 30010
    eureka:
      instance:
        prefer-ip-address: true
        status-page-url-path: /actuator/info
        health-check-url-path: /actuator/health
        metadata-map:
          zone: zone-1
      client:
        register-with-eureka: true
        fetch-registry: true
        prefer-same-zone-eureka: true
        #地區
        region: beijing
        availability-zones:
          beijing: zone-1,zone-2
        service-url:
          zone-1: http://localhost:30000/eureka/
          zone-2: http://localhost:30001/eureka/
    
    zone.name: zone-1

     

  4. Service-2:

    spring:
      application:
        name: service
    server:
      port: 30011
    eureka:
      instance:
        prefer-ip-address: true
        status-page-url-path: /actuator/info
        health-check-url-path: /actuator/health
        metadata-map:
          zone: zone-2
      client:
        register-with-eureka: true
        fetch-registry: true
        prefer-same-zone-eureka: true
        #地區
        region: beijing
        availability-zones:
          beijing: zone-2,zone-1
        service-url:
          zone-1: http://localhost:30000/eureka/
          zone-2: http://localhost:30001/eureka/
    
    zone.name: zone-2

     

  5. Consumer-1:

    呼叫服務程式碼:

    @RestController
    public class HiController {
        @Autowired
        private RestTemplate restTemplate;
    
        @RequestMapping(value="/consumer")
        public String hi() {
            return restTemplate.getForObject("http://service/hi", String.class);
        }
    }

     

    配置檔案:

    spring:
      application:
        name: consumer
    server:
      port: 30030
    eureka:
      instance:
        prefer-ip-address: true
        status-page-url-path: /actuator/info
        health-check-url-path: /actuator/health
        metadata-map:
          zone: zone-1
      client:
        register-with-eureka: true
        fetch-registry: true
        prefer-same-zone-eureka: true
        #地區
        region: beijing
        availability-zones:
          beijing: zone-1,zone-2
        service-url:
          zone-1: http://localhost:30000/eureka/
          zone-2: http://localhost:30001/eureka/

     

效果演示

可以看到Consumer-1優先呼叫的是同一個zone-1的Service-1,這個時候,無論怎麼重新整理,呼叫多少次,都只會呼叫Service-1,不會呼叫Service-2.

當我們把Service-1服務停掉,再呼叫的話:

才會呼叫zone-2分割槽下的Service-2。

配置檔案講解

整個分割槽分為兩步:

  1. 服務註冊:要保證服務註冊到同一個zone內的註冊中心,因為如果註冊到別zone的註冊中心的話,網路延時比較大,心跳檢測很可能出問題。
  2. 服務呼叫:要保證優先呼叫同一個zone內的服務,只有在同一個zone內的服務不可用時,才去呼叫別zone的服務。

1. 服務註冊的配置檔案

eureka:
  client:
    prefer-same-zone-eureka: true
    #地區
    region: beijing
    availability-zones:
      beijing: zone-1,zone-2
    service-url:
      zone-1: http://localhost:30000/eureka/
      zone-2: http://localhost:30001/eureka/

 

當一個服務(作為一個eureka client)向註冊中心(eureka server)註冊的時候,會根據eureka.client下的配置來進行註冊。這裡我們主要關心有多個註冊中心的情況下,服務會註冊到哪個註冊中心,並且和哪個註冊中心來維持心跳檢測。
註冊中心選擇邏輯
1. 如果prefer-same-zone-eureka為false,按照service-url下的 list取第一個註冊中心來註冊,並和其維持心跳檢測。不會再向list內的其它的註冊中心註冊和維持心跳。只有在第一個註冊失敗的情況下,才會依次向其它的註冊中心註冊,總共重試3次,如果3個service-url都沒有註冊成功,則註冊失敗。每隔一個心跳時間,會再次嘗試。
2. 如果prefer-same-zone-eureka為true,先通過region取availability-zones內的第一個zone,然後通過這個zone取service-url下的list,並向list內的第一個註冊中心進行註冊和維持心跳,不會再向list內的其它的註冊中心註冊和維持心跳。只有在第一個註冊失敗的情況下,才會依次向其它的註冊中心註冊,總共重試3次,如果3個service-url都沒有註冊成功,則註冊失敗。每隔一個心跳時間,會再次嘗試。

所以說,為了保證服務註冊到同一個zone的註冊中心,一定要注意availability-zones的順序,必須把同一zone寫在前面

2. 服務呼叫的配置檔案

eureka:
  instance:
    metadata-map:
      zone: zone-1

 

服務消費者和服務提供者分別屬於哪個zone,均是通過eureka.instance.metadata-map.zone來判定的。
服務消費者會先通過ribbon去註冊中心拉取一份服務提供者的列表,然後通過eureka.instance.metadata-map.zone指定的zone進行過濾,過濾之後如果同一個zone內的服務提供者有多個例項,則會輪流呼叫。
只有在同一個zone內的所有服務提供者都不可用時,才會呼叫其它zone內的服務提供者。

擴充套件

eureka.instance.lease-renewal-interval-in-seconds: 30

服務和註冊中心的心跳間隔時間,預設為30s

 

eureka.instance.lease-expiration-duration-in-seconds: 90

服務和註冊中心的心跳超時時間,預設為90s

也就是說,當一個服務異常down掉後,90s之後註冊中心才會知道這個服務不可用了。在此期間,依舊會把這個服務當成正常服務。ribbon呼叫仍會把請求轉發到這個服務上。為了避免這段期間出現無法提供服務的情況,要開啟ribbon的重試功能,去進行其它服務提供者的重試。

 

轉自:https://segmentfault.com/a/1190000014107639