Spring Cloud中的服务路由与过滤技术实现

Spring Cloud中的服务路由与过滤技术实现

大家好,我是微赚淘客系统3.0的小编,也是冬天不穿秋裤,天冷也要风度的程序猿!

在微服务架构中,服务路由与过滤是确保服务之间通信有效性和安全性的重要技术。Spring Cloud作为一个强大的微服务框架,提供了完善的服务路由与过滤机制,使得开发者可以轻松地实现这些功能。本文将详细介绍如何在Spring Cloud中实现服务路由与过滤,并给出相关的Java代码示例。

一、Spring Cloud Gateway简介

Spring Cloud Gateway是Spring Cloud生态系统中的一个重要组件,用于实现动态路由、监控、弹性限流和安全等功能。它是基于Spring 5.0、Spring Boot 2.0和Project Reactor构建的,具有异步和非阻塞的特性。

二、服务路由的实现

服务路由是指根据请求的不同,将请求转发到不同的微服务上。在Spring Cloud Gateway中,路由由RouteLocatorBuilder类来配置。下面是一个简单的路由配置示例:

1. 引入依赖

pom.xml文件中引入Spring Cloud Gateway依赖:

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

2. 配置路由

在Spring Boot应用的主类中配置路由:

package cn.juwatech.gateway;import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class GatewayConfig {@Beanpublic RouteLocator customRouteLocator(RouteLocatorBuilder builder) {return builder.routes().route("path_route", r -> r.path("/api/service1/**").uri("http://localhost:8081")).route("host_route", r -> r.host("*.juwatech.cn").uri("http://localhost:8082")).build();}
}

在上述代码中,定义了两个路由规则:

  • 当请求路径匹配/api/service1/**时,路由到http://localhost:8081
  • 当请求主机名匹配*.juwatech.cn时,路由到http://localhost:8082

三、服务过滤的实现

过滤器用于对请求和响应进行处理,可以实现认证、鉴权、日志记录、请求修改等功能。Spring Cloud Gateway提供了多种内置过滤器,同时也支持自定义过滤器。

1. 内置过滤器

Spring Cloud Gateway提供了一些常用的内置过滤器,如AddRequestHeader、AddResponseHeader、RewritePath等。下面是一个使用内置过滤器的示例:

@Bean
public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {return builder.routes().route("rewrite_route", r -> r.path("/api/service2/**").filters(f -> f.rewritePath("/api/service2/(?<segment>.*)", "/${segment}").addRequestHeader("X-Request-Source", "Gateway")).uri("http://localhost:8083")).build();
}

在上述代码中,使用了RewritePath和AddRequestHeader两个过滤器,将请求路径/api/service2/后的部分重写,并添加一个请求头。

2. 自定义过滤器

自定义过滤器可以满足一些特殊需求。以下是一个自定义全局日志过滤器的示例:

package cn.juwatech.gateway;import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
import org.springframework.core.Ordered;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;import java.util.logging.Logger;@Component
public class LoggingFilter implements GlobalFilter, Ordered {private static final Logger logger = Logger.getLogger(LoggingFilter.class.getName());@Overridepublic Mono<Void> filter(ServerWebExchange exchange, org.springframework.cloud.gateway.filter.GatewayFilterChain chain) {ServerHttpRequest request = exchange.getRequest();logger.info("Request URI: " + request.getURI());return chain.filter(exchange).then(Mono.fromRunnable(() -> {logger.info("Response Status Code: " + exchange.getResponse().getStatusCode());}));}@Overridepublic int getOrder() {return -1; // 优先级,数值越小优先级越高}
}

在上述代码中,自定义了一个全局过滤器LoggingFilter,用于记录请求URI和响应状态码。通过实现GlobalFilterOrdered接口,可以控制过滤器的执行顺序。

四、综合示例

最后,将路由和过滤结合起来,构建一个完整的Spring Cloud Gateway应用。以下是一个完整的示例,包括路由配置和自定义过滤器:

package cn.juwatech.gateway;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;@SpringBootApplication
public class GatewayApplication {public static void main(String[] args) {SpringApplication.run(GatewayApplication.class, args);}@Beanpublic RouteLocator customRouteLocator(RouteLocatorBuilder builder) {return builder.routes().route("service1_route", r -> r.path("/api/service1/**").filters(f -> f.addRequestHeader("X-Request-Source", "Gateway")).uri("http://localhost:8081")).route("service2_route", r -> r.host("*.juwatech.cn").filters(f -> f.rewritePath("/api/service2/(?<segment>.*)", "/${segment}")).uri("http://localhost:8082")).build();}
}

五、总结

本文详细介绍了如何在Spring Cloud中实现服务路由与过滤技术。通过使用Spring Cloud Gateway,可以轻松地实现动态路由和复杂的过滤逻辑,提升微服务架构的灵活性和安全性。我们探讨了路由配置、内置过滤器、自定义过滤器以及综合示例,帮助大家更好地理解和应用这些技术。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Python28-6 随机森林

随机森林算法详细介绍 1. 理论背景 随机森林&#xff08;Random Forest&#xff09;是一种由Leo Breiman和Adele Cutler在2001年提出的集成学习方法。它结合了多个决策树的预测结果&#xff0c;以提高模型的准确性和鲁棒性。 2. 算法细节 随机森林的构建过程可以分为以下几…

Qt——升级系列(Level Eight):界面优化

目录 QSS 背景介绍 基本语法 QSS设置方式 指定控件样式设置 全局样式设置 从文件加载样式表 使用Qt Designer 编辑样式 选择器 选择器概况 子控件选择器 伪类选择器 样式属性 盒模型 控件样式示例 按钮 复选框、单选框 输入框 列表 菜单栏 登录界面 绘图 基本概念 绘制各种形…

[Go 微服务] Kratos 使用的简单总结

文章目录 1.Kratos 简介2.传输协议3.日志4.错误处理5.配置管理6.wire 1.Kratos 简介 Kratos并不绑定于特定的基础设施&#xff0c;不限定于某种注册中心&#xff0c;或数据库ORM等&#xff0c;所以您可以十分轻松地将任意库集成进项目里&#xff0c;与Kratos共同运作。 API -&…

Linux内网端口转公网端口映射

由于服务商做安全演练&#xff0c;把原先服务器内网的端口映射到外网端口全都关闭了&#xff0c;每次维护服务器特别麻烦&#xff0c;像数据库查询如果用原生的mysql 去连接&#xff0c;查询返回的结果乱了&#xff0c;非常不方便。 查了服务还是可以正常访问部分外网的&#x…

知识图谱查询语言的表示

文章目录 SPARQL知识图谱查询基本构成常见的SPARQL查询算子语义Markup表示语言SPARQL知识图谱查询基本构成 RDF 支持类似数据库的查询语言,叫作SPARQL,它提供了查询RDF 数据的标准语法、处理SPARQL查询的规则以及结果返回形式。 变量,RDF中的资源,以“?”或者“$”指示;…

【chatgpt】pytorch的全连接层FC

文章目录 创建全连接层全连接层&#xff08;线性层&#xff09;使用 PyTorch 定义全连接层1. 定义一个全连接层2. 查看层的参数3. 使用全连接层 示例&#xff1a;构建一个简单的神经网络总结 打印FC参数输出解释完整代码示例示例输出总结 线性层的参数和属性线性层的参数和属性…

抖音外卖服务商入驻流程及费用分别是什么?入驻官方平台的难度大吗?

随着抖音关于新增《【到家外卖】内容服务商开放准入公告》的意见征集通知&#xff08;以下简称“通知”&#xff09;的发布&#xff0c;抖音外卖服务商入驻流程及费用逐渐成为众多创业者所关注和热议的话题。不过&#xff0c;就当前的讨论情况来看&#xff0c;这个话题似乎没有…

软件测试中安全测试包含内容及安全测试怎么测

一、软件测试安全测试包含哪些 1. 漏洞扫描 漏洞扫描是软件测试安全测试的基础&#xff0c;它用于检测应用程序和系统中存在的已知漏洞。安全测试工具如AppScan、OWASP ZAP和Nessus等可以对应用程序进行自动化扫描&#xff0c;发现可能存在的漏洞&#xff0c;如跨站点脚本&am…

7.2、指针变量的定义和使用

代码 #include <iostream> using namespace std; #include <string>int main() {//定义指针int a 10;//指针定义语法&#xff1a;数据类型 * 指针变量名int * p;//让指针记录变量a的地址p &a;cout << "a的地址为&#xff1a;" << &am…

MySQL之应用层优化(二)

应用层优化 Web服务器问题 寻找最优并发度 每个Web服务器都有一个最佳并发度——就是说&#xff0c;让进程处理请求尽可能快&#xff0c;并且不超过系统负载的最优的并发连接数。这就是前面说的最大系统容量。进行一个简单的测量和建模&#xff0c;或者只是反复试验&#xf…

2024年湖南省各市科小申报时间(科技型中小企业申报流程、条件、好处)新政

湖南省各市科小申报时间流程 一、评价管理 省科技厅牵头负责科技型中小企业评价工作的组织和监督、实地核查、公示公告、入库登记及编号撤销和集中抽查工作&#xff0c;及时处理相关异议、投诉和举报信息。 各市州科技局负责科技型中小企业评价工作的具体实施&#xff0c;组…

nginx SSI(Server Side Include)服务端包含 合并拼装静态内容

一、什么是SSI 在被传送给浏览器之前&#xff0c;服务器会对 HTML 文档进行完全地读取、分析以及修改&#xff0c;使用SSI指令将文本、图片或代码信息包含到网页中。对于整个页面可以拆分成多个模块&#xff0c;通过SSI指令将几个模块拼接成一个完整的页面&#xff0c;当有内容…

【数据库原理】课程笔记

数据库原理 一、数据库系统基础 数据模型的类型 概念数据模型&#xff1a; 概念数据模型也称概念模型或信息模型,是对现实世界中问题域内事务(特性)的描述,是以用户观点实现世界的模型(图形表示)。主要用于描述事物的概念化结构,使数据库的设计人员在设计初期,避开计算机系统及…

ATA-L2水声功率放大器驱动水声换能器的测试研究

随着水声通信技术的发展&#xff0c;水下通信设备也开始逐步走向实用化&#xff0c;为了满足其实际的使用要求&#xff0c;功率放大器的设计需要具有高效率的特性&#xff0c;并能在水下长时间连续可靠的工作。 压电陶瓷换能器主要负责电信号与声信号之间的转换&#xff0c;换能…

mybatis配置返回boolean类型

先大概说明一下ResultMap和ResultType的使用场景 ResultMap适用于复杂的查询&#xff0c;可以处理多表关联查询、嵌套查询等情况。通过ResultMap&#xff0c;可以更精确地控制查询结果的映射。ResultType适用于简单的查询&#xff0c;而ResultMap适用于复杂的查询。具体使用哪…

学习整理在php中使用PHPExcel读取excel表列数大于Z时读取不到的解决方案

php读取excel列数大于Z时读取不到 背景解决方案关键代码 背景 表格数据超过26列&#xff0c; 也就是在Z列之前没有AA列及以后的情况&#xff0c; 测试一直都没有问题&#xff0c;超过&#xff0c;就会获取不到数据了 解决方案 private function getExcelData(){//获取excel文…

使用Python进行文件属性修改

哈喽,大家好,我是木头左! 在计算机中,文件属性是指与文件相关的元数据,如创建时间、修改时间、访问时间等。这些属性对于管理和组织文件非常重要。Python提供了一些内置的函数和方法,可以方便地修改文件的属性。本文将介绍如何使用Python进行文件属性的修改。 1. 获取文件…

应用密码学—(扩展)欧几里得、DES、RSA、SHA-1算法

1. 欧几里得算法 1.1 分析算法的实现原理 欧几里德&#xff08;Euclid&#xff09;算法&#xff0c;也既常说的“辗转相除法”&#xff0c;公式为gcd(m, n) { return gcd(n, m%n); }&#xff0c;对于任意两个正整数m、n&#xff0c;每次求的一个数字r m % n&#xff0c;然后把…

教育场景中的自动化分拣系统!基于大象机器人UltraArm P340机械臂和传送带的实现

引言 今天我们将展示一个高度自动化的模拟场景&#xff0c;展示多个机械臂与传送带协同工作的高效分拣系统。在这个场景中&#xff0c;机械臂通过视觉识别技术对物体进行分类&#xff0c;并通过精确的机械操作将它们放置在指定的位置。这一系统不仅提高了分拣的速度和准确性&am…

PTrade怎么获取KDJ随机指标?想做量化策略怎么申请PTrade量化软件?

get_KDJ - 随机指标 get_KDJ(high, low, close, n9, m13, m23) 使用场景 该函数仅在回测、交易模块可用 接口说明 获取随机指标KDJ指标的计算结果 PTrade是恒生公司开发的一款专业量化软件&#xff0c;部分合作券商可提供&#xff0c;↑↑↑&#xff01; 参数 high&…