2. 程式人生 > >SpringCloud 第三篇： 服務消費者（Ribbon / Feign）

SpringCloud 第三篇： 服務消費者（Ribbon / Feign）

阿新 • • 發佈：2019-01-23

        前面的文章學習了服務的註冊和發現。在微服務架構中，業務都會被拆分成一個獨立的服務，服務與服務的通訊是基於http restful的。Spring cloud有兩種服務呼叫方式，一種是ribbon+restTemplate，另一種是feign。在這一篇文章要學習的是如何 通過 rest + ribbon 和 Feign 來消費服務，也就是跨服務呼叫。

1. Rest + Ribbon

1.1 Ribbon 簡介

        ribbon 是一個客戶端負載均衡器，可以簡單的理解成類似於 nginx的負載均衡模組的功能，可以很好的控制http和tcp的一些行為。

1.2 建立服務消費者

在之前那個專案裡面建立一個Module，和之前建立服務相似的過程，注意下要匯入Ribbon所需的包。


建立完成之後的 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">
	<modelVersion>4.0.0</modelVersion>

	<groupId>com.example</groupId>
	<artifactId>demo</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>demoRibbon</name>
	<description>Demo project for Spring Boot</description>

	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.0.2.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.8</java.version>
		<spring-cloud.version>Finchley.BUILD-SNAPSHOT</spring-cloud.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
	</dependencies>

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

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

	<repositories>
		<repository>
			<id>spring-snapshots</id>
			<name>Spring Snapshots</name>
			<url>https://repo.spring.io/snapshot</url>
			<snapshots>
				<enabled>true</enabled>
			</snapshots>
		</repository>
		<repository>
			<id>spring-milestones</id>
			<name>Spring Milestones</name>
			<url>https://repo.spring.io/milestone</url>
			<snapshots>
				<enabled>false</enabled>
			</snapshots>
		</repository>
	</repositories>

</project>

1.3 添加註解

        在服務的啟動類中,通過 @EnableDiscoveryClient 指向服務中心註冊，並且向程式的 ioc 注入一個bean: restTemplate;並通過@LoadBalanced註解表明這個restRemplate開啟負載均衡的功能。

package com.example.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableEurekaClient
public class DemoRibbonApplication {

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

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

1.4 配置資訊

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:10000/eureka/
server:
  port: 10001
spring:
  application:
    name: service-demo

1.5 測試

        寫一個測試類HelloController，通過之前注入ioc容器的restTemplate來消費service-demo服務的“/hello”介面，在這裡我們直接用的服務名替代了具體的url地址，在ribbon中它會根據服務名來選擇具體的服務例項，根據服務例項在請求的時候會用具體的url替換掉服務名，如果服務名帶有下劃線都無法呼叫成功，程式碼如下：

package com.example.demo.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;

@RestController
public class HelloController {

    @Autowired
    RestTemplate restTemplate;

    @RequestMapping("/wlecome")
    public String wlecome(@RequestParam String name){
        String wlecome = restTemplate.getForObject("http://SERVICE-DEMO/hello?name="+name, String.class);
        return wlecome;
    }
}


 由於我們程式碼輸出的是的service-demo服務的埠號，所以 prot 顯示的是10001。

        這說明當我們通過呼叫 restTemplate.getForObject("http://SERVICE-DEMO/hello?name="+name, String.class) 方法時，已經做了負載均衡，訪問了不同的埠的服務例項。

2. Feign

2.1 Feign簡介

        官網裡面解釋：Feign是一個宣告式的偽Http客戶端，它使得寫Http客戶端變得更簡單。使用Feign，只需要建立一個介面並註解。它具有可插拔的註解特性，可使用Feign 註解和JAX-RS註解。Feign支援可插拔的編碼器和解碼器。Feign預設集成了Ribbon，並和Eureka結合，預設實現了負載均衡的效果。

總結就是：

        1. Feign 採用的是基於介面的註解；

        2. Feign 可以和其他的開源工具整合工作；

        3. Feign 整合了ribbon。

2.2 建立消費者服務

建立一個Module，和之前建立服務相似的過程，注意下要匯入Feign所需的包。


建立完成之後的 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">
	<modelVersion>4.0.0</modelVersion>

	<groupId>com.example</groupId>
	<artifactId>demo</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>demoFeign</name>
	<description>Demo project for Spring Boot</description>

	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.0.2.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.8</java.version>
		<spring-cloud.version>Finchley.BUILD-SNAPSHOT</spring-cloud.version>
	</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-server</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-openfeign</artifactId>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
	</dependencies>

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

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

	<repositories>
		<repository>
			<id>spring-snapshots</id>
			<name>Spring Snapshots</name>
			<url>https://repo.spring.io/snapshot</url>
			<snapshots>
				<enabled>true</enabled>
			</snapshots>
		</repository>
		<repository>
			<id>spring-milestones</id>
			<name>Spring Milestones</name>
			<url>https://repo.spring.io/milestone</url>
			<snapshots>
				<enabled>false</enabled>
			</snapshots>
		</repository>
	</repositories>

</project>

2.3 添加註解

在服務的啟動類中,通過@EnableDiscoveryClient向服務中心註冊，加上@EnableFeignClients註解開啟Feign的功能：

package com.example.feign;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
public class DemoFeignApplication {

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

2.4 配置資訊

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:10000/eureka/
server:
  port: 10004
spring:
  application:
    name: service-feign

2.5 測試

        定義一個feign介面，通過@FeignClient（“服務名”），來指定呼叫哪個服務，需要注意的是如果呼叫的服務名帶有下劃線在啟動時會報錯。比如在程式碼中呼叫了service-demo服務的“/hello”介面，程式碼如下：

package com.example.feign.feign;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;

@FeignClient("service-demo")//訪問的服務名如果帶有下劃線啟動會報錯
public interface SchedualServiceHello {

    @RequestMapping(value = "/hello",method = RequestMethod.GET)
    String sayHelloFromClientOne(@RequestParam(value = "name") String name);
}
寫一個測試Controll，通過上面定義的Feign客戶端SchedualServiceHi 來消費服務。程式碼如下：
package com.example.feign.controller;

import com.example.feign.feign.SchedualServiceHello;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class FeignController {
    @Autowired
    SchedualServiceHello schedualServiceHello;

    String port;
    @RequestMapping("/hello")
    public String home(@RequestParam String name) {
        return schedualServiceHello.sayHelloFromClientOne(name);
    }
}


3 總結

通過 Rest+Ribbon 和 Feign， 我們能把HTTP遠端呼叫對開發者完全透明，得到與呼叫本地方法一致的編碼體驗。這一點與阿里Dubbo中暴露遠端服務的方式類似，區別在於Dubbo是基於私有二進位制協議，而它們本質上還是個HTTP客戶端。如果是在用Spring Cloud Netflix搭建微服務，一般我們選擇 Feign 。

相關推薦

SpringCloud 第三篇： 服務消費者（Ribbon / Feign）

        前面的文章學習了服務的註冊和發現。在微服務架構中，業務都會被拆分成一個獨立的服務，服務與服務的通訊是基於http restful的。Spring cloud有兩種服務呼叫方式，一種是ribbon+restTemplate，另一種是feign。在這一篇文章要學習

史上最簡單的SpringCloud教程 ｜ 第三篇： 服務消費者（Feign）

最新Finchley版本請訪問： https://www.fangzhipeng.com/springcloud/2018/08/30/sc-f3-feign/ 或者 http://blog.csdn.net/forezp/article/details/810409

跟我學SpringCloud | 第三篇：服務的提供與Feign呼叫

跟我學SpringCloud | 第三篇：服務的提供與Feign呼叫 上一篇，我們介紹了註冊中心的搭建，包括叢集環境嚇註冊中心的搭建，這篇文章介紹一下如何使用註冊中心，建立一個服務的提供者，使用一個簡單的客戶端去呼叫服務端提供的服務。 本篇文章中需要三個角色，分別是服務的提供者，服務的消費者，還有一個是上一篇

白話SpringCloud | 第四章：服務消費者(RestTemple+Ribbon+Feign)

前言 上兩章節，介紹了下關於註冊中心-Eureka的使用及高可用的配置示例，本章節開始，來介紹下服務和服務之間如何進行服務呼叫的，同時會講解下幾種不同方式的服務呼叫。 一點知識 在SpringCloud體系中，我們知道服務之間的呼叫是通過http協議進行呼叫的。而註冊中心的主要目的就是維護這些服務的服務

【SpringCloud Greenwich版本】第三章：服務消費者（Feign）

一、SpringCloud版本 本文介紹的Springboot版本為2.1.1.RELEASE,SpringCloud版本為Greenwich.RC1，JDK版本為1.8，整合環境為IntelliJ IDEA 二、Feign介紹 Feign是一個宣告式的Web服務客戶端。這使得W

【SpringCloud Greenwich版本】第四章：服務消費者（ribbon）

一、SpringCloud版本 本文介紹的Springboot版本為2.1.1.RELEASE,SpringCloud版本為Greenwich.RC1，JDK版本為1.8，整合環境為IntelliJ IDEA 二、Ribbon介紹 Ribbon是一個客戶端負載均衡器，它可以很好地

SpringCloud進擊 | 二淺出：服務消費者（Ribbon+REST）【Finchley版本】

1.前言 上一節：SpringCloud進擊 | 一淺出：服務註冊與發現（Eureka）【Finchley版本】 上一節我們實踐的是 Spring Cloud 的服務註冊與發現。在微服務架構中，業務基本上都會被拆分成一個獨立的服務，服務與服務的通訊是基於 http restful 的

SpringBoot 2.X課程學習 | 第三篇：自動配置（Auto-configuration）

一、auto-configuration introduction      自動配置是spri

史上最簡單的SpringCloud教程 ｜ 第二篇： 服務消費者（rest+ribbon）

image tree 開啟 then rom cat learn 替代 官網 最新Finchley版本：https://www.fangzhipeng.com/springcloud/2018/08/30/sc-f2-ribbon/或者http://blog.csdn.n

在eclipse上部署springcloud小例子--第二篇：服務消費者（feign）

上一篇文章，講述瞭如何通過RestTemplate+Ribbon去消費服務，這篇文章主要講述如何通過Feign去消費服務。 一、Feign簡介 Feign是一個宣告式的偽Http客戶端，它使得寫Http客戶端變得更簡單。使用Feign，只需要建立一個介面並註解。它具有可插拔的註解特性，可使用

在eclipse上部署springcloud小例子--第二篇：服務消費者（rest+ribbon）

在上一篇文章，講了服務的註冊和發現。在微服務架構中，業務都會被拆分成一個獨立的服務，服務與服務的通訊是基於http restful的。Spring cloud有兩種服務呼叫方式，一種是ribbon+restTemplate，另一種是feign。在這一篇文章首先講解下基於ribbon+rest。 &n

Python 語言學習 第三篇：陣列型別（列表、字典和元組）

列表和欄位都可以在原處進行修改，可以按照需求增長或縮短，並且可以包含任何型別的物件或被巢狀。列表和字典儲存的是物件的引用，而不是拷貝。 一，列表 列表是有序的序列，每一個列表項的順序是固定的，這使得列表可以通過指定的偏移來索引和分片。列表是可變的序列，支援在原處修改。 列表項可以是任何型別，或物件，也可

第三篇：服務治理:Spring Cloud Eureka

1、服務治理是微服務框架中的核心與基礎，主要用來實現各個微服務例項的自動化註冊和發現。            分為服務註冊和服務發現。 2、引入相應依賴模組 <parent> <groupId>org.springframework.boot

一起來學Spring Cloud | 第三章：服務消費者 (負載均衡Ribbon)

一、負載均衡的簡介： 負載均衡是高可用架構的一個關鍵元件，主要用來提高效能和可用性，通過負載均衡將流量分發到多個伺服器，多伺服器能夠消除單個伺服器的故障，減輕單個伺服器的訪問壓力。 1、服務端負載均衡：客戶端請求到負載均衡伺服器，負載均衡伺服器根據自身的演算法將該請求轉給某臺真正提供業務的伺服器，該伺服器將響

跟我學SpringCloud | 第九篇：服務閘道器Zuul初

SpringCloud系列教程 | 第九篇：服務閘道器Zuul初探 前面的文章我們介紹了，Eureka用於服務的註冊於發現，Feign支援服務的呼叫以及均衡負載，Hystrix處理服務的熔斷防止故障擴散，Spring Cloud Config服務叢集配置中心，似乎一個微服務框架已經完成了。 我們還是少考慮了一

跟我學SpringCloud | 第十篇：服務閘道器Zuul高階篇

SpringCloud系列教程 | 第十篇：服務閘道器Zuul高階篇 Springboot: 2.1.6.RELEASE SpringCloud: Greenwich.SR1 如無特殊說明，本系列教程全採用以上版本 上一篇我們主要聊到了Zuul的使用方式，以及自動轉發機制，其實Zuul還有更多的使

springcloud 系列教程四：服務消費者（Feign）

一、Feign簡介 Feign 的英文表意為 "假裝，偽裝，變形"， 是一個http請求呼叫的輕量級框架，可

DAX 第六篇：統計函式（描述性統計）

統計函式用於建立聚合，對資料進行統計分析。在使用統計函式時，必須考慮到資料模型，表之間關係，資料重複等因素，一般都會搭配過濾函式實現資料的提取和分析。 統計量一般是：均值、求和、計數、最大值、最小值、求中位數、獲得分位數等。 一，求均值 均值分為幾何均值和算術均值，幾何平均數是n個變數值連乘積的n次方根

第三篇：SpringCloud之服務消費（Feign）

上一篇文章，講述瞭如何通過RestTemplate+Ribbon去消費服務，這篇文章主要講述如何通過Feign去消費服務。 Feign簡介 Feign是一種宣告式、模板化的HTTP客戶端，它使得寫Http客戶端變得更簡單。使用Feign，只需要建立一個介面並註解。它具有可

SpringCloud | 第三篇: 服務消費者（Feign）

上一篇文章，講述瞭如何通過RestTemplate+Ribbon去消費服務，這篇文章主要講述如何通過Feign去消費服務。 一、Feign簡介 Feign是一個宣告式的偽Http客戶端，它使得寫Http客戶端變得更簡單。使用Feign，只需要建立一個介面並註解。它具有