2. 程式人生 > >SpringCloud之服務提供與呼叫(Ribbon,Feign)

SpringCloud之服務提供與呼叫(Ribbon,Feign)

阿新 • • 發佈：2018-12-12

本系列介紹的配置均基於 Spring Boot 2.0.1.RELEASE 版本和 Spring Cloud Finchley.SR1

eureka註冊續約流程

  1. 啟動註冊中心
  2. 服務提供者生產服務並註冊到服務中心中
  3. 消費者從服務中心中獲取服務並執行

image


    </properties>

    <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>
    </dependencies>

    <build>
        <finalName>producer-service</finalName>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.建立啟動類

Finchley版本已經不需要新增@EnableDiscoveryClient註解,Spring Cloud會自動識別。

@SpringBootApplication
public class ProducerServiceApplication {

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

}

3.配置檔案

spring.application.name=producer-service
server.port=9001
#eureka
eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/
  • spring.application.name 服務提供者的名字
  • server.por 服務埠號
  • eureka.client.serviceUrl.defaultZone eureka的服務註冊地址，如果eureka是多節點，多個地址逗號分隔，具體可以看上一篇部落格:服務註冊與發現。

多節點eureka服務註冊如下：

eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/,http://localhost:8002/eureka/

4.Action or Controller類

@RestController
@RequestMapping(value = "/test")
public class ProducerAction {

    @RequestMapping(value = "", method = RequestMethod.GET)
    public String test(String param) {
        return "param is " + param;
    }

}

5.啟動服務

6.呼叫下試試

param is test

服務消費 ribbon

Ribbon 了，它是一個基於 HTTP 和 TCP 的客戶端負載均衡器。它可以通過在客戶端中配置ribbonServerList 來設定服務端列表去輪詢訪問以達到均衡負載的作用。

當 Ribbon 與 Eureka聯合使用時，ribbonServerList會被DiscoveryEnabledNIWSServerList 重寫，擴充套件成從 Eureka 註冊中心中獲取服務例項列表。同時它也會用 NIWSDiscoveryPing 來取代 IPing，它將職責委託給 Eureka 來確定服務端是否已經啟動。

1.在spring-cloud-manage下建立一個子專案consumer-service

pom.xml檔案如下

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>spring-cloud-manage</artifactId>
        <groupId>org.springcloudmanage</groupId>
        <version>1.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>consumer-service</artifactId>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
    </properties>

    <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>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

spring-cloud-starter-netflix-eureka-client中已經引用了ribbon先關的jar，所需不需要再引入了

2.建立啟動類

@SpringBootApplication
public class ConsumerServiceApplication {

    @LoadBalanced
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

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

}

3.配置檔案

spring.application.name=consumer-service
server.port=9002
#eureka
eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/

4.Action or Controller類

這裡注入restTemplate，Spring Cloud Ribbon 自己有攔截器會對 服務名producer-service做解析，自動的去選取服務例項負載均衡呼叫，並將服務名替換成實際要請求的IP地址和埠

@RestController
@RequestMapping(value = "/ribbon/test")
public class ConsumerAction {

    @Autowired
    private RestTemplate restTemplate;

    @RequestMapping(value = "", method = RequestMethod.GET)
    public String test(String param) {
        String url = "http://producer-service/test/?param=" + param;
        return restTemplate.getForObject(url, String.class);
    }
    
}

5.啟動服務

消費端服務啟動成功後，可以看到erueka時已經顯示註冊成功了

image

5.呼叫消費端服務

param is ribbon-test

控制檯日誌

2018-08-28 16:25:23.397  INFO 3791 --- [nio-9002-exec-1] c.netflix.config.ChainedDynamicProperty  : Flipping property: producer-service.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
2018-08-28 16:25:23.414  INFO 3791 --- [nio-9002-exec-1] c.n.u.concurrent.ShutdownEnabledTimer    : Shutdown hook installed for: NFLoadBalancer-PingTimer-producer-service
2018-08-28 16:25:23.433  INFO 3791 --- [nio-9002-exec-1] c.netflix.loadbalancer.BaseLoadBalancer  : Client: producer-service instantiated a LoadBalancer: DynamicServerListLoadBalancer:{NFLoadBalancer:name=producer-service,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:null
2018-08-28 16:25:23.440  INFO 3791 --- [nio-9002-exec-1] c.n.l.DynamicServerListLoadBalancer      : Using serverListUpdater PollingServerListUpdater
2018-08-28 16:25:23.462  INFO 3791 --- [nio-9002-exec-1] c.netflix.config.ChainedDynamicProperty  : Flipping property: producer-service.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
2018-08-28 16:25:23.463  INFO 3791 --- [nio-9002-exec-1] c.n.l.DynamicServerListLoadBalancer      : DynamicServerListLoadBalancer for client producer-service initialized: DynamicServerListLoadBalancer:{NFLoadBalancer:name=producer-service,current list of Servers=[192.168.101.238:9001],Load balancer stats=Zone stats: {defaultzone=[Zone:defaultzone;	Instance count:1;	Active connections count: 0;	Circuit breaker tripped count: 0;	Active connections per server: 0.0;]
},Server stats: [[Server:192.168.101.238:9001;	Zone:defaultZone;	Total Requests:0;	Successive connection failure:0;	Total blackout seconds:0;	Last connection made:Thu Jan 01 08:00:00 CST 1970;	First connection made: Thu Jan 01 08:00:00 CST 1970;	Active Connections:0;	total failure count in last (1000) msecs:0;	average resp time:0.0;	90 percentile resp time:0.0;	95 percentile resp time:0.0;	min resp time:0.0;	max resp time:0.0;	stddev resp time:0.0]
]}ServerList:org.springf[email protected]12e48993
2018-08-28 16:25:24.447  INFO 3791 --- [erListUpdater-0] c.netflix.config.ChainedDynamicProperty  : Flipping property: producer-service.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647

可以啟動多個producer-service服務測試下實際的負載均衡效果。

服務消費 feign

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

在實際工作中，我們基本上都是使用Feign來完成呼叫的。我們通過一個例子來展現 Feign 如何方便的宣告對 eureka-producer 服務的定義和呼叫。

1.consumer-service新增對feign的依賴

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>spring-cloud-manage</artifactId>
        <groupId>org.springcloudmanage</groupId>
        <version>1.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>consumer-service</artifactId>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

2.啟動類上加上feign所需註解

@EnableFeignClients
@SpringBootApplication
public class ConsumerServiceApplication {

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

}

3.配置檔案

spring.application.name=consumer-service
server.port=9002
#eureka
eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/
#開啟Hystrix斷路器
feign.hystrix.enabled=true
#斷路器的超時時間需要大於ribbon的超時時間，不然不會觸發重試,預設為1000
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

4.feign 呼叫

建立feign客戶端呼叫類，其中name為所需呼叫的服務名，fallback使用Hystrix，當producer-service不可用時，對服務做降級，並返回友好提示

@FeignClient(name = "producer-service", fallback = ProducerServiceFeignClientHystrix.class)
public interface ProducerServiceFeignClient {

    @RequestMapping(value = "/test", method = RequestMethod.GET)
    String test(@RequestParam("param") String param);

}

==注意@RequestParam("param")中name必須要和producer-service服務中的引數名一致==

@Component
public class ProducerServiceFeignClientHystrix implements ProducerServiceFeignClient {
    @Override
    public String test(String param) {
        return "服務[producer-service]無法訪問";
    }
}

param is feign-test

給大家推薦一個程式設計師學習交流群：863621962。群裡有分享的視訊，還有思維導圖 群公告有視訊，都是乾貨的，你可以下載來看。主要分享分散式架構、高可擴充套件、高效能、高併發、效能優化、Spring boot、Redis、ActiveMQ、Nginx、Mycat、Netty、Jvm大型分散式專案實戰學習架構師視訊

服務[producer-service]無法訪問

相關推薦

SpringCloud之服務提供與呼叫(Ribbon,Feign)

本系列介紹的配置均基於 Spring Boot 2.0.1.RELEASE 版本和 Spring Cloud Finchley.SR1 eureka註冊續約流程 啟動註冊中心 服務提供者生產服務並註冊到服務中心中 消費者從服務中心中獲取服務並執行

四：Spring Cloud 之服務發現與呼叫-Ribbon

1. 簡介 Ribbon is a client side load balancer which gives you a lot of control over the behaviour of HTTP and TCP clients. F

springcloud(三)：服務提供與呼叫

上一篇文章我們介紹了eureka服務註冊中心的搭建，這篇文章介紹一下如何使用eureka服務註冊中心，搭建一個簡單的服務端註冊服務，客戶端去呼叫服務使用的案例。 案例中有三個角色：服務註冊中心、服務提供者、服務消費者，其中服務註冊中心就是我們上一篇的eureka單機版啟

第二章、spring cloud服務註冊中心eureka---服務提供與呼叫

服務提供與呼叫 案例中有三個角色：服務註冊中心、服務提供者、服務消費者，其中服務註冊中心就是我們上一篇的eureka單機版啟動既可，流程是首先啟動註冊中心，服務提供者生產服務並註冊到服務中心中，消費者從服務中心中獲取服務並執行。 02eureka-pro

（二）服務提供與呼叫

案例中有三個角色：服務註冊中心、服務提供者、服務消費者，其中服務註冊中心就是我們上一篇的eureka單機版啟動既可，流程是首先啟動註冊中心，服務提供者生產服務並註冊到服務中心中，消費者從服務中心中獲取服務並執行。 服務提供 我們假設服務提供者有一個hello方法，可以根據傳入的引數，提供輸出“h

Spring Cloud：服務提供與呼叫（03）

上一篇文章我們介紹了eureka服務註冊中心的搭建，這篇文章介紹一下如何使用eureka服務註冊中心，搭建一個簡單的服務端註冊服務，客戶端去呼叫服務使用的案例。 案例中有三個角色：服務註冊中心、服務提供者、服務消費者，其中服務註冊中心就是我們上一篇的eureka單機版啟動既可，流程是首先啟動註冊

JAVA ssm b2b2c多使用者商城系統原始碼(三)：服務提供與呼叫

上一篇文章我們介紹了eureka服務註冊中心的搭建，這篇文章介紹一下如何使用eureka服務註冊中心，搭建一個簡單的服務端註冊服務，客戶端去呼叫服務使用的案例。 案例中有三個角色：服務註冊中心、服務提供者、服務消費者，其中服務註冊中心就是我們上一篇的eureka單機版啟動既可，流程是首先啟動註冊

微服務SpringCloud之服務註冊與發現

   在找.net core 微服務框架時發現了Steeltoe開源專案，它可以基於Spring Cloud實現.net core和.net  Framework的微服務。正好之前也有學習過SpringBoot，而Spring C

SpringCloud之服務呼叫(Ribbon)

業務場景 訂單服務呼叫商品服務叢集，進行偽下單功能開發，使用Ribbon實現訂單呼叫商品服務。 思路：1.建立訂單服務2.編寫偽下單介面a.呼叫商品服務獲取商品資訊（Ribbon呼叫服務）b.根據商品資訊，訂單介面返回訂單詳情資訊 呼叫邏輯圖如下： 實現訂單服務專案 訂單服務專案通過Spring

SpringCloud之服務呼叫(feign)

前言 前一篇介紹了使用Ribbon的RestTemplate進行服務呼叫的使用方式。除了這種方式進行服務呼叫以外還可以通過Feign進行呼叫，本篇文章就是簡單介紹一下如何使用Feign進行服務呼叫。根據前一篇文章所用專案進行修改。 Feign使用流程 1.pom檔案引入依賴 <!

微服務SpringCloud之服務呼叫與負載均衡

上一篇我們學習了服務的註冊與發現，本篇部落格是在上一篇的基礎上學習服務的呼叫。上一部落格主要建立了Eureka的服務端和一個Client，該Client包含了一個Controller用來提供對外服務供外部呼叫，可以作為生產者。 一、引入依賴 前面建立了EurekaClient的專案，在專案中引入了spri

springcloud之服務消費者（ribbon）

serve frame ribbon lee cti 代碼 images net 發現 本章介紹springcloud中的服務消費者 　　springcloud服務調用方式有兩種實現方式： 　　　　1，restTemplate+ribbon, 　　　　2，feign 　

springcloud之服務消費者（feign）

開啟 out nbu 使用 方式 spring cat pan span 本章將繼續講述springcloud的消費者（feign） 　　　　Spring Cloud Feign是一套基於Netflix Feign實現的聲明式服務調用客戶端。它使得編寫Web服務客戶端變得更

springcloud微服務系列之服務註冊與發現組件Eureka

顯示 功能 depend mod 其他 瀏覽器 使用 空間 之間 一、Eurake的簡介二、使用Eureka進行服務的註冊消費1、創建一個服務註冊中心2、創建服務的提供者3、創建服務的消費者總結 一、Eurake的簡介 今天我們來介紹下springcloud的核心組件Eur

springcloud Spring Boot mybatis分布式微服務雲架構(三)：服務提供與調用

客戶端 生產 pat 簡單的 第一次 his 流程 如何 localhost 上一篇文章我們介紹了eureka服務註冊中心的搭建，這篇文章介紹一下如何使用eureka服務註冊中心，搭建一個簡單的服務端註冊服務，客戶端去調用服務使用的案例。 案例中有三個角色：服務註冊中心、服

SpringCloud之服務消費者Feign（三）

消費 apt boot cal port xmlns sco packaging url 一、Feign簡介Feign是一個聲明式的偽Http客戶端，它使得寫Http客戶端變得更簡單。使用Feign，只需要創建一個接口並註解。它具有可插拔的註解特性，可使用Feign 註解和

SpringCloud-Eureka服務註冊與發現之叢集配置(五)

1.構建多個Eureka服務端，具體步驟參考單機版的Eureka服務端構建步驟 2.修改每個Eureka服務端yml檔案，將對外暴露的註冊介面地址由一個變成多 個，自身的暴露地址除外

SpringCloud-Eureka服務註冊與發現之自我保護機制(四)

當我們進行SpringCloud微服務開發的時候，有可能會出現如下的一些紅色提示資訊。這個是Eureka的自我保護機制。 自我保護機制 ：預設情況下，如果Eureka Server在一定時間內沒有接收到某個微服務例項的心跳，Eureka S

SpringCloud-Eureka服務註冊與發現之開發小技巧(三)

1.如何為服務起別名，即修改下面紅色部分 解決方案：在yml配置檔案中加入以下資訊 測試： 2.如何設定服務端的ip地址 解決方案: 在yml配置檔案中加入以下資訊

SpringCloud之服務調用(Ribbon)

find random net text ram auth ade 文檔 pub 業務場景 訂單服務調用商品服務集群，進行偽下單功能開發，使用Ribbon實現訂單調用商品服務。 思路：1.創建訂單服務2.編寫偽下單接口a.調用商品服務獲取商品信息（Ribbon調用服務）b.