小言_互联网的博客

SpringCloud入门(八) ------ 使用Feign进行负载均衡

2020-04-01 15:16 209人阅读  评论(0)

Feign:

官网:

http://projects.spring.io/spring-cloud/spring-cloud.html#spring-cloud-feign

定义:

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

用法:

只需要创建一个接口，然后在上面添加注解即可。
参考官网：https://github.com/OpenFeign/feign

Feign的作用:

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

Feign集成了Ribbon

利用Ribbon维护了MicroServiceCloud-Dept的服务列表信息，并且通过轮询实现了客户端的负载均衡。而与Ribbon不同的是，通过feign只需要定义服务绑定接口且以声明式的方法，优雅而简单的实现了服务调用

搭建Feign进行负载均衡

因为是面向接口的负载均衡，所以需要有公用的接口，供调用方调用,在公用的项目里，加入相应的接口与Feign依赖：

pom:

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>jymcloudservice</artifactId>
        <groupId>com.jym</groupId>
        <version>1.0-SNAPSHOT</version>
        <relativePath>../jymcloudservice/pom.xml</relativePath>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>jymcloudservice-common</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.10</version>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-feign</artifactId>
        </dependency>
    </dependencies>


</project>

新建调用接口，加入FeignClient注解:value 值为在eureka注册的服务名

package com.jym.jymcloudservice.service;

import com.jym.jymcloudservice.entity.Dept;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import java.util.List;

/**
 * @program: cloudTest
 * @description:
 * @author: jym
 * @create: 2020/02/29
 */
@FeignClient(value = "JYMSERVICECLOUD-DEPT")
public interface DeptClientService {

    @RequestMapping(value = "/dept/get/{id}",method = RequestMethod.GET)
    public Dept get(@PathVariable("id") long id);

    @RequestMapping(value = "/dept/list",method = RequestMethod.GET)
    public List list();

}

然后maven clean install，更新服务与调用方的依赖

调用方：

Pom文件:

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>jymcloudservice</artifactId>
        <groupId>com.jym</groupId>
        <version>1.0-SNAPSHOT</version>
        <relativePath>../jymcloudservice/pom.xml</relativePath>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>jymcloudservice-consumer-feign</artifactId>


    <dependencies>
        <dependency>
            <artifactId>jymcloudservice-common</artifactId>
            <groupId>com.jym</groupId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>ch.qos.logback</groupId>
            <artifactId>logback-core</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jetty</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>springloaded</artifactId>
        </dependency>
        <!-- ribbon相关 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-ribbon</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId> spring-cloud-starter-config</artifactId>
        </dependency>
        <!-- feign相关 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-feign</artifactId>
        </dependency>

    </dependencies>

</project>

yml:

server:
  port: 9002

eureka:
  client:
    register-with-eureka: false
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

controller:要使用新加入的service 不使用RestTemplate:

package com.jym.deptconsumer.controller;

import com.jym.jymcloudservice.entity.Dept;
import com.jym.jymcloudservice.service.DeptClientService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * @program: cloudTest
 * @description:
 * @author: jym
 * @create: 2020/02/26
 */
@RestController
@RequestMapping("/dept")
public class DeptConsumerController {


    @Autowired
    private DeptClientService service;



    @RequestMapping(value = "/get/{id}")
    public Dept get (@PathVariable long id) {
        return service.get(id);
    }


    @RequestMapping(value = "/list",method = RequestMethod.GET)
    public List<Dept> list () {
        return service.list();
    }
}

启动类，开启Feign

package com.jym.deptconsumer;

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

/**
 * @program: cloudTest
 * @description:
 * @author: jym
 * @create: 2020/02/26
 */
@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients(basePackages= {"com.jym.jymcloudservice"}) // 对应接口的包
public class JymConsumerApplicationFeign {
    public static void main(String[] args) {
        SpringApplication.run(JymConsumerApplicationFeign.class,args);
    }

}

EnableFeignClients注解的basePackages为调用的接口类所在的包

测试:

启动eureka 以及服务方后，启动该项目,通过浏览器调用:

调用成功

总结:

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

学习年限不足，知识过浅，说的不对请见谅。

世界上有10种人，一种是懂二进制的，一种是不懂二进制的。


转载：https://blog.csdn.net/weixin_43326401/article/details/104582185
查看评论
* 以上用户言论只代表其个人观点，不代表本网站的观点或立场