使用Spring WebClient重试时添加新标头

文章/答案/技术大牛

发布

1回答

spring、spring-boot、request-headers、spring-retry、spring-webclient

正如注释所说，在重试post请求之前，我需要将新的令牌添加到头中。如果存在statusCode为UNAUTHORIZED，并且如果statusCode为2xx，则返回bodyToMono。

浏览 19提问于2020-03-03得票数 2

1回答

春季-卡夫卡RetryableTopic引发RecordTooLargeException

spring-kafka

我使用spring进行非阻塞重试，其中包含固定的BackOff和一个重试主题()。我注意到，当重试尝试相对较高时，我会得到RecordTooLargeException，在检查消息时，我发现它包含了以前所有尝试的卡夫卡标头，而且像kafka_exception-stacktrace这样的标头相当重为什么它试图发布带有前一次重试的头的重试消息？我找

浏览 4提问于2021-11-03得票数 0

回答已采纳

1回答

Spring WebClient -基于响应头的延迟重试方法

java、spring-webflux、project-reactor、spring-webclient、retrywhen

一点背景当外部服务以503 - Service Unavailable状态进行响应时，响应包括一个值的Retry-After头，该值指示重试请求之前应该等待多长时间。我想在Spring /反应堆中找到一种方法，告诉webClient在X周期之后重试<

浏览 6提问于2021-01-15得票数 8

回答已采纳

2回答

春季集成-失败时的装饰信息

java、spring、jms、activemq、spring-integration

由于在这些WS调用中没有事务，所以我希望跟踪我的流程已经完成了多远，以便在重试消息处理时跳过已经执行的步骤。示例步骤：因此，对于这个问题:在消息处理失败时，是否可以用附加的标</em

浏览 3提问于2015-09-21得票数 1

回答已采纳

1回答

带有新头的Spring* WebClient重试逻辑*

java、spring、spring-boot、spring-webflux、spring-webclient

我正在尝试使用SpringWebClient构建重试逻辑。我要解决的问题很简单。我正在调用一个API端点来获取一些值。如果API返回一个带有401响应的错误，那么我将不得不调用令牌服务并更新我的令牌，并使用新的令牌并进行相同的API调用。/locations data POST /token and get renew Token --> This is another WebClient/location

浏览 1提问于2021-08-01得票数 1

回答已采纳

1回答

使用Vert.x WebClient支持内容编码和内容解码

java、vert.x、quarkus、mutiny

VertxHttpClient(Vertx vertx) {} 当我向请求添加accept-encoding标头时。kernelHttpRequest.setHeader("Accept-Encoding", "gzip"); Vert.x-WebClient/3.9.5忽略了这个标头

浏览 48提问于2021-07-01得票数 0

1回答

添加查询跟踪id以请求标头

spring-boot、spring-cloud-sleuth

我有一个spring引导应用程序，它依赖sleuth 3.0.3和spring Spluth-Zipkin-3.0.3。我有一个要求，我需要传递跟踪id来请求头部，同时从webclient调用API。演示webClient@Componentpublic class DemoApiClient { private final DemoProper

浏览 11提问于2021-12-17得票数 0

1回答

Spring @DltHandler注释方法在非阻塞重试实现中没有正确接收标头。

spring、kotlin、error-handling、spring-kafka、dlt

我试着用Spring实现一个非阻塞的重试。根据文档，我们可以设置一个处理程序方法来处理来自DLT主题的消息，在@KafkaListnener中完成了穷尽的尝试之后。我的意图是捕获DLT处理程序方法上的一些标头，如下代码所示： fun processaDlt( @Payload mensagem: String,在Spring代码中，我看到一些标头以字符串"kafka_“作为前缀，并且在消息上看到了这些值，这些值在

浏览 7提问于2021-09-17得票数 0

1回答

如何在WebClient上记录“真正的”Http头？

spring、netty、spring-webflux、project-reactor、reactor-netty

我目前正在使用ExchangeFilterFunction来记录ClientRequest实例内部的所有标头，并且我正在通过request.headers()访问它们。在执行我的过滤器之后，下面的HttpClient添加了某些头，比如Accept-Encoding头，因此不会被记录下来，因为它们永远不会添加到ClientRequest实例中。

浏览 7提问于2019-11-08得票数 1

2回答

Spring WebClient集在报头中表示令牌

java、oauth、keycloak、webclient、spring-webclient

我考虑在webclient构建器过程中将该功能添加为筛选函数，如下所示WebClient webClient() {编辑:我能够手动设置标题，同时构建一个新的WebClient。return WebClient.builder() .defaultHeader(&q

浏览 0提问于2020-12-11得票数 12

1回答

如何在Spring* 6和Spring 3中重新尝试新的HTTP接口*

java、spring、spring-boot、spring-webclient

Spring引入了新的HTTP接口。对于异常处理，状态将注册一个应用于通过客户端执行的所有响应的响应状态处理程序： .defaultStatusHandler(HttpStatusCode::isError, resp -> ...)然而，还不清楚如何处理重试。在WebClient中，可以简单地使用retryWhen()： p

浏览 19提问于2022-11-30得票数 0

回答已采纳

2回答

使用带有西里尔字符的URL的c# WebClient问题

c#、webclient

但是，即使我对参数进行URL编码，我也不能在c#中使用它。=ЗДРАВСТВУЙТЕ使用URL编码版本 Server.UrlEncode("ЗДРАВСТВУЙТЕ"));所以..。我做错了什么。有什么

浏览 2提问于2011-02-15得票数 0

回答已采纳

3回答

如何在Spring* WebClient中一次设置多个headers？*

spring-boot、java-8、resttemplate、rest-client、spring-webclient

我试着给我的rest客户端设置头文件，但每次我都要写 .header("key1", "value1")如何使用headers()方法同时设置所有头部？

浏览 17提问于2019-12-02得票数 11

回答已采纳

2回答

如何在服务器端而不是浏览器端读取SSE事件流

server-sent-events、event-stream

我正在创建一个应用程序来读取事件流并将信息保存在我的数据库中。现在我想用java (不是javascript代码)从上面的API中获取流，任何人都有这个想法。

浏览 8提问于2018-10-21得票数 1

1回答

重试下一个Flux元素，忽略成功的那个

spring、reactive-programming、spring-webflux、project-reactor

我正在尝试使用反应性编程，以便能够从其他服务下载文件。诀窍是，在连接失败或Flux元素失败的情况下，我想在Flux上重试几次，但是一旦能够掌握它，我希望从一开始就不处理这些元素。一旦我成功地重试，我想继续使用57元素，这样我就不必从一开始就处理它并执行GET。但我想要实现的是，在重试时，我只需要得到红色元素(因为我已经有黄色和紫色)。

浏览 1提问于2019-10-10得票数 1

回答已采纳

1回答

来自WebClient的Spring* ReactiveSecurityContext头*

spring、spring-boot、spring-security、spring-webflux、spring-webclient

我试图相应地将WebClient头值设置为经过身份验证的用户，如下所示：} 是否应该将所需的标头值存储在其他地方因为以反应性的方式，一切都返回Mo

浏览 2提问于2021-03-12得票数 0

回答已采纳

3回答

密码破解

java、c++、c

我有两个文件，一个用户名列表和一个密码列表。我需要编写一个程序来检查每个用户名和密码列表。然后我需要去一个网站，看看它是否登录了。我不太确定如何进行比较，以及如何模拟程序登录网站输入信息。你能帮我解决这个问题吗？这是一个家庭作业的问题。

浏览 7提问于2011-03-04得票数 2

2回答

使用WebClient将Spring应用程序中接收的请求标头传播到下游服务

spring、spring-webflux、opentracing、spring-webclient

我有两种网络流量应用程序，基于注释的和基于路由的.这些应用程序是使用一组标头调用的，其中一些(开放跟踪)需要使用WebClient在下游调用中传播。如果这些是普通的Spring WebMvc应用程序，我将使用过滤器将选定的标头保留在ThreadLocal中，在RestTemplate拦截器中访问它，将它们发送到后续服务并清除ThreadLocal。

浏览 3提问于2019-04-10得票数 7

回答已采纳

1回答

在使用XElement.Load时维护会话状态

c#、asp.net、session

我的RSS应用程序使用一个内部ASP.NET提要，该提要使用当前登录用户的身份来自定义其内容。RSS提要是由我的应用程序中的标准.ashx处理程序生成的。当我使用XElement.Load(rssFeedUri)调用RSS feed时，不会维护会话状态(可能是因为会话ID cookie没有随请求一起发送)。直接从已登录用户的浏览器地址栏调用RSS提要时，RSS提要可以正常工作。我已经确保我的处理程序实现了IRequiresSessionState，这样如果将会话ID传递给服务，我就可以访问会话数据。<em

浏览 0提问于2011-05-31得票数 1

回答已采纳

1回答

Spring Kafka RetryableTopic多次尝试

spring-kafka

我正在使用spring-kafka RetryableTopic进行带有固定BackOff和a single retry topic的非阻塞重试。我注意到，如果我使用超过127次尝试，重试永远不会停止，而且如果我使用这个标头： @Header(name = RetryTopicHeaders.DEFAULT_HEADER_ATTEMPTS, required我在spring-kafka文档中找不到max_retries的任何限制，但在

浏览 174提问于2021-11-05得票数 1

点击加载更多