zoukankan      html  css  js  c++  java
  • Spring Cloud07: Feign 声明式接口调用

    一、什么是Feign

    Feign也是去实现负载均衡,但是它的使用要比Ribbon更加简化,它实际上是基于Ribbon进行了封装,让我们可以通过调用接口的方式实现负载均衡。Feign和Ribbon都是由Netflix提供的,Feign是一个声明式、模板化的Web Service客户端,它简化了开发者编写Web服务客户端的操作,开发者可以通过简单的接口和注解来调用HTTP API,使得开发变得更加简化、快捷。Spring Cloud Feign也是基于Netflix Feign的二次开发,它整合了Ribbon和Hystrix,具有可插拔、基于注解、负载均衡、服务熔断等一系列的便捷功能,也就是说我们在实际开发中可以用Feign来取代Ribbon。

    相比较于Ribbon+RestTemplate的方式,Feign大大简化了代码的开发,Feign支持多种注解,包括Feign注解、JAX-RS注解、Spring MVC注解等,Spring Cloud对Feign进行了优化,整合了Ribbon和Eureka,从而让Feign使用更加方便。

    二、Ribbon和Feign的区别

    Ribbon是一个通用的HTTP客户端工具,Feign是基于Ribbon实现的。

    三、Feign的优点

    1.Feign是一个声明式的Web Service客户端。

    2.支持Feign注解、Spring MVC注解、JAX-RS注解

    3.Feign是基于Ribbon实现,使用起来更加方便

    4.Feign集成了Hystrix,具备服务熔断的功能

    四、实战!

    1.创建Module,配置pom.xml如下:

        <dependency>
        	<groupId>org.springframework.cloud</groupId>
        	<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        	<version>2.0.2.RELEASE</version>
        </dependency>
        
        <dependency>
        	<groupId>org.springframework.cloud</groupId>
        	<artifactId>spring-cloud-starter-openfeign</artifactId>
        	<version>2.0.2.RELEASE</version>
        </dependency>
    

    2.创建配置文件application.yml,配置如下:

    server:
      port: 8050
    spring:
      application:
        name: feign
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:8761/eureka
      instance:
        prefer-ip-address: true
    

    3.创建启动类,代码如下:

    package com.zing;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    
    @SpringBootApplication
    @EnableFeignClients
    public class FeignApplication {
    	public static void main(String[] args) throws Exception {
    		SpringApplication.run(FeignApplication.class, args);
    	}
    
    }
    

    注解说明:

    ​ * @EnableFeignClients:声明其为Feign客户端

    4.创建声明式接口,代码如下:

    package com.zing.feign;
    
    import java.util.Collection;
    
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.GetMapping;
    
    import com.zing.entity.Student;
    
    @FeignClient(value = "provider")
    public interface IFeignService {
    	
    	@GetMapping("/student/findAll")
    	public Collection<Student> findAll();
    	
    	@GetMapping("/student/index")
    	public String index();
    }
    

    5.Handler代码如下:

    package com.zing.controller;
    
    import java.util.Collection;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.zing.entity.Student;
    import com.zing.feign.IFeignService;
    
    @RestController
    @RequestMapping("/feign")
    public class FeignHandler {
    
    	@Autowired
    	private IFeignService feignservice;
    	
    	@GetMapping("/findAll")
    	public Collection<Student> findAll(){
    		return feignservice.findAll();
    	}
    	
    	@GetMapping("/index")
    	public String index() {
    		return feignservice.index();
    	}
    	
    }
    

    6.测试feign的负载均衡功能

    ​ (1)分别启动注册中心,两个不同端口的服务提供者,feign,注册中心页面如下:

    img

    ​ (2)多次访问 http://localhost:8050/feign/index ,我们可以看到两个端口地址交替出现,证明Feign实现了负载均衡。如下图:

    img

    img

    7.测试Feign的熔断机制

    ​ (1)我们先停掉所有的服务提供者,只保留注册中心和Feign的服务,打开注册中心如下图:

    img

    ​ (2)再次访问 http://localhost:8050/feign/index 可看到如下图的内容:

    img

    ​ (3)为了不直接暴露错误信息,我们需要添加服务熔断机制,修改application.yml如下:

    server:
      port: 8050
    spring:
      application:
        name: feign
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:8761/eureka
      instance:
        prefer-ip-address: true
    feign:
      hystrix:
        enabled: true
    

    ​ 配置说明:

    ​ * feign.hystrix.enable:是否开启熔断机制,默认false。

    ​ (4)创建IFeignService的实现类FeignServiceImpl,在里面定义容错处理机制,通过@Component注解将FeignServiceImpl实例注入到IOC容器中,代码如下:

    package com.zing.feign.impl;
    
    import java.util.Collection;
    
    import org.springframework.stereotype.Component;
    
    import com.zing.entity.Student;
    import com.zing.feign.IFeignService;
    
    @Component
    public class FeignServiceImpl implements IFeignService{
    
    	@Override
    	public Collection<Student> findAll() {
    		return null;
    	}
    
    	@Override
    	public String index() {
    		return "服务器维护中。。。";
    	}
    
    }
    

    ​ (5)在IFeignService接口定义处定义@FeignClient的fallback属性来做降级处理,设置映射,映射到FeignServiceImpl中去。修改IFeignService后代码如下:

    package com.zing.feign;
    
    import java.util.Collection;
    
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.GetMapping;
    
    import com.zing.entity.Student;
    import com.zing.feign.impl.FeignServiceImpl;
    
    @FeignClient(value = "provider",fallback = FeignServiceImpl.class)
    public interface IFeignService {
    	
    	@GetMapping("/student/findAll")
    	public Collection<Student> findAll();
    	
    	@GetMapping("/student/index")
    	public String index();
    }
    

    ​ (6)重复(1)、(2)步,出现以下界面,证明服务熔断机制起效。如图:

    img

    五、总结

    我们在本次的代码中,采用Feign实现了负载均衡和服务熔断。

  • 相关阅读:
    实验五——循环结构学习总结
    实验七——函数定义及调用总结
    实验九——基本数据类型存储及应用总结
    实验六——循环结构程序练习总结
    第二次作业及总结——数据类型和运算符
    实验八——函数定义及调用总结
    实验四——多分支结构及本章总结
    开篇随笔
    第三次作业——for 语句及分支结构elseif
    第二次作业
  • 原文地址:https://www.cnblogs.com/kylinxxx/p/14510922.html
Copyright © 2011-2022 走看看