spring-boot - 如何在 Spring Boot WebFlux 上使用 AWS X-Ray 跟踪传入请求?
问题描述
我在 AWS ECS 上运行了多个微服务,我想试用 AWS X-Ray。按照这个开发者指南,我添加了一个WebConfig.java
带有跟踪过滤器的文件。
添加行到build.gradle
:
implementation "javax.servlet:javax.servlet-api:4.0.1"
implementation "com.amazonaws:aws-xray-recorder-sdk-core:2.8.0"
新文件WebConfig.java
:
import com.amazonaws.xray.javax.servlet.AWSXRayServletFilter;
import javax.servlet.Filter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class WebConfig {
@Bean
public Filter tracingFilter() {
return new AWSXRayServletFilter("ordermicroservice");
}
}
但是,我认为这是不正确的,主要是因为我必须为javax.servlet.Filter
. 我认为这是因为我使用的是 spring-boot-webflux 而不是 spring-boot-web。所以我有一个 Netty 网络服务器而不是 Tomcat 网络服务器。
我的问题是:
- 如何将日志记录添加到 servlet 过滤器,以确保每个传入的 HTTP 请求都正确通过过滤器?
- 在使用 Netty 而不是 Tomcat 的 spring-boot-webflux 项目中编写 Web 过滤器的正确方法是什么?
编辑:现在我想出了如何使用 Spring Boot WebFlux 编写过滤器。我将其添加到此处的问题中以供将来参考:
import org.springframework.stereotype.Component
import org.springframework.web.server.ServerWebExchange
import org.springframework.web.server.WebFilter
import org.springframework.web.server.WebFilterChain
import reactor.core.publisher.Mono
@Component
class MyCustomWebFilter : WebFilter {
override fun filter(webExchange: ServerWebExchange, chain: WebFilterChain): Mono<Void> {
print("Successfully reached the WebFilter.\n")
val request = webExchange.request
val response = webExchange.response
// TODO: Do the actual filtering by looking at the request and modifying the response
return chain.filter(webExchange)
}
}
解决方案
正如 Michael 所提到的,您可能需要实现 WebFilter 接口。由于 AWSXRayServletFilter 是一个 servlet 过滤器,因此它不适用于 WebFilter。不幸的是,X-Ray SDK for WebFlux 中还没有内置支持。你需要做的是在你的 WebFilter 链中,实现你自己的拦截器,通过创建一个段并向它添加相关数据来跟踪传入的请求。您可以在此处参考 AWSXRayServletFilter 如何跟踪传入请求:https ://github.com/aws/aws-xray-sdk-java/blob/master/aws-xray-recorder-sdk-core/src/main/java/com /amazonaws/xray/javax/servlet/AWSXRayServletFilter.java
或者,您可以使用 OpenTelemetry Java SDK 来检测您的应用程序并使用 AWS Collector 将跟踪数据发送到 X-Ray。OTel SDK 支持 WebFlux 框架。您可以在下面找到更多信息。
OTel Java SDK 检测:https ://github.com/open-telemetry/opentelemetry-java-instrumentation
AWS OTel 收集器:https ://aws-otel.github.io/docs/getting-started/collector
推荐阅读
- grails - assertequals 如何对域对象起作用?
- javascript - 此节点js代码的php中的等效加密代码如何?
- android - Android RecyclerView如何更改第一项它的文本颜色
- plot - 如何在mathematica中绘制具有不同范围的图形
- ssh - 当 IP 更改时保持 SSH 会话处于活动状态
- html - 使列高填充行引导程序4
- aws-lambda - Netlify Lambda 构建出现语法错误
- javascript - 使用 get-image-colors 包获取颜色量
- python - 将不同的dict列表与ansible结合起来
- php - 登录系统一直提示我无法登录