云原生微服务 第六章 Spring Cloud Eureka微服务的远程调用、负载均衡

系列文章目录

第一章 Java线程池技术应用
第二章 CountDownLatch和Semaphone的应用
第三章 Spring Cloud 简介
第四章 Spring Cloud Netflix 之 Eureka
第五章 Spring Cloud Netflix 之 Ribbon
第六章 Spring Cloud 之 OpenFeign

在这里插入图片描述

文章目录

  • 系列文章目录
  • 前言
  • 1、OpenFeign的实现原理和过程
    • 1.1、OpenFeign支持Spring Cloud体系内的所有注解
    • 1.2、OpenFeign自动封装HTTP请求
    • 1.3、OpenFeign支持请求拦截器和响应拦截器
    • 1.4、在Spring项目中的过程
    • 1.5、远程调用
  • 2、常用注解
  • 3、实践
    • 3.1、修改pom.xml配置
    • 3.2、增加用户服务接口，添加FeignClient配置
    • 3.3、修改控制层UserConsumerController
    • 3.4、启动类增加OpenFeign配置
    • 3.5、远程调用超时设置
  • 4、总结

前言

OpenFeign 全称 Spring Cloud OpenFeign，它是 Spring 官方推出的一种声明式服务调用与负载均衡组件。我们可以像调用本地方法一样来调用远程服务，而完全感觉不到这是在进行远程调用。
在这里插入图片描述

OpenFeign_18">1、OpenFeign的实现原理和过程

OpenFeign是一个声明式的Web服务客户端，它使得编写Web服务客户端变得更加简单。通过使用OpenFeign，开发者可以更加容易地创建与远程服务进行交互的客户端代码。
OpenFeign通过自动封装HTTP请求和简化远程调用代码的过程，使得开发者可以更加专注于业务逻辑的实现，提高了开发效率和代码可读性。

OpenFeignSpring_Cloud_21">1.1、OpenFeign支持Spring Cloud体系内的所有注解

例如@GetMapping、@PostMapping、@PathVariable、@RequestParam等，同时也支持自定义注解。

OpenFeignHTTP_24">1.2、OpenFeign自动封装HTTP请求

包括HTTP方法、请求URL、请求参数、请求头等，开发者无需手动编写HTTP请求代码。只需要定义一个接口，并通过注解指定接口的路径和方法，OpenFeign就会自动发送HTTP请求并解析响应数据。

OpenFeign_27">1.3、OpenFeign支持请求拦截器和响应拦截器

开发者可以通过实现请求拦截器和响应拦截器来对HTTP请求和响应进行处理，例如添加认证信息、重试等。

1.4、在Spring项目中的过程

在Spring项目启动中，OpenFeign会发起一个主动扫包的过程。从指定目录下加载所有被@FeignClient修饰的接口，将这些接口转换为Bean，交给Spring来管理。这些接口会经过MVC Constract解析，将方法上的注解解析出来放到MethodMetadata中。每一个FeignClient接口会生成一个动态代理对象，指向包含方法的MethodHandler的HashMap。

1.5、远程调用

当服务A发起远程调用时，它会从动态代理proxy中找到一个MethodHandler的实例，生成request，包含请求的url。经过负载均衡算法找到一个服务的IP地址，拼接请求的URL。服务B处理服务A发起的远程调用，执行逻辑后，返回响应给A。

2、常用注解

使用 OpenFegin 进行远程服务调用时，常用注解如下表。

注解说明
@FeignClient该注解用于通知 OpenFeign 组件对 @RequestMapping 注解下的接口进行解析，并通过动态代理的方式产生实现类，实现负载均衡和服务调用。
@EnableFeignClients该注解用于开启 OpenFeign 功能，当 Spring Cloud 应用启动时，OpenFeign 会扫描标有 @FeignClient 注解的接口，生成代理并注册到 Spring 容器中。
@RequestMappingSpring MVC 注解，在 Spring MVC 中使用该注解映射请求，通过它来指定控制器（Controller）可以处理哪些 URL 请求，相当于 Servlet 中 web.xml 的配置。
@GetMappingSpring MVC 注解，用来映射 GET 请求，它是一个组合注解，相当于 @RequestMapping(method = RequestMethod.GET) 。
@PostMappingSpring MVC 注解，用来映射 POST 请求，它是一个组合注解，相当于 @RequestMapping(method = RequestMethod.POST) 。

3、实践

3.1、修改pom.xml配置

在上一章节 [《微服务实战》 第五章 Spring Cloud Netflix 之 Ribbon ] 基础上，添加OpenFeign依赖项

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.kelvin</groupId>
        <artifactId>SpringCloud</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>
    <artifactId>customer-api</artifactId>
    <name>customer-api</name>
    <description>customer-api</description>

    <properties>
        <java.version>1.8</java.version>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>
    <dependencies>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--devtools 开发工具-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <!--Spring Boot 测试-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!--junit 测试-->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
        <!-- 修改后立即生效，热部署 -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>springloaded</artifactId>
            <version>1.2.8.RELEASE</version>
        </dependency>
        <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>
           <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-loadbalancer -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-loadbalancer</artifactId>
        </dependency>
        <dependency>
            <groupId>com.kelvin</groupId>
            <artifactId>common-api</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
    </dependencies>

</project>

3.2、增加用户服务接口，添加FeignClient配置

import com.kelvin.common.model.UserInfo;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import java.util.List;

/***
 * @title 用户服务接口
 * @desctption 用户服务接口
 * @author kelvin
 * @create 2023/5/11 16:44
 **/
@Component
@FeignClient(value = "USER-SERVICE")
public interface UserService {
    @RequestMapping(value = "/user/userInfoList",method = RequestMethod.GET)
    public List<UserInfo> userInfoList();
}

3.3、修改控制层UserConsumerController

import com.kelvin.common.model.UserInfo;
import com.kelvin.customerapi.service.UserService;
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 java.util.List;

/***
 * @title UserConsumerController
 * @desctption 用户控制层
 * @author kelvin
 * @create 2023/5/11 14:22
 **/
@RestController
@RequestMapping("/user")
public class UserConsumerController {

/*    @Autowired
    private UserConsumerService userConsumerService;*/

    @Autowired
    private UserService userService;

    @GetMapping("/userInfoList")
    public List<UserInfo> userInfoList(){
        return userService.userInfoList();
    }
}

OpenFeign_183">3.4、启动类增加OpenFeign配置

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;

/***
 * @title SpringBoot 启动类
 * @desctption SpringBoot 启动类
 * @author kelvin
 * @create 2023/5/11 12:22
 **/
@SpringBootApplication
@EnableFeignClients
public class CustomerApiApplication {

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

}

3.5、远程调用超时设置

openFeign其实是有默认的超时时间的，默认分别是连接超时时间10秒、读超时时间60秒
可添加配置，自定义超时时间


server:
  port: 80

eureka:
  client:
    register-with-eureka: false #本微服务为服务消费者，不需要将自己注册到服务注册中心
    fetch-registry: true  #本微服务为服务消费者，需要到服务注册中心搜索服务
    service-url:
      defaultZone: http://localhost:7001/eureka
feign:
  client:
    config:
      default:
        #建立连接所用的时间，适用于网络状况正常的情况下，两端连接所需要的时间
        connect-timeout: 5000
        #指建立连接后从服务端读取到可用资源所用的时间
        read-timeout: 10000

4、总结

OpenFeign通过自动封装HTTP请求和简化远程调用代码的过程，使得开发者可以更加专注于业务逻辑的实现，提高了开发效率和代码可读性。


http://www.niftyadmin.cn/n/5066766.html

相关文章

【c++11特性】——static_cast，dynamic_cast，const_cast，reinterpret_cast解析

【c++11特性】——static_cast，dynamic_cast，const_cast，reinterpret_cast解析

目录 1.static_cast 2.dynamic_cast dynamic_cast为什么只能用于具有虚函数的类&#xff1f; 3.const_cast 4.reinterpret_cast reinterpret_cast 的作用 static_cast 和dynamic_cast的区别&#xff1f; 1.static_cast 概念 static_cast 是C中的一种类型转换运算符&am…
阅读更多...
【LeetCode热题100】--34.在排序数组中查找元素的第一个和最后一个位置

【LeetCode热题100】--34.在排序数组中查找元素的第一个和最后一个位置

34.在排序数组中查找元素的第一个和最后一个位置 二分查找中&#xff0c;寻找 leftIdx 即为在数组中寻找第一个大于等于 target 的下标&#xff0c;寻找 rightIdx 即为在数组中寻找第一个大于 target 的下标&#xff0c;然后将下标减一。进行两次查找 class Solution {public …
阅读更多...
Docker 学习总结（79）—— Dockerfile 编写技巧总结

Docker 学习总结（79）—— Dockerfile 编写技巧总结

目标 更快的构建速度 更小的 Docker 镜像大小 更少的 Docker 镜像层 充分利用镜像缓存 增加 Dockerfile 可读性 让 Docker 容器使用起来更简单 总结 编写 .dockerignore 文件 容器只运行单个应用 将多个 RUN 指令合并为一个 基础镜像的标签不要用 latest 每个 RUN 指令后删除多…
阅读更多...
【物联网】浅谈单片机中的看门狗

【物联网】浅谈单片机中的看门狗

STM32看门狗是一种重要的系统保护机制&#xff0c;能够监控系统的运行状态并在故障时自动重启。它在各个领域都有广泛的应用&#xff0c;如工业自动化、通信设备和汽车电子等。通过配置和控制看门狗定时器&#xff0c;我们可以提高系统的稳定性和可靠性。在实际应用中&#xff…
阅读更多...
如何在windows系统环境下使用tail命令查看日志

如何在windows系统环境下使用tail命令查看日志

答案是&#xff1a; 使用tail for Windows工具 tail for Windows 是便携式软件不需要安装&#xff0c;它可用于显示文件的最后一行并跟踪/监视文件的更改。 下载地址&#xff1a; https://tail-for-windows.en.softonic.com/ 点击直接下载 解压使用 解压后需将tail.exe放入 c:…
阅读更多...
Java基于SSM的校园一卡通系统设计与实现

Java基于SSM的校园一卡通系统设计与实现

末尾获取源码 开发语言&#xff1a;Java Java开发工具&#xff1a;JDK1.8 后端框架&#xff1a;SSM 前端&#xff1a;采用JSP技术开发 数据库&#xff1a;MySQL5.7和Navicat管理工具结合 服务器&#xff1a;Tomcat8.5 开发软件&#xff1a;IDEA / Eclipse 是否Maven项目&#x…
阅读更多...
小团队内部资料共享协作：有效实施策略与方法

小团队内部资料共享协作：有效实施策略与方法

在高效率的办公节奏下&#xff0c;传统的文件共享方式无法匹配许多团队的需求&#xff0c;并且在现实使用过程中往往存在许多问题&#xff0c;如版本混乱、权限管理困难等。那么小团队的内部资料共享协作应该怎么做呢&#xff1f; 小型团队可以借助专业的协作工具实现高效内部…
阅读更多...
Java数组案例

Java数组案例

定义一个数组&#xff0c;存储1&#xff0c;2&#xff0c;3&#xff0c;4&#xff0c;5&#xff0c;6&#xff0c;7&#xff0c;8&#xff0c;9&#xff0c;10&#xff0c;遍历数组&#xff0c;统计数组里面一共有多少个能被3整除的数字 public class index {public static voi…
阅读更多...
最新文章

Copyright @ 2022~2023