草庐IT

AsyncRestTemplate

全部标签

java - 如何使用 AsyncRestTemplate 拦截 AsyncClientHttpRequest?

我正在使用springAsyncRestTemplate帮助程序类开发一个异步REST客户端。客户端需要在每个请求的头部发送一个token。当使用HttpAsyncClient(属于http://hc.apache.org/httpcomponents-asyncclient-4.0.x/index.html)作为其余模板的底层http客户端时,可以添加拦截器:HttpRequestInterceptorinterceptor=(request,context)->request.addHeader("token","value");CloseableHttpAsyncClientcl

java - 如何使用 AsyncRestTemplate 同时调用多个电话?

我不明白如何有效地使用AsyncRestTemplate进行外部服务调用。下面的代码:classFoo{publicvoiddoStuff(){Future>future1=asyncRestTemplate.getForEntity(url1,String.class);Stringresponse1=future1.get();Future>future2=asyncRestTemplate.getForEntity(url2,String.class);Stringresponse2=future2.get();Future>future3=asyncRestTemplate.g

java - 如何使用 AsyncRestTemplate 同时调用多个电话?

我不明白如何有效地使用AsyncRestTemplate进行外部服务调用。下面的代码:classFoo{publicvoiddoStuff(){Future>future1=asyncRestTemplate.getForEntity(url1,String.class);Stringresponse1=future1.get();Future>future2=asyncRestTemplate.getForEntity(url2,String.class);Stringresponse2=future2.get();Future>future3=asyncRestTemplate.g

java - 带有 AsyncRestTemplate Netty 客户端的 Spring Boot 失败

我有一个SpringBoot1.3.6应用程序,开箱即用并使用嵌入式Tomcat服务器。该应用程序有一个端点执行一个非常简单的回显请求。后来我使用AsyncRestTemplate定义了一个调用该简单端点的相应客户端,但是如果我的客户端使用Netty4ClientHttpRequestFactory请求失败,否则它成功。我下面的示例是在Kotlin中,但在Java中同样失败,因此它与我用来实现它的语言无关。服务器@SpringBootApplicationopenclassEchoApplication{companionobject{@JvmStaticfunmain(args:Ar

java - 带有 AsyncRestTemplate Netty 客户端的 Spring Boot 失败

我有一个SpringBoot1.3.6应用程序,开箱即用并使用嵌入式Tomcat服务器。该应用程序有一个端点执行一个非常简单的回显请求。后来我使用AsyncRestTemplate定义了一个调用该简单端点的相应客户端,但是如果我的客户端使用Netty4ClientHttpRequestFactory请求失败,否则它成功。我下面的示例是在Kotlin中,但在Java中同样失败,因此它与我用来实现它的语言无关。服务器@SpringBootApplicationopenclassEchoApplication{companionobject{@JvmStaticfunmain(args:Ar

java - 如果花费太多时间,如何取消 AsyncRestTemplate HTTP 请求?

从一开始,我一直对如何处理InterruptedException以及如果花费太多时间如何正确取消http请求感到困惑。我有一个库,其中我为我们的客户提供了两种方法,同步和异步。他们可以调用他们认为适合他们目的的任何方法。executeSync()-等待我得到结果,然后返回结果。executeAsync()-立即返回一个Future,如果需要,可以在其他事情完成后进行处理。他们将通过DataKey包含用户ID和超时值的对象。我们将根据用户ID确定要调用哪台机器,然后使用该机器创建一个URL,我们将使用AsyncRestTemplate对URL进行http调用然后根据是否成功将响应发送回