SpringCloud实现服务调用feign与熔断hystrix和网关gateway详细分析

2023-05-14 05:05:26 网关 调用 熔断

回归cloud的学习，对于SpringCloud的架构与原理以及性能的分析我们都在之前的文章里写过：

springcloud架构的认识

我们之前测试过eureka服务注册功能，它能很好的保存服务之间的通讯关系，是维系微服务通讯网之间的电话本，同时也能够以心跳检测的形式监听每一个微服务的生命状态，对于结点进行很好的监控。那么我们今天的服务调用就是将接口变得易于管理，更简单的去调用分布式系统内的微服务。而对于同一时间大量调用的某一个微服务来说它的压力是巨大了，但是出于用户体验的原因，我们必须对用户返回什么，对前端给出一个响应，而不是挂出404或者非常慢的响应。那么熔断降级的处理就是非常合适的做法。另外我们对于分布式调用微服务的形式也应、配置一个类似于nignx之类的主机进行反向的分发。在我们的cloud生态立提供了gateway网关组件去实现请求的分发与微服务路由的管理。

那么就让我们用上次测试eureka的项目进行测试：

首先是利用feign组件实现服务调用与熔断降级（这里的熔断可以自行去配置，默认是超过1秒没给出响应就返回熔断的降级响应）：

  <!--引入feign服务调用-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

以上是feign的依赖，我们之前的项目采取的是父工程pom继承体系，便于管理公共依赖。


@EnableFeignClients

在orderApplication类上打上开启feign服务组件的注解。

这里先介绍如何使用feign实现简单的微服务调用：

我们需要有接口作为一个product服务调用的客户端（可以含有很多这样的客户端，便于管理不同的微服务调用接口）当前我们是order模块：


@FeignClient(name = "product")
public interface FeignInterface {
    
    @GetMapping("/product/{id}")
    Product findById(@PathVariable("id")int id);
}

然后我们就可以利用自动注入的形式在controller里优化接口了：

    @Autowired
    private FeignInterface feignInterface;
    @GetMapping("/buyByFeign/{id}")
    public Product getProductByFeign(@PathVariable("id") int id) {
        return feignInterface.findById(id);
    }

细心的同志可以看到之前的controller接口是这样的：

    @Autowired
    private RestTemplate restTemplate;
    @RequestMapping(value = "/buy/{id}", method = RequestMethod.GET)
    public Product getProductById(@PathVariable("id") int id) {
        return restTemplate.getForObject("Http://product/product/" + id, Product.class);
    }

两相对比，我们发现feign服务调用的形式完全不需要写任何请求语句，也不需要处理与product微服务之间的响应。浏览器访问时依旧按照order接口上的路径去写即可。

其次介绍一下feign实现的熔断：

我们对某一个微服务调用路线准备熔断：举个例子，本文主要是order与product模块之间的调用关系，因此熔断也就是处理从order到product模块之间的请求路线：

下一个实现类去实现feign服务调用接口实现的方法就是我们的熔断方法（注意这里开启熔断器服务的注解也需打在orderApplication类上，在下面介绍hystrix时会给出来）：

@Component("feignHystrix")
public class FeignHystrix implements FeignInterface{
    public Product findById(int id) {
        Product product = new Product();
        product.setId(-1);
        product.setProductName("服务熔断");
        return product;
    }
}

要打上spring组件注解交给spring管理，不然跑起来就是一个没有实例化的字节码文件，根本用不了。

其次我们需要告诉feign客户端，你这条调用线路的熔断降级处理类型：

@FeignClient(name = "product",fallback = FeignHystrix.class)
public interface FeignInterface {
    @GetMapping("/product/{id}")
    Product findById(@PathVariable("id")int id);
}

fallback = FeignHystrix.class就是确定熔断降级类型的配置。

这样的方式就可以实现feign的服务调用与熔断降级了。但是会出现直接就是熔断方法的响应，原因是在controller层的自动注入会直接默认你注入的是接口的实现类型，这里我们最好是绑定一下name。

其次我们来换一种熔断处理，也就是利用hystrix去实现服务调用关系间的熔断处理：

        <!--引入服务熔断hystrix-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            <version>2.2.10.RELEASE</version>
        </dependency>

以上是它的依赖，hystrix组件用起来也是十分的简单，会对你的要求进行不同的配置，这里本文只展示最基本的使用举例：


@EnableCircuitBreaker

记住在Application类上开启熔断器才行，基本的使用十分简单就是直接在controller接口类里这么写就可以：

    @Autowired
    private RestTemplate restTemplate;
    @RequestMapping(value = "/buy/{id}", method = RequestMethod.GET)
    @HystrixCommand(fallbackMethod = "getProductFallBack") //给接口配置hystrix熔断降级方法
    public Product getProductById(@PathVariable("id") int id) {
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            System.out.println("睡两秒等熔断");
        }
        return restTemplate.getForObject("http://product/product/" + id, Product.class);
    }
    
    public Product getProductFallBack(int id) {
        Product product = new Product();
        product.setId(-1);
        product.setProductName("服务熔断");
        return product;
    }

注意这个降级的方法是有要求的，参数类型与返回值要与接口方法一致。你也可以建立一个新的类型里面统一的书写降级方法，调用时配置上类型与方法的路径即可（默认是1秒不给响应就采取熔断降级，所以直接开线程睡2秒测试熔断响应）。

注册中心与服务发现可以使得微服务之间鸽子能够查询到各自的存在，不需要开发者手动的配置各个微服务的路由。服务调用与熔断降级有效的将微服务之间的调用与流量的压力进行了管控与优化，但是由客户端或者是浏览器发送来的请求如果还是直接ip加端口加访问路径的话，未必就太麻烦了？这样对于前端开发来说也是很大的痛点！所以nignx反向代理很受欢迎，也是采用一个nignx.conf文件作为内部系统服务接口的通讯录，外部请求统一ip与端口只需要给我你想要访问的服务名称我就可以帮你通讯。这也就是网关的基本功能。当然如果简单的路由分发nignx完全可以充当网关的角色，这里我们先介绍一下gateway组件的基本使用：

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

以上是gateway的依赖，我们需要前置知道的是gateway与spring WEB有冲突，所以最好不要安装web的依赖，如果和我一样是父工程pom管理的可以在application.yml文件配置这一项解决冲突：

spring:
  application:
    name: gateway
  main:
    web-application-type: Reactive

其次就是网关的配置信息了（你不需要写任何类型文件，只需要浅浅的配置一下yml文件）：

spring: 
    cloud:
        gateway:
          routes:
          - id: order
            uri: http://127.0.0.1:9002
            predicates:
            - Path=/order/**
          - id: product
            uri: http://127.0.0.1:9001
            predicates:
            - Path=/product/**

这个routers像极了view项目里我们书写的router.js里的routes[]数组的内容，微服务注册名称，微服务内部访问路径，微服务默认的访问入口（这里的入口是controller类型上打的@RequestMapping内容，后面的二级三级就是我们需要填写访问的）举个例子（gateway默认的端口是8080）我们现在需要访问order微服务的buy/1去查1号商品，之前我们的访问方式是：http://127.0.0.1:9002/order/buy/1

现在配置完以上的网关内容后我们只需要访问localhost:8080/order/buy/1（注意这个order是代表微服务名称，也就是你配置的id，可不是controller类型的一级路由）。

到此这篇关于SprinGCloud实现服务调用feign与熔断hystrix和网关gateway详细分析的文章就介绍到这了,更多相关SpringCloud服务调用feign内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！

相关文章