《六》、springcloud微服务——Feign负载均衡

一、Feign概述

Feign是一个声明式WebService客户端。使用Feign能让编写Web Service客户端更加简单, 它的使用方法是定义一个接口,然后在上面添加注解,同时也支持JAX-RS标准的注解。Feign也支持可拔插式的编码器和解码器。Spring Cloud对Feign进行了封装,使其支持了Spring MVC标准注解和HttpMessageConverters。Feign可以与Eureka和Ribbon组合使用以支持负载均衡。
  即: Feign是一个声明式的Web服务客户端,使得编写Web服务客户端变得非常容易,只需要创建一个接口,然后在上面添加注解即可。

1、能干吗?

  Feign旨在使编写Java Http客户端变得更容易。
  前面在使用Ribbon+RestTemplate时,利用RestTemplate对http请求的封装处理,形成了一套模版化的调用方法。但是在实际开发中,由于对服务依赖的调用可能不止一处,往往一个接口会被多处调用,所以通常都会针对每个微服务自行封装一些客户端类来包装这些依赖服务的调用。所以,Feign在此基础上做了进一步封装,由他来帮助我们定义和实现依赖服务接口的定义。在Feign的实现下,我们只需创建一个接口并使用注解的方式来配置它(以前是Dao接口上面标注Mapper注解,现在是一个微服务接口上面标注一个Feign注解即可),即可完成对服务提供方的接口绑定,简化了使用Spring cloud Ribbon时,自动封装服务调用客户端的开发量。

2、Feign集成了Ribbon

  利用Ribbon维护microservicecloud-dept的服务列表信息,并且通过轮询实现了客户端的负载均衡。而与Ribbon不同的是,通过feign只需要定义服务绑定接口且以声明式的方法,优雅而简单的实现了服务调用。
  Feign通过接口的方法调用Rest服务(之前是Ribbon+RestTemplate),
  通过Feign直接找到服务接口,由于在进行服务调用的时候融合了Ribbon技术,所以也支持负载均衡作用。

二、Feign使用步骤

1、参考 microservicecloud-consumer-dept-80 新建 microservicecloud-consumer-dept-feign
2、修改 microservicecloud-consumer-dept-feign 相关内容

(1)、删除不需要的包及类

(2)、修改pom.xml
   添加feign相关依赖

    <!-- feign相关 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>

(3)、修改主启动类

  • 名字:DeptConsumer_feign_App.java
  • 内容:删除Ribbon相关的
package cn.smilexl.springcloud;

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

@SpringBootApplication
@EnableEurekaClient
public class DeptConsumer_feign_App {
    
    public static void main(String[] args) {
        SpringApplication.run(DeptConsumer_feign_App.class, args);
    }
}
3、修改 microservicecloud-api 工程

(1)、pom.xml文件
   添加feign相关依赖

  <!-- feign相关 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>

(2)、新建service包并在次包下新建 DeptClientService.java 接口

  • (1) 在接口上新增注解 @FeignClient
  • (2) 在接口中添加相关方法
package cn.smilexl.springcloud.service;

import java.util.List;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import cn.smilexl.springcloud.entities.Dept;

@FeignClient(value="MICROSERVICECLOUD-DEPT")
public interface DeptClientService {
    
    // 添加
    @GetMapping("/dept/add")
    public Boolean addDept(Dept dept);

    // 根据id查询
    @GetMapping("/dept/get/{id}")
    public Dept findById(@PathVariable("id") Long id);

    // 根据id查询
    @GetMapping("/dept/list")
    public List<Dept> findAll();    
}
  • (3) mvn clean / mvn install
4、修改 microservicecloud-consumer-dept-feign 工程的 controller

   添加上一步新建的 DeptClientService接口

package cn.smilexl.springcloud.controller;

import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import cn.smilexl.springcloud.entities.Dept;
import cn.smilexl.springcloud.service.DeptClientService;

@RestController
public class DeptController_Consumer {
    
    @Autowired
    private DeptClientService service;

    // 添加
    @GetMapping("/consumer/dept/add")
    public Boolean add(Dept dept) {
        return service.addDept(dept);
    }

    // 根据id查询
    @GetMapping("/consumer/dept/get/{id}")
    public Dept get(@PathVariable("id") Long id) {
        return service.findById(id);
    }

    // 根据id查询
    @GetMapping("/consumer/dept/list")
    public List<Dept> list() {
        return service.findAll();
    }
}
5、修改 microservicecloud-consumer-dept-feign 工程的主启动类
package cn.smilexl.springcloud;

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

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients(basePackages= {"cn.smilexl.springcloud"})
@ComponentScan("cn.smilexl.springcloud")
public class DeptConsumer_feign_App {

    public static void main(String[] args) {
        SpringApplication.run(DeptConsumer_feign_App.class, args);
    }
}
6、测试
  • 启动3个eureka集群 7001/7002/7003;
  • 启动3个部门微服务提供者 8001/8002/8003;
  • 启动 Feign 自己;
  • http: //localhost/consumer/dept/list
  • Feign 自带负载均衡配置项
7、总结

Feign通过接口的方法调用Rest服务(之前是Ribbon+Rest Template),
该请求发送给Eureka服务器(http: //MICROSERVICECLOUD-DEPT/dept/list),
通过 Feign 直接找到服务接口,由于在进行服务调用的时候融合了Ribbon技术,所以也支持负载均衡作用。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。