2. 程式人生 > 實用技巧 >服務消費

服務消費

阿新 • • 發佈：2020-08-13

當我們實現了服務註冊的時候，也同步獲取到了註冊成功的服務資訊，就可以直接呼叫服務，我們今天來實踐下。

一、準備工作

1.1 建立 Eureka- Server

  1. 新建 Eureka Server 模組，新增 Eureka Server 依賴
<properties>
    <java.version>1.8</java.version>
    <spring-cloud.version>Hoxton.SR4</spring-cloud.version>
</properties>
    
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
    
<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>		
</dependencies>
  1. 在配置檔案 resources/application. yml 中新增 EurekaServer 相關配置
# 指定執行埠
server:
  port: 9000      
spring:
  application:
	# 指定服務名稱
    name: eureka-server
eureka:
  instance:
    # 指定主機地址
    hostname: localhost
  client:
    # 指定是否從註冊中心獲取服務(註冊中心不需要開啟)
    fetch-registry: false
    # 指定是否將自身註冊到註冊中心(註冊中心不需要開啟)
    register-with-eureka: false
  1. 在啟動類上新增 @EnableEurekaServer 註解來啟用 Euerka 註冊中心功能
@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApplication.class, args);
    }

}
  1. 啟動專案，訪問 http://localhost:9000 ，可以看到 Eureka 註冊中心介面：

1.2 建立 PriceService 模組

  1. 新增依賴
<properties>
    <java.version>1.8</java.version>
    <spring-cloud.version>Hoxton.SR4</spring-cloud.version>
</properties>
    
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
    
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>
  1. 在配置檔案 resources/application. yml 新增相關配置
spring:
  application:
    # 指定服務名稱
    name: price-service

eureka:
  client:
    # 註冊到 Eureka 的註冊中心
    register-with-eureka: true
    # 獲取註冊例項列表
    fetch-registry: true
    service-url:
      # 指定註冊中心
      defaultZone: http://localhost:9000/eureka
  1. 在啟動類上新增 @EnableDiscoveryClient 註解
@EnableDiscoveryClient
@SpringBootApplication
public class PriceServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(PriceServiceApplication.class, args);
    }

}
  1. 建立 PriceController，實現根據商品Id 獲取價格功能
@RestController
@RequestMapping("/price")
public class PriceController {

    @GetMapping("/getPrice/{productId}")
    public BigDecimal getPrice(@PathVariable("productId") String productId) {
        System.out.println("productId=" + productId);
        return new BigDecimal("100");
    }

}
  1. 啟動兩個 PriceService 服務

1.3 建立 OrderService 模組

  1. 新增依賴
<properties>
    <java.version>1.8</java.version>
    <spring-cloud.version>Hoxton.SR4</spring-cloud.version>
</properties>
    
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
    
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>
  1. 在配置檔案 resources/application. yml 新增相關配置
server:
  # 指定執行埠
  port: 8005
spring:
  application:
    # 指定服務名稱
    name: order-service

eureka:
  client:
    # 註冊到 Eureka 的註冊中心
    register-with-eureka: true
    # 獲取註冊例項列表
    fetch-registry: true
    service-url:
      # 指定註冊中心
      defaultZone: http://localhost:9000/eureka
  1. 在啟動類上新增 @EnableDiscoveryClient 註解
@EnableDiscoveryClient
@SpringBootApplication
public class OrderServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(OrderServiceApplication.class, args);
    }

}
  1. 新建 OrderController 用於訪問 PriceService 獲取價格
@RestController
@RequestMapping("/order")
public class OrderController {

    private final RestTemplate restTemplate;

    public OrderController(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    @GetMapping("/getPrice")
    public BigDecimal getPrice(String productId) {
        // TODO 方法待實現
		return null;
    }

}

二、負載均衡

當一個服務存在多個例項的，我們就需要使用能夠滿足負載均衡的 HTTP 元件。

2.1 Loadbalancer

2.1.1 Loadbalancer 介紹

LoadBalancerClient 是 SpringCloud 提供的負載均衡器客戶端，它先從提供的服務中獲取某一個例項（預設策略為輪詢），通過 choose() 方法獲取到節點中的一個服務，拿到服務的資訊之後取出服務 IP 資訊，就可以得到完成的想要訪問的 IP地址和介面，最後通過 RestTempate 訪問服務。

2.1.2 Loadbalancer 使用

  1. 新建 HttpConfig ，啟用 @LoadBalanced 實現負載均衡功能
@Configuration
public class HttpConfig {

    @LoadBalanced
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}
  1. 完善 OrderController.getPrice() 方法
@GetMapping("/getPrice")
public BigDecimal getPrice(String productId) {
    final BigDecimal price = restTemplate.getForObject("http://PRICE-SERVICE/price/getPrice/" + productId, BigDecimal.class);
    return price;
}
  1. 啟動 OrderService 服務，訪問 http://localhost:8005/order/getPrice?productId=123 ，返回:
100

說明呼叫成功了，我們再訪問二次請求，然後檢視 PriceService 控制檯輸出：

檢視 PriceService01控制檯：

productId=123
productId=123

檢視 PriceService02 控制檯：

productId=123

可以看到使用了輪詢機制。

2.2 Ribbon

Spring Cloud Netflix Ribbon 是 Spring Cloud Netflix 子專案的核心元件之一，主要給服務間呼叫及 API 閘道器轉發提供負載均衡的功能。

2.2.1 Ribbon的常用配置

全域性配置:

ribbon:
  ConnectTimeout: 1000 #服務請求連線超時時間（毫秒）
  ReadTimeout: 3000 #服務請求處理超時時間（毫秒）
  OkToRetryOnAllOperations: true #對超時請求啟用重試機制
  MaxAutoRetriesNextServer: 1 #切換重試例項的最大個數
  MaxAutoRetries: 1 # 切換例項後重試最大次數
  NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #修改負載均衡演算法

指定服務進行配置:

user-service:
  ribbon:
    ConnectTimeout: 1000 #服務請求連線超時時間（毫秒）
    ReadTimeout: 3000 #服務請求處理超時時間（毫秒）
    OkToRetryOnAllOperations: true #對超時請求啟用重試機制
    MaxAutoRetriesNextServer: 1 #切換重試例項的最大個數
    MaxAutoRetries: 1 # 切換例項後重試最大次數
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #修改負載均衡演算法

可以看出與全域性配置的區別就是 ribbon 節點掛在服務名稱下面。

2.2.2 Ribbon的負載均衡策略

ribbon可以選擇以下幾種負載均衡策略：

* com.netflix.loadbalancer.RandomRule：從提供服務的例項中以隨機的方式；
* com.netflix.loadbalancer.RoundRobinRule：以線性輪詢的方式，就是維護一個計數器，從提供服務的例項中按順序選取，第一次選第一個，第二次選第二個，以此類推，到最後一個以後再從頭來過；
* com.netflix.loadbalancer.RetryRule：在RoundRobinRule的基礎上新增重試機制，即在指定的重試時間內，反覆使用線性輪詢策略來選擇可用例項；
* com.netflix.loadbalancer.WeightedResponseTimeRule：對RoundRobinRule的擴充套件，響應速度越快的例項選擇權重越大，越容易被選擇；
* com.netflix.loadbalancer.BestAvailableRule：選擇併發較小的例項；
* com.netflix.loadbalancer.AvailabilityFilteringRule：先過濾掉故障例項，再選擇併發較小的例項；
* com.netflix.loadbalancer.ZoneAwareLoadBalancer：採用雙重過濾，同時過濾不是同一區域的例項和故障例項，選擇併發較小的例項。

三、Feign

3.1 Feign 介紹

Feign 是一個宣告式的Web Service客戶端，它使得編寫 Web Serivce 客戶端變得更加簡單。我們只需要使用Feign 來建立一個介面並用註解來配置它既可完成。它具備可插拔的註解支援，包括 Feign註解和 JAX-RS 註解。Feign 也支援可插拔的編碼器和解碼器。Spring Cloud 為 Feign 增加了對 Spring MVC 註解的支援，還整合了Ribbon 和 Eureka 來提供負載均衡的HTTP客戶端實現。

3.2 FeignClient註解屬性

屬性名 預設值 作用 備註
value 空字串 呼叫服務名稱，和name屬性相同
serviceId 空字串 服務id，作用和name屬性相同 已過期
name 空字串 呼叫服務名稱，和value屬性相同
url 空字串 全路徑地址或hostname，http或https可選
decode404 false 配置響應狀態碼為404時是否應該丟擲FeignExceptions
configuration {} 自定義當前feign client的一些配置 參考FeignClientsConfiguration
fallback void.class 熔斷機制，呼叫失敗時，走的一些回退方法，可以用來丟擲異常或給出預設返回資料。 底層依賴hystrix，啟動類要加上@EnableHystrix
path 空字串 自動給所有方法的requestMapping前加上字首，類似與controller類上的requestMapping
primary true

3.3 Feign 簡單使用

  1. 在 OrderService 模組中新增 Feign 依賴
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
  1. 啟用 Feign 註解
@EnableFeignClients
@EnableDiscoveryClient
@SpringBootApplication
public class OrderServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(OrderServiceApplication.class, args);
    }

}
  1. 建立 PriceService 介面
@FeignClient(value = "PRICE-SERVICE", path = "/price")
public interface PriceService {

    @RequestMapping(value = "/getPrice/{productId}", method = RequestMethod.GET)
    BigDecimal getPrice(@PathVariable("productId")String productId);

}

可以看到相當於是一個和 PriceService 訪問的契約。

  1. 修改 OrderController 呼叫邏輯
@RestController
@RequestMapping("/order")
public class OrderController {

    private final PriceService priceService;

    public OrderController(PriceService priceService) {
        this.priceService = priceService;
    }

    @GetMapping("/getPrice")
    public BigDecimal getPrice(String productId) {
        final BigDecimal price = priceService.getPrice(productId);
        return price;
    }

}

5）執行 OrderService 服務，訪問 http://localhost:8005/order/getPrice?productId=123 ，返回:

100

說明呼叫成功。

相關推薦

Spring Cloud Alibaba（四）實現Dubbo服務消費

本專案演示如何使用 Spring Cloud Alibaba 完成 Dubbo 的RPC呼叫。 Spring Cloud與Dubbo Spring Cloud是一套完整的微服務架構方案

服務消費

當我們實現了服務註冊的時候，也同步獲取到了註冊成功的服務資訊，就可以直接呼叫服務，我們今天來實踐下。

服務消費之負載均衡

當一個服務存在多個例項的，我們就需要使用能夠滿足 **負載均衡 **的 HTTP 元件。

8、SpringCloud 之宣告式服務消費Feign

Feign 是什麼 Feign是Netflix公司開發的一個宣告式的REST呼叫客戶端； Ribbon負載均衡、Hystrix服務熔斷是我們Spring Cloud中進行微服務開發非常基礎的元件，在使用的過程中我們也發現它們一般都是同時出現，而且配置

SpringBoot+SpringCloud+vue+Element開發專案——服務消費（Ribbon、Feign）

一、服務提供者 1、新建一個專案jansens-producer、新增依賴 Swagger:API文件。 Consul:註冊中心。

Spring Cloud Alibaba 使用RestTemplate進行服務消費

建立服務提供者工程 建立spring-cloud-alibaba-service-member工程，會員中心服務該服務提供使用者會員資訊。

Dubbo之從服務消費端說起

既然Dubbo是一個RPC框架，我們就從分解一個RPC框架開始，然後把Dubbo中的模組和程式碼對應到RPC的每個部分上。

Dubbo服務消費過程

服務消費者端程式碼 @DubboReference(version = \"1.0.0\") private DemoService demoService; public static void main(String[] args) {

Dubbo配置(一) -- 服務釋出與消費

github測試Demo專案地址：github.com/HopeAndStar… 一：概述 本文為Dubbo學習第一步，使用XML配置檔案釋出與消費服務。檔案配置參考Dubbo官網後經過自身Demo專案測試完成編寫，當然不對亦或是不全地方歡迎大家補充或

Spring Cloud 框架 -- Eureka 服務的註冊與消費

服務註冊 服務註冊就是把一個微服務註冊到 Eureka Server 上，這樣，當其他服務需要呼叫該服務時，只需要從 Eureka Server 上查詢該服務的資訊即可。

SpringCloud Alibaba Nacos 服務發現 Feign進行消費

使用Feign服務發現消費服務 啟動Nacos訪問地址為:http://101.200.201.195:8848/nacos/ 啟動buscien-service-01業務服務，進行消費

Spring Boot 教程：消費 Rest Web 服務

【注】本文譯自： https://www.tutorialspoint.com/spring_boot/spring_boot_consuming_restful_web_services.htm

聯想消費極速達服務上線：工程師化身快遞員，當日送達並提供新機“開荒”服務

6 月 1 日訊息 聯想官網消費極速達服務昨日正式上線，首批上線覆蓋全國二十多個城市，專業工程師化身快遞員，可在當日送達購買的產品，同時消費者還將獲贈“新機開荒”服務。

Springboot-微服務-微服務元件之服務管理-eureka-消費端呼叫服務

Springboot-微服務-微服務元件之服務管理-eureka-消費端呼叫服務 微服務現在大部分的呼叫方式都是rest風格的呼叫方式也就常見的http，當然也還有另一種方式就是RPC

kafaka高效吞吐量-生產端，服務端，消費端

零拷貝：sendfile 生產端 生產端：訊息壓縮，快取批量傳送，非同步解耦 多執行緒併發：防止某一個業務阻塞等待

小米有品和小米商城內部業務整合，將繼續分別服務不同的消費人群

11 月 16 日訊息，據 Tech 星球報道，小米近日通過內部郵件的方式宣佈，獨立電商平臺“小米有品”與小米中國區零售業務整合，未來小米有品和小米商城將結束獨立結算和運營政策不同的情況，一起服務小米集團的新零售

《微服務架構設計》——Eventuate Tram框架訂閱/消費模式原始碼解析

Eventuate Tram框架官方文件：https://eventuate.io/docs/manual/eventuate-tram/latest/getting-started-eventuate-tram.html#getting-started

Spring Cloud構建微服務架構：訊息驅動的微服務（消費組）【Dalston版】

通過之前的《訊息驅動的微服務（入門）》一文，相信很多朋友已經對Spring Cloud Stream有了一個初步的認識。但是，對於《訊息驅動的微服務（核心概念）》一文中提到的一些核心概念可能還有些迷糊，下面我們將詳細的來

Spring Cloud構建微服務架構：訊息驅動的微服務（消費分割槽）【Dalston版】

通過上一篇《訊息驅動的微服務（消費組）》的學習，我們已經能夠在多例項環境下，保證同一訊息只被一個消費者例項進行接收和處理。但是，對於一些特殊場景，除了要保證單一例項消費之外，還希望那些具備相同特徵的訊

SAP 雲平臺上的 ABAP 程式設計環境裡如何消費第三方服務

在ABAP On-Premises環境下，使用ABAP程式設計消費第三方服務，相信很多ABAP顧問都已經非常熟悉了，無非就是使用CL_HTTP_CLIENT或者CL_REST_HTTP_CLIENT來發送和接收HTTP請求。