Spring Cloud之Feign

生活中,最使人疲惫的往往不是道路的遥远,而是心中的郁闷;最使人痛苦的往往不是生活的不幸,而是希望的破灭;最使人颓废的往往不是前途的坎坷,而是自信的丧失;最使人绝望的往往不是挫折的打击,而是心灵的死亡。所以我们要有自己的梦想,让梦想的星光指引着我们走出落漠,走出惆怅,带着我们走进自己的理想。

导读:本篇文章讲解 Spring Cloud之Feign,希望对大家有帮助,欢迎收藏,转发!站点地址:www.bmabk.com,来源:原文

Feign的概述

Feign是Netflix公司开源的轻量级rest客户端,使用Feign可以非常方便的实现Http 客户端。Spring Cloud引入Feign并且集成了Ribbon实现客户端负载均衡调用。

Feign不但整合了Ribbon和Hystrix的功能,还提供了一种比Ribbon更简单的服务调用方式 ——— 声明式服务调用。

Feign的使用

添加依赖

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

定义接口

定义FeignClient接口
@Component
@FeignClient(value = "eureka-client1") //指定远程调用的服务名
public interface TestController {
    //远程调用test接口
    @GetMapping("/test")//用GetMapping标识远程调用的http的方法类型
    public String test();
}

启动类添加注解

使用@EnableFeignClients和@EnableDiscoveryClient注解,开启Spring Cloud Feign和服务注册与发现

@SpringBootApplication
@EnableFeignClients
@EnableEurekaClient
public class DemoApplication {

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

服务提供者

@RestController
public class TestController {

    @GetMapping("/test")
    public String test() {
        return "hello world";
    }

    @PostMapping("/getUser")
    public User getUser(@RequestBody User user) {
        return user;
    }
}

服务消费者

server:
  port: 8083
  
spring:
  application:
    name: Server-Consumer
    
eureka:
  client:
    serviceUrl:
      defaultZone: http://admin:admin123@localhost:8080/eureka/
     

在Spring Cloud Ribbon中访问服务需要通过RestTemplate对象来实现,并且参数绑定过程繁琐。Feign对这个步骤进行了进一步的封装,使用Feign调用服务只需要定义一个接口,然后将服务提供者中的部分代码复制改造即可.

//@FeignClient("Server-Produce")注解获取服务,其中服务名称不区分大小写。
@FeignClient("Server-Produce")
public interface ITestService {

    @GetMapping("/test")
    public String test();

    @PostMapping("/getUser")
    public User getUser(User user);
}

执行测试

@RestController
public class TestController {

    @Autowired
    private ITestService testService;

    @GetMapping("/test")
    public String test(){
        return testService.test();
    }

    @GetMapping("/getUser")
    public User getUser(){
        User user = new User();
        user.setUsername("小白");
        return testService.getUser(user);
    }
}

在这里插入图片描述

Feign的配置

配置Hystrix

# 开启Hystrix
feign:
  hystrix:
    enabled: true

创建TestService 类实现ITestService接口,重写方法,这些方法就是处理服务降级的方法

@Service
public class TestService implements ITestService{
    @Override
    public String test() {
        return "服务暂时不可用,请稍后重试";
    }

    @Override
    public User getUser(User user) {
        return null;
    }
}

fallback 属性来指定对应的服务降级实现类:

@FeignClient(value = "Server-Produce",fallback = TestService.class)
public interface ITestService {

    @GetMapping("/test")
    public String test();

    @PostMapping("/getUser")
    public User getUser(User user);
}

在这里插入图片描述

请求压缩

Feign支持对请求与响应进行GZIP压缩,以减少通信过程中的性能损耗

# 开启Hystrix
feign:
  hystrix:
    enabled: true
   # 开启压缩
  compression:
    request:
      enabled: true
      # 指定压缩的请求数据类型
      mime-types: text/xml,application/xml,application/json
      # 指定请求压缩的大小下限,超过这个大小的请求才会对其进行压缩
      min-request-size: 2048
    response:
      enabled: true

日志配置

Feign提供了日志打印的功能,Feign的日志级别分为四种:

NONE: 不记录任何信息。

BASIC: 仅记录请求方法、URL以及响应状态码和执行时间。

HEADERS: 除了记录BASIC级别的信息之外,还会记录请求和响应的头信息。

FULL: 记录所有请求与响应的明细,包括头信息、请求体、元数据等。

请求压缩

@SpringBootTest
@RunWith(SpringRunner.class)
public class TestFeign {
    @Autowired
    //接口代理对象,由Feign生成代理对象
    TestController testController; 

    @Test
    public void testRibbon(){
        //发起远程调用
        String string = testController.test();
        System.out.println(string);
    }
}
 [main] INFO  c.netflix.discovery.DiscoveryClient - Starting heartbeat executor: renew interval is: 30
 [main] INFO  c.n.discovery.InstanceInfoReplicator - InstanceInfoReplicator onDemand update allowed rate per min is 4
 [main] INFO  c.netflix.discovery.DiscoveryClient - Discovery Client initialized at timestamp 1608039839407 with initial instances count: 3
 [main] INFO  c.n.config.ChainedDynamicProperty - Flipping property: eureka-client1.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
 [main] INFO  c.n.l.DynamicServerListLoadBalancer - DynamicServerListLoadBalancer for client eureka-client1 initialized: DynamicServerListLoadBalancer:{NFLoadBalancer:name=eureka-client1,current list of Servers=[127.0.0.1:8081],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:127.0.0.1:8081;	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.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList@2fca282c
{"name":"lisi","age":"20"}

在这里插入图片描述

Feign工作原理

1、启动类添加@EnableFeignClients注解,Spring会扫描标记了@FeignClient注解的接口,并生成此接口的代理对象

2、@FeignClient(value = "eureka-client1")指定eureka的服务名称,Feign会从注册中心获取eureka服务列表,并通过负载均衡算法进行服务调用。

3、在接口方法 中使用注解@GetMapping("/test"),指定调用的url,Feign将根据url进行远程调用。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/137037.html

(0)
飞熊的头像飞熊bm

相关推荐

发表回复

登录后才能评论
极客之音——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!