【微服务技术二】Feign、Gateway（路由、过滤器、跨域）的初步认知

news2024/11/24 12:59:01

微服务技术二

    • 五、Feign远程调用
      • Feign替代RestTemplate
      • 自定义Feign配置
        • 方式一：配置文件方式：
        • 方式二：java代码方式
      • Feign性能优化
      • Feign的最佳实践*
    • 六、Gateway网关
      • 搭建网关服务
      • 路由断言工厂Route Predicate Factory
      • 路由过滤器 GatewayFilter
      • 默认过滤器 DefaultFilter
      • 全局过滤器 GlobalFilter
      • 过滤器执行顺序
      • 跨域问题解决

五、Feign远程调用

之前远程调用使用RestTemplate，代码如下：

String url = "http://xxxservice/xxx接口/" + xxx参数;
User user= restTemplate.getForObject(url, User.class);

使用RestTemplate的缺陷：

  • 代码可读性差，编程体验不统一（莫名的url路径）
  • 参数复杂时的URL难以维护

Feign是一个声明式的http客户端，官方网址：https://github.com/OpenFeign/feign

Feign替代RestTemplate

使用Feign的步骤：

  • 1、引入依赖：
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
  • 2、在消费者服务的启动类添加注解开启Feign的功能：
@EnableFeignClients
  • 3、编写Feign客户端UserClient 类：
@FeignClient("userservice")
public interface UserClient {
	@GetMapping("/user/{id}")
	User findById(@PathVariable("id") Long id);
}
  • 4、 远程调用示例：
    在这里插入图片描述

主要是基于SpringMVC的注解来声明远程调用信息，比如：

  • 服务名称：userservice
  • 请求方式：GET
  • 请求路径：/user/{id}
  • 请求参数：Long id
  • 返回值类型：User
    【feign还集成了ribbon，实现了负载均衡】

自定义Feign配置

Feign运行自定义配置来覆盖默认配置，可以修改的配置如下：

类型作用说明
feign.Logger.Level修改日志级别包含四种不同的级别：NONE、BASIC、HEADERS、FULL
feign.codec.Decoder响应结果的解析器http远程调用的结果做解析，例如解析json字符串为java对象
feign.codec.Encoder请求参数编码将请求参数编码，便于通过http请求发送
feign.Contract支持的注解格式默认是SpringMVC注解
feign.Retryer失败重试机制请求失败的重试机制，默认是没有，不过会使用Ribbon的重试

【一般需要配置的就是日志级别】

配置Feign日志两种方式：【消费者】

方式一：配置文件方式：

  • 全局生效：
feign:
	client:
		config:
			default: # 这里用default就是全局配置，如果是写服务名，则是针对某个微服务的配置
				loggerLevel: FULL # 日志级别
  • 局部生效：
feign:
	client:
		config:
			xxxservice: # 这里写服务名，则是针对某个(xxxservice)微服务的配置
				loggerLevel: FULL # 日志级别

方式二：java代码方式

  • 1、需要先声明一个Bean：
public class FeignClientConfiguration {
	@Bean
	public Logger.Level feignLogLevel() {
		return Logger.Level.BASIC;
	}
}
  • 而后如果是全局配置，则把它放到@EnableFeignClients（启动类）这个注解中：
@EnableFeignClients(defaultConfiguration = FeignClientCongiguration.class)
  • 如果是局部配置，则把它放到@FeignClient（客户端）这个注解中：
@FeignClient(value = "xxxservice", congiguration = FeignClientConfiguration.class)

Feign性能优化

Feign底层的客户端实现：

  • URLConnection：默认实现，不支持连接池
  • Apache HttpClient：支持连接池
  • OKHttp：支持连接池

优化性能Feign从两个点：

  • 使用连接池代替默认的URLConnection
  • 日志级别，最好使用basic或none

Feign的性能优化-连接池配置：（消费者）

  • 引入依赖，Feign添加HttpClient的支持：
<dependency>
	<groupId>io.github.openfeign</groupId>
	<artifactId>feign-httpclient</artifactId>
</dependency>
  • 配置连接池：
feign:
	client:
		config:
			default: # default全局的配置
				loggerLevel: BASIC # 日志级别，BASIC就是基本的请求和响应信息
	httpclient:
		enable: true # 开启feign对HttpClient的支持
		max-connections: 200 # 最大的连接数
		max-connections-per-route: 50 # 每个路径的最大连接数

Feign的最佳实践*

  • 方式一(继承)：给消费者的FeignClient和提供者的controller定义统一的父接口作为标准。
    在这里插入图片描述
    缺陷：紧耦合，不推荐使用
  • 方式二(抽取)：将FeignClient抽取为独立模块，并且把接口有关的POJO、默认的Feign配置都放到这个模块中，提供给消费者使用
    在这里插入图片描述

抽取方式的步骤：
1、首先创建一个module，命名为feign-api，然后引入feign的starter依赖
在这里插入图片描述
2、将消费者中编写的客户端、实体类、配置类都复制到fein-api模块中
3、在消费者中引入feign-api的依赖
4、修改消费者服务中的所有与上述三个组件有关的import部分，改成导入feign-api中的包。
5、重启测试。

当定义的FeignClient不在SpringBootApplication的扫描包范围时，这些FeignClient无法使用，两种方式解决：

  • 指定FeignClient所在包
@EnableFeignClients(basePackages = "com.jules.feign.clients")
  • 方式二：
@EnableFeignClients(clients = {UserClient.class})

在这里插入图片描述

六、Gateway网关

网关功能：

  • 身份验证和权限校验（一切请求先到 网关，再到微服务）
  • 服务路由（根据请求判断去哪个服务）、负载均衡
  • 对用户请求做限流

SpringCloud中网关的实现包括两种：

  • gateway
  • zuul
    Zuul是基于Servlet的实现，属于阻塞式编程。而SpringCloudGateway则是基于Spring5中提供的WebFlux，属于响应式的编程，性能更好。

搭建网关服务

1、创建新的module，引入SpringCloudGateway的依赖和nacos的服务发现依赖：

<!-- 网关依赖-->
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!--nacos服务发现依赖-->
<dependency>
	<groupId>com.alibaba.cLoud</groupId>
	<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

2、配置application.yml，包括服务基本信息、nacos地址、路由

路由的配置包括;

  • 路由id：路由的唯一标示
  • 路由目标(uri)：路由的目标地址，http代表固定地址，lb代表根据服务名负载均衡
  • 路由断言 (predicates)：判断路由的规则
  • 路由过滤器 (filters)：对请求或响应做处理
server:
	port: 10010 # 网关端口
spring:
	application: 
		name: gateway # 服务名称
	cloud: 
		nacos:
			server-addr: localhost:8848 # nacos地址
		gateway:
			routes: # 网关路由配置(可多个)
				- id: xxx-service # 路由id，自定义，必须唯一
				  # uri: http:/127.0.0.1:8081 # 路由的目标地址 http就是固定地址，写死的
				  uri: lb://xxxservice # 路由的目标地址lb(loadBalance)就是负载均衡，后面跟服务名称
				  predicates: # 路由断言，就是判断请求是否符合路由规则的条件
				  	- Path=/xxx/** # 这个是按照路径匹配，只要以/xxx/开头就符合
				- id: yyy-service 
				  uri: lb://yyyservice 
				  predicates: 
				  	- Path=/yyy/**

在这里插入图片描述

路由断言工厂Route Predicate Factory

上述配置文件中写的断言规则只是字符串，这些字符串会被Predicate Factory读取并处理，转变为路由判断的条件
在这里插入图片描述

路由过滤器 GatewayFilter

GatewayFiler 是网关中提供的一种过滤器，可以对进入网关的请求和微服务返回的响应做处理，提供了31种不同的路由过滤器工厂。
在这里插入图片描述

一些路由过滤器工厂：

  • AddRequestHeader：给当前请求添加一个请求头
  • RemoveRequestHeader：移除请求中一个请求头
  • AddResponseHeader：给响应结果中添加一个响应头
  • RemoveResponseHeader：从响应结果中移除一个响应头
  • RequestRateLimiter：限制请求的流量
  • ……
    示例：给某一个服务加过滤器
    在这里插入图片描述
    改造测试：
    在这里插入图片描述

默认过滤器 DefaultFilter

给所有的服务都加上过滤器：

server:
	port: 10010 # 网关端口
spring:
	application: 
		name: gateway # 服务名称
	cloud: 
		nacos:
			server-addr: localhost:8848 # nacos地址
		gateway:
			routes: # 网关路由配置(可多个)
				- id: xxx-service # 路由id，自定义，必须唯一
				  # uri: http:/127.0.0.1:8081 # 路由的目标地址 http就是固定地址，写死的
				  uri: lb://xxxservice # 路由的目标地址lb(loadBalance)就是负载均衡，后面跟服务名称
				  predicates: # 路由断言，就是判断请求是否符合路由规则的条件
				  	- Path=/xxx/** # 这个是按照路径匹配，只要以/xxx/开头就符合
				- id: yyy-service 
				  uri: lb://yyyservice 
				  predicates: 
				  	- Path=/yyy/** 
			default-filter: # 默认过滤器，会对所有的路由请求都生效
				- AddRequestHeader=Truth, lalalala

全局过滤器 GlobalFilter

全局过滤器的作用也是处理一切进入网关的请求和微服务响应，与GatewayFilter的作用一样区别在于GatewayFilter通过配置定义，处理逻辑是固定的。而GlobalFilter的逻辑需要自己写代码实现。定义方式是实现ClobalFilter接口。
在这里插入图片描述
过滤器示例：

//@Order(-1)
@Component
public class AuthFilter implements GlobalFilter, Ordered
{
	 @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain)
    {
    	//1.获取请求参数
    	ServerHttpRequest request = exchange.getRequest();
    	MultiValueMap<String, String> params = request.getQueryParams();
    	//2.获取参数中的 authorization 参数
    	String auth = params.getFirst("authorization");
    	//3.判断参数值是否等于admin
    	if("admin".equals(auth)) {
    		//4.是，放行
    		return chain.filter(exchange);
    	}
    	//5.否，拦截
    	//5.1.设置状态码
    	exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED); //未认证=401
    	//5.2.拦截请求
    	return exchange.getResponse().setComplete();
    }
    
   @Override
    public int getOrder()
    {
        return -1;
    }
}

过滤器执行顺序

请求路由后，会将当前路由过滤器和DefaultFilter、 GlobalFilter，合并到一个过滤器链 (集合)中，排序后依次执行每个过滤器。
在这里插入图片描述

跨域问题解决

在这里插入图片描述
网关处理跨域采用的同样是CORS方案，并且只需要简单配置即可实现：

spring:
	cloud:
		gateway:
			globalcors: # 全局的跨域问题
				add-to-simple-url-handler-mapping: true # 解决options请求被拦截问题
				corsConfigurations:
					'[/**]':
						allowedOrigins: # 允许哪些网站的跨域请求
							- "http://localhost:端口"
							- "http://www.xxx.com"
						allowedMethods: # 允许的跨域ajax的请求方式
							- "GET"
							- "POST"
							- "DELETE"
							- "PUT"
							- "OPTIONS"
						allowedHeaders: "*" # 允许在请求中携带的头信息
						allowCredentials: true # 是否允许携带cookie
						maxAge: 360000 # 这次跨域检测的有效期

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/891231.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Linux网络编程(TCP状态转换关系)

Linux网络编程(TCP状态转换关系)

文章目录 前言一、TCP状态转换图二、TCP连接状态转换解析三、TCP断开状态转换解析四、为什么需要有2MLS时长总结 前言 本篇文章来讲解一下TCP的状态转换关系&#xff0c;学习这个状态转换关系对于我们深入了解网络编程是非常有必要的。 一、TCP状态转换图 二、TCP连接状态转换…
阅读更多...
【数据结构OJ题】相交链表

【数据结构OJ题】相交链表

原题链接&#xff1a;https://leetcode.cn/problems/intersection-of-two-linked-lists/description/ 目录 1. 题目描述 2. 思路分析 3. 代码实现 1. 题目描述 2. 思路分析 看到这道题&#xff0c;很容易想到的方法就是暴力求解&#xff0c;就是将一个链表的每个结点的地址…
阅读更多...
【Spring专题】Spring之Bean的生命周期源码解析——阶段二（一）（IOC之实例化）

【Spring专题】Spring之Bean的生命周期源码解析——阶段二（一）（IOC之实例化）

目录 前言阅读准备阅读指引阅读建议 课程内容一、SpringIOC之实例化1.1 简单回顾1.2 概念回顾1.3 核心方法讲解 二、方法讲解2.1 AbstractBeanFactory#getMergedLocalBeanDefinition&#xff1a;合并BeanDefinition2.2 AbstractAutowireCapableBeanFactory#createBean&#xff…
阅读更多...
iOS 17 测试版中 SwiftUI 视图首次显示时状态的改变导致动画“副作用”的解决方法

iOS 17 测试版中 SwiftUI 视图首次显示时状态的改变导致动画“副作用”的解决方法

问题现象 精彩的 SwiftUI 动画可以让我们的 App 活灵活现、精妙绝伦。不过原本正常的动画在测试版本的 iOS 里却有着让码农持续秃头的“副作用”&#xff1a; 我们希望在视图首次显示时驱动状态改变来产生橘色小球围绕红球旋转的动画&#xff0c;红球应该始终保持在屏幕中心。…
阅读更多...
Flink的Standalone部署实战

Flink的Standalone部署实战

在Flink是通用的框架&#xff0c;以混合和匹配的方式支持部署不同场景&#xff0c;而Standalone单机部署方便快速部署&#xff0c;记录本地部署过程&#xff0c;方便备查。 环境要求 1&#xff09;JDK1.8及以上 2&#xff09;flink-1.14.3 3&#xff09;CentOS7 Flink相关信…
阅读更多...
腾讯24届校招内推

腾讯24届校招内推

校招开始啦&#xff5e;有兴趣的话可以扫我的码投&#xff0c;也可以分享给身边找工作的同学&#xff5e; ❤投递攻略 1️⃣腾讯校招步骤&#xff0c;先微信扫码绑定内推关系&#xff0c;后在电脑上上传更改简历和部门投递 2️⃣投递时将选择投递部门&#xff0c;投递后将在…
阅读更多...
实战项目-在线学院 阿里云视频的操作

实战项目-在线学院 阿里云视频的操作

一 阿里云视频 1.1 阿里视频上传 1.2 阿里云视频上传
阅读更多...
Vue3 Vuex状态管理多组件传递数据简单应用

Vue3 Vuex状态管理多组件传递数据简单应用

去官网学习→安装 | Vuex cd 项目 安装 Vuex&#xff1a; npm install --save vuex 或着 创建项目时勾选Vuex vue create vue-demo ? Please pick a preset: Manually select features ? Check the features needed for your project: (Press <space> to se…
阅读更多...
RocketMQ主题下的队列只有两个被订阅

RocketMQ主题下的队列只有两个被订阅

一、场景 主题下的队列只有两个被订阅 二、消费者 一共有两个消费者 Consumer1 所在消费组&#xff1a;C_TEST_1订阅主题&#xff1a;fsc_wb_ccs_web_orderly_84 Consumer2 所在消费组&#xff1a;C_TEST_1订阅主题&#xff1a;fsc_wb_ccs_web_84 三、原因 两个不同的消…
阅读更多...
预演攻击：谁需要网络靶场，何时需要

预演攻击：谁需要网络靶场，何时需要

"网络演习 "和 "网络靶场 "几乎是当今信息安全领域最流行的词汇。与专业术语不同的是&#xff0c;这些词对于企业和高级管理人员来说早已耳熟能详&#xff1a;法律要求他们进行演习&#xff0c;包括网络演习&#xff0c;而网络射击场也经常在企业界和媒体上…
阅读更多...
数据生成 | MATLAB实现WGAN生成对抗网络数据生成

数据生成 | MATLAB实现WGAN生成对抗网络数据生成

数据生成 | MATLAB实现WGAN生成对抗网络数据生成 目录 数据生成 | MATLAB实现WGAN生成对抗网络数据生成生成效果基本描述程序设计参考资料 生成效果 基本描述 1.WGAN生成对抗网络&#xff0c;数据生成&#xff0c;样本生成程序&#xff0c;MATLAB程序&#xff1b; 2.适用于MATL…
阅读更多...
美能达打印机刷卡扫描文件后，用户收不到扫描邮件

美能达打印机刷卡扫描文件后，用户收不到扫描邮件

环境： 柯尼卡美能达一体机 bizhub 287 域服务器 Windows server 2019 问题描述： 新员工在域服务器创建账户后同步到打印服务器上面，他们在打印机扫描文件后，自动发邮件那个邮箱上没有他们邮件，导致他们也收不到邮件 正常是用户在打印机上刷卡后扫描件文件为PDF格式，…
阅读更多...
Jmeter 连接 MySQL 数据库脚本

Jmeter 连接 MySQL 数据库脚本

1、创建线程组 2、创建 JDBC Connection Configuration 3、创建 JDBC Request 4、最终创建的目录 5、重点来了 5.1 在百度中下载个 MySQL-connector-Java-8.0.28.jar&#xff0c;放在 jmeter 的 bin 目录下 5.2 在测试计划中&#xff0c;将 jar 包添加到脚本中 5.3 输入参…
阅读更多...
您可以购买 Banana Pi BPI-CM2 而不是 Raspberry Pi CM4。它提供什么？

您可以购买 Banana Pi BPI-CM2 而不是 Raspberry Pi CM4。它提供什么？

最近&#xff0c;Banana Pi&#xff08;SINOVOIP&#xff09;推出了Banana Pi BPI-CM2系统级模块&#xff08;SoM&#xff09;。BPI-CM2 是类似于Raspberry Pi CM4 的计算模块&#xff0c;提供一系列令人印象深刻的功能。Banana BPI-CM2 SoM 采用Rockchip RK3568四核 Cortex-A5…
阅读更多...
MMdetection在VisDrone2019上训练FCOS和CenterNet

MMdetection在VisDrone2019上训练FCOS和CenterNet

配置环境 Python 3.5>PyTorch 1.1>CUDA 9.0NCCL 2>GCC 4.9mmcv‘’ 把mmdetection的代码下载下来 git clone https://github.com/open-mmlab/mmdetection.git进入这个mmdetection文件,准备编译mmdetection的文件 cd mmdetection 装一下下面这些包&#xff0c; #…
阅读更多...
Three.js--》✨ 阳 光 dua 郎 大 男 孩 ✨——阿伟的自述

Three.js--》✨ 阳 光 dua 郎 大 男 孩 ✨——阿伟的自述

不要让鲲流太嚣张&#xff0c;我们杰流才是最弔的 ———— 阳光dua郎大男孩 目录 项目搭建 初始化three.js基础代码 获取项目所需素材 加载图片语音模型 今天简单实现一个three.js的3D故事小游戏&#xff0c;加强自己对three知识的掌握与学习&#xff0c;只有在项目中才能…
阅读更多...
YOLOv5基础知识入门（7）— NMS（非极大值抑制）原理解析

YOLOv5基础知识入门（7）— NMS（非极大值抑制）原理解析

前言&#xff1a;Hello大家好&#xff0c;我是小哥谈。NMS是指非极大值抑制&#xff08;non maximum suppression&#xff09;&#xff0c;它是一种常用于物体检测任务的算法。在物体检测中&#xff0c;通常会有多个预测框&#xff08;bounding box&#xff09;被提议出来&…
阅读更多...
3D图像驱动live2d--Kalidokit--人脸动作捕捉

3D图像驱动live2d--Kalidokit--人脸动作捕捉

3D图像驱动live2d–Kalidokit 可在线实时根据摄像头中人脸动作实现动作捕捉 Kalidokit https://kit.kalidoface.com/live2d/ https://github.com/yeemachine/kalidokit
阅读更多...
Spring系列篇--关于AOP【面向切面】的详解

Spring系列篇--关于AOP【面向切面】的详解

目录 一.AOP是什么 二.案例演示 1.前置通知1.1 先准备接口 1.2然后再准备好实现类 1.3对我们的目标对象进行JavaBean配置 1.4 编写前置系统日志通知 1.5配置系统通知XML中的JavaBean 1.6 配置代理XML中的JavaBean 1.7 测试代码开始测试 注意这里有一个报错问题&…
阅读更多...
谷歌在Chrome浏览器中推进抗量子加密技术

谷歌在Chrome浏览器中推进抗量子加密技术

近日&#xff0c;Chromium博客上发表的一篇博文称&#xff0c;为了加强网络安全&#xff0c;应对迫在眉睫的量子计算机威胁&#xff0c;谷歌各个团队密切合作&#xff0c;为网络向抗量子密码学的过渡做好准备。 谷歌的Chrome团队在博客中写道&#xff0c;该项目涉及修订技术标准…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023