微服务的消费 | 从0开始构建SpringCloud微服务(11)

照例附上项目github链接

本项目实现的是将一个简单的天气预报系统一步一步改造成一个SpringCloud微服务系统的过程。本章主要讲解微服务的消费。

微服务的消费模式

微服务的消费模式主要有：

1. 服务直连模式
2. 客户端发现模式
3. 服务端发现模式

下面我们主要讲解客户端发现模式，以及服务端发现模式。

客户端发现模式

客户端发现模式的具体流程如下：

1）服务实例启动后，将自己的位置信息提交到服务注册表中。

2）客户端从服务注册表进行查询，来获取可用的服务实例。

3）客户端自行使用负载均衡算法从多个服务实例中选择出一个。

服务端发现模式

服务端发现模式与客户端发现模式的区别在于：服务端发现模式的负载均衡由负载均衡器（独立的）来实现，客户端不需要关心具体调用的是哪一个服务。

微服务的消费者

下面我们价格介绍一些常见的微服务的消费者。

HttpClient

HttpClient是常见的微服务的消费者，它是Apache Jakarta Common 下的子项目，可以用来提供高效的、最新的、功能丰富的支持 HTTP 协议的客户端编程工具包，并且它支持 HTTP协议最新的版本和建议。

Ribbon

Ribbon是一个基于HTTP和TCP的客户端负载均衡工具，它基于Netflix Ribbon实现。通过Spring Cloud的封装，可以让我们轻松地将面向服务的REST模版请求自动转换成客户端负载均衡的服务调用。

Ribbon常与Eureka结合使用。在典型的分布式部署中，Eureka为所有的微服务提供服务注册，Ribbon提供服务消费的客户端，含有许多负载均衡的算法。

Feign

Feign是一个声明式的Web Service客户端，它的目的就是让Web Service调用更加简单。Feign提供了HTTP请求的模板，通过编写简单的接口和插入注解，就可以定义好HTTP请求的参数、格式、地址等信息。

而Feign则会完全代理HTTP请求，我们只需要像调用方法一样调用它就可以完成服务请求及相关处理。Feign整合了Ribbon和Hystrix(关于Hystrix我们后面再讲)，可以让我们不再需要显式地使用这两个组件。

总起来说，Feign具有如下特性：

• 可插拔的注解支持，包括Feign注解和JAX-RS注解;
• 支持可插拔的HTTP编码器和解码器;
• 支持Hystrix和它的Fallback;
• 支持Ribbon的负载均衡;
• 支持HTTP请求和响应的压缩。

集成Feign

本节我们主要讲解如何集成Feign，实现微服务的消费功能。

添加配置

pom.xml配置文件，添加如下依赖。

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-feign</artifactId>
        </dependency>

application.yml文件，添加如下配置

服务的名称与工程的名称一致，并且设置请求一个服务的connect与read的超时时间。

spring: 
  application:
    name: micro-weather-eureka-client-feign
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
feign: 
  client: 
    config: 
      feignName: 
        connectTimeout: 5000
        readTimeout: 5000

添加注解

添加@EnableFeignClients注解，启动Feign功能。

package com.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletComponentScan;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;
import org.springframework.scheduling.annotation.EnableScheduling;

//@ServletComponentScan(basePackages="com.demo.web.servlet")
@SpringBootApplication
@EnableDiscoveryClient
@EnableScheduling
@EnableFeignClients
public class Sifoudemo02Application {

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

创建Feign客户端

创建一个Feign客户端，通过其CityClient的接口，可以调用城市数据API微服务mas-weather-city-eureka中的cities接口，返回城市列表。

package com.demo.service;

import java.util.List;

import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import com.demo.vo.City;

//创建一个Feign客户端 获取城市数据微服务中的城市列表信息
@FeignClient("msa-weather-city-eureka")
public interface CityClient {
    @RequestMapping(value="/cities",method=RequestMethod.GET)
    List<City> listCity()throws Exception;
}

使用Feign客户端

@RestController
public class CityController{
    @Autowired
    private CityClient cityClient;
    
    @GetMapping("/cities")
    public List<City> listCity(){
        List<City> cityList=cityClient.listCity();
![在这里插入图片描述](https://img-blog.csdnimg.cn/20190311174443475.jpg?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwOTU1Mjg3,size_16,color_FFFFFF,t_70)        return cityList;
    }
}

测试

先启动Eureka服务端，然后启动被请求的微服务——城市数据API微服务，最后启动Feign客户端。