springCloud學習2(服務發現)

時間  2019-12-06
標籤 springcloud 學習 服務 發現 简体版
原文   原文鏈接

1、服務發現架構

  服務發現架構一般具備下面 4 個概念：java

  1. 服務註冊：服務如何使用服務發現代理進行註冊？
  2. 服務地址的客戶端查找：服務客戶端查找服務信息的方法是什麼？
  3. 信息共享：如何跨節點共享服務信息？
  4. 健康監測：服務如何將它的健康信息傳回給服務發現代理？

下圖展現了這 4 個概念的流程，以及在服務發現模式實現中一般發生的狀況：git

服務發現架構

  一般服務實例都只向一個服務發現實例註冊，服務發現實例之間再經過數據傳輸，讓每一個服務實例註冊到全部的服務發現實例中。   服務在向服務發現實例註冊後，這個服務就能被服務消費者調用了。服務消費者可使用多種模型來"發現"服務。github

  1. 每次調用服務時，經過服務發現層來獲取目標服務地址並進行調用。這種用的比較少，弊端較多。首先是每次服務調用都經過服務發現層來完成，耗時會比直接調用高。最主要的是這種方法很脆弱，消費端徹底依賴於服務發現層來查找和調用服務。
  2. 更健壯的方法是使用所謂的客戶端負載均衡。

  以下圖所示：算法

客戶端負載均衡

  在這個模型中，當服務消費者須要調用一個服務時：spring

  (1)聯繫服務發現層，獲取所請求服務的全部服務實例，而後放到本地緩存中。json

  (2)每次調用該服務時，服務消費者從緩存中取出一個服務實例的位置，一般這個'取出'使用簡單的複製均衡算法，如「輪詢」，「隨機",以確保服務調用分佈在全部實例之間。bootstrap

  (3)客戶端將按期與服務發現層進行通訊，並刷新服務實例的緩存。緩存

  (4)若是在調用服務的過程當中，服務調用失敗，那麼本地緩存將從服務發現層中刷新數據，再次嘗試。服務器

2、spring cloud 實戰

  使用 spring cloud 和 Netflix Eureka 搭建服務發現實例。微信

一、構建 Spring Eureka 服務

  eurekasvr POM 主要配置以下：

<!-- 其餘依賴省略 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
複製代碼

  applicaiton.yml 配置以下：

server:
 port: 8761

eureka:
 client:
    #不註冊本身
 register-with-eureka: false
    #不在本地緩存註冊表信息
 fetch-registry: false
 server:
    #接受請求前的等待實際，開發模式下不要開啓
    #wait-time-in-ms-when-sync-empty: 5
複製代碼

  最後在啓動類上加入註釋@SpringBootApplication便可啓動服務中心。服務中心管理頁面：http://localhost:8761

二、將服務註冊到服務中心

  這裏咱們編寫一個新服務註冊到服務中心,organizationservice：組織服務。並將上一篇的兩個服務：confsvr:配置中心服務,licensingservice:受權服務註冊到服務中心。

a、confvr 註冊

  首先修改 POM 文件：

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

  而後修改配置文件 application.yml:

server:
 port: 8888

eureka:
 instance:
    #註冊服務的IP，而不是服務器名
 prefer-ip-address: true
 client:
    #向eureka註冊服務
 register-with-eureka: true
    #拉取註冊表的本地副本
 fetch-registry: true
 service-url:
      #Eureka服務的位置(若是有多個註冊中心，使用,分隔）
 defaultZone: http://localhost:8761/eureka/

spring:
 profiles:
    # 使用文件系統來存儲配置信息，須要設置爲native
 active: native
 application:
 name: confsvr
 cloud:
 config:
 server:
 native:
          # 使用文件來存放配置文件,爲每一個應用程序提供用逗號分隔的文件夾列表
 searchLocations: file:///D:/configFolder/licensingservice,file:///D:/configFolder/organizationservice
複製代碼

  最後在啓動類加入註解@EnableDiscoveryClient,啓動便可在 eureka 管理頁面發現。

b、licensingservice 註冊

  首先修改 POM

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

  而後修改配置文件 bootstrap.yml

spring:
 application:
    #指定名稱，以便spring cloud config客戶端知道查找哪一個配置
 name: licensingservice
 profiles:
    #指定環境
 active: dev
 cloud:
 config:
      #設爲true便會自動獲取從配置中心獲取配置文件
 enabled: true
eureka:
 instance:
 prefer-ip-address: true
 client:
 register-with-eureka: true
 fetch-registry: true
 service-url:
 defaultZone: http://localhost:8761/eureka/
複製代碼

  最後在啓動類加入註解@EnableDiscoveryClient,啓動便可在 eureka 管理頁面發現本服務實例。

c、建立 organizationservice

  首先在文件夾file:///D:/configFolder/organizationservice下建立兩個配置文件：organizationservice.yml,organizationservice-dev.yml,內容分別爲：

#organizationservice-dev.yml
server:
 port: 10012
複製代碼
#organizationservice.yml
spring:
 application:
 name: organizationservice
複製代碼

  主要 POM 配置以下：

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

  而後修改配置文件，bootstrap.yml

spring:
 application:
    #指定名稱，以便spring cloud config客戶端知道查找哪一個配置
 name: organizationservice
 profiles:
    #指定環境
 active: dev
 cloud:
 config:
 enabled: true
eureka:
 instance:
 prefer-ip-address: true
 client:
 register-with-eureka: true
 fetch-registry: true
 service-url:
 defaultZone: http://localhost:8761/eureka/
複製代碼

  最後在啓動類加入註解@EnableDiscoveryClient,啓動。

三、使用服務發現來查找服務

  如今已經有兩個註冊服務了，如今來讓許可證服務調用組織服務，獲取組織信息。首先在 organizationservice 服務中的 controller 包中加入一個 controller 類,讓它可以響應請求:

//OrganizationController.java
@RestController
public class OrganizationController {

    @GetMapping(value = "/organization/{orgId}")
    public Object getOrganizationInfo(@PathVariable("orgId") String orgId) {
        Map<String, String> data = new HashMap<>(2);
        data.put("id", orgId);
        data.put("name", orgId + "公司");
        return data;
    }
}
複製代碼

  接下來讓許可證服務經過 Eureka 來找到組織服務的實際位置，而後調用該接口。爲了達成目的，咱們將要學習使用 3 個不一樣的 Spring/Netflix 客戶端庫，服務消費者可使用它們來和 Ribbon 進行交互。從最低級別到最高級別，這些庫包含了不一樣的與 Ribbon 進行交互的抽象封裝層次：

  • Spring DiscoveryClient
  • 啓用了 RestTemplate 的 Spring DiscoveryClient
  • Neflix Feign 客戶端

a、使用 Spring DiscoveryClient

  該工具提供了對 Ribbon 和 Ribbon 中緩存的註冊服務最低層次的訪問，能夠查詢經過 Eureka 註冊的全部服務以及這些服務對應的 URL。

  首先在 licensingservice 的啓動類中加入@EnableDiscoveryClient註解來啓用 DiscoveryClient 和 Ribbon 庫。

  而後在 service 包下建立 OrganizationService.java

@Service
public class OrganizationService {

    private static final String SERVICE_NAME = "organizationservice";
    private DiscoveryClient discoveryClient;

    @Autowired
    public OrganizationService(DiscoveryClient discoveryClient) {
        this.discoveryClient = discoveryClient;
    }

    /** * 使用Spring DiscoveryClient查詢 * * @param id * @return */
    public Organization getOrganization(String id) {
        RestTemplate restTemplate = new RestTemplate();
        List<ServiceInstance> instances = discoveryClient.getInstances(SERVICE_NAME);
        if (instances.size() == 0) {
            throw new RuntimeException("無可用的服務");
        }
        String serviceUri = String.format("%s/organization/%s", instances.get(0).getUri().toString(), id);
        ResponseEntity<Organization> responseEntity = restTemplate.exchange(serviceUri, HttpMethod.GET
                , null, Organization.class, id);
        return responseEntity.getBody();
    }
}
複製代碼

  接着在 controller 包中新建 LicensingController.java

@RestController
public class LicensingController {

    private OrganizationService organizationService;

    @Autowired
    public LicensingController(OrganizationService organizationService) {
        this.organizationService = organizationService;
    }

    @GetMapping("/licensing/{orgId}")
    public Licensing getLicensing(@PathVariable("orgId") String orgId) {
        Licensing licensing = new Licensing();
        licensing.setValid(false);
        licensing.setOrganization(organizationService.getOrganization(orgId));
        return licensing;
    }
}
複製代碼

  啓動全部項目，訪問localhost:10011/licensing/12,能夠看到返回以下結果：

{
  "organization": {
    "id": "12",
    "name": "12公司"
  },
  "valid": false
}
複製代碼

  在實際開發中，基本上是用不到這個的，除非是爲了查詢 Ribbon 以獲取某個服務的全部實例信息，纔會直接使用。若是直接使用它存在如下兩個問題：

  1. 沒有利用 Ribbon 的客戶端負載均衡
  2. 和業務無關的代碼寫得太多

b、使用帶 Ribbon 功能的 Spring RestTemplate 調用服務

  這種方法是較爲經常使用的微服務通訊機制之一。要啓動該功能，須要使用 Spring Cloud 註解@LoadBanced 來定義 RestTemplate bean 的構造方法。方便起見直接在啓動類中定義 bean:

#LicensingserviceApplication.java
@SpringBootApplication
@EnableDiscoveryClient  //使用不帶Ribbon功能的Spring RestTemplate,其餘狀況下可刪除
public class LicensingserviceApplication {

    /**
     * 使用帶有Ribbon 功能的Spring RestTemplate，其餘狀況可刪除
     */
    @LoadBalanced
    @Bean
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }

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

  接着 service 包下增長一個類：OrganizationByRibbonService.java

@Component
public class OrganizationByRibbonService {

    private RestTemplate restTemplate;

    @Autowired
    public OrganizationByRibbonService(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    public Organization getOrganizationWithRibbon(String id) {
        ResponseEntity<Organization> responseEntity = restTemplate.exchange("http://organizationservice/organization/{id}",
                HttpMethod.GET, null, Organization.class, id);
        return responseEntity.getBody();
    }
}
複製代碼

  最後就是在 LicensingController.js 中加一個訪問路徑：

//不要忘記注入OrganizationByRibbonService服務
@GetMapping("/licensingByRibbon/{orgId}")
    public Licensing getLicensingByRibbon(@PathVariable("orgId") String orgId) {
        Licensing licensing = new Licensing();
        licensing.setValid(false);
        licensing.setOrganization(organizationService.getOrganization(orgId));
        return licensing;
    }
}
複製代碼

  訪問localhost:10011/licensingByRibbon/113,便可看到結果。

c、使用 Netflix Feign 客戶端調用

  Feign 客戶端是 Spring 啓用 Ribbon 的 RestTemplate 類的替代方案。開發人員只需定義一個接口，而後使用 Spring 註解來標註接口，便可調用目標服務。除了編寫接口定義無需編寫其餘輔助代碼。

  首先啓動類上加一個@EnableFeignClients註解啓用 feign 客戶端。而後在 POM 中加入 Feign 的依賴

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

  而後在 client 包下新建 OrganizationFeignClient.java

@FeignClient("organizationservice")//使用FeignClient註解指定目標服務
public interface OrganizationFeignClient {

    /** * 獲取組織信息 * * @param orgId 組織id * @return Organization */
    @RequestMapping(method = RequestMethod.GET, value = "/organization/{orgId}", consumes = "application/json")
    Organization getOrganization(@PathVariable("orgId") String orgId);
}
複製代碼

  最後修改LicensingController.java,加入一個路由調用 Feign。

//注入OrganizationFeignClient,使用構造注入

@GetMapping("/licensingByFeign/{orgId}")
public Licensing getLicensingByFeign(@PathVariable("orgId") String orgId) {
    Licensing licensing = new Licensing();
    licensing.setValid(false);
    licensing.setOrganization(organizationFeignClient.getOrganization(orgId));
    return licensing;
}
複製代碼

訪問localhost:10011/licensingByFeign/11313,便可看到結果。

總結

  這一節磨磨蹭蹭寫了好幾天，雖然例子很簡單，可是相信應該是可以看懂的。因爲篇幅緣由代碼沒有所有貼上，想要查看完整代碼，點擊下發連接。

本篇代碼存放於:github

本篇原創發佈於：tapme.top/blog/detail…

掃碼關注微信公衆號：FleyX 學習筆記,獲取更多幹貨

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程