Vert.x httpClient/webClient按块或按流处理响应
Vert.x是一个用于构建高性能、可伸缩和异步应用程序的工具包。它是一个基于事件驱动的、非阻塞的应用程序框架，适用于构建现代化的云原生应用程序。
在Vert.x中，httpClient和webClient都是用于进行网络通信的客户端工具。它们可以用于发送HTTP请求并处理响应。
httpClient和webClient都支持按块或按流处理响应。这意味着可以在接收到响应的同时逐渐处理响应数据，而不是等待整个响应完全接收之后再处理。
按块处理响应的方式可以通过设置回调函数来实现。当每个块的数据可用时，回调函数将被调用并传递给应用程序。这样可以让应用程序在接收到响应数据的同时进行处理，提高了系统的响应速度和吞吐量。
按流处理响应的方式则更加灵活，可以使用流式API来处理响应数据。应用程序可以通过创建流处理器（stream handler）并注册相应的事件来对接收到的响应数据进行处理。这样可以将响应数据分成多个块进行处理，从而实现更细粒度的控制和处理。
对于Vert.x中的httpClient和webClient，推荐的腾讯云相关产品是Tencent Cloud API网关。Tencent Cloud API网关是一种支持按块或按流处理响应的全托管API网关服务，提供了稳定、高可用的API访问接口和灵活的流处理能力。详情请参考Tencent Cloud API网关。
总结：Vert.x的httpClient和webClient是用于进行网络通信的客户端工具，支持按块或按流处理响应。按块处理响应可以通过设置回调函数实现，而按流处理响应可以通过创建流处理器并注册相应的事件来实现。腾讯云相关产品推荐使用Tencent Cloud API网关。
相关·内容
我有vert.x和asyncHttpClient的应用程序。我想用vert.x httpClient (webClient)替换asyncHttpClient，但我需要能够按块或按小部分数据(如AsyncHttpClient中的org.asynchttpclient.AsyncHandler )或像流一样处理响应。有可能吗？我查看了自定义BodyCodec，但我不能理解自定义WriteStream中的数据流。
浏览 31提问于2021-11-02得票数 0
回答已采纳
我在AWS上配置了一个HTTPS网站，它允许从IP的白列表中访问。我的本地机器使用VPN连接运行，该连接位于白名单中。我可以通过网页浏览器或java.net.http包访问该网站，代码如下：
HttpClient client = HttpClient.newHttpClient();
HttpRequest request = HttpRequest.newBuilder()
.uri(URI.create("https://mywebsite/route"))
.GET() // GET is default
.build();
HttpRespon
浏览 1提问于2022-06-20得票数 0
我正在我的Spring应用程序中尝试使用webClient。使用block()方法，我得到了以下错误：
org.springframework.messaging.MessageHandlingException: error occurred during processing message in 'MethodInvokingMessageProcessor' [org.springframework.integration.handler.MethodInvokingMessageProcessor@28b67bb]; nested exception is java.
浏览 6提问于2021-07-19得票数 0
回答已采纳
我想对Restful进行基准测试，所以我向它发送了大量的请求，以度量吞吐量和延迟。我使用Vert.x WebClient创建一个客户机。
首先，我从AbstractVerticle创建AbstractVerticle扩展并在start方法中创建WebClient。
public class BenchmarkVerticle extends AbstractVerticle {
@Override
public void start(Future<Void> future) {
WebClient client = WebClient.create(
浏览 0提问于2018-04-18得票数 1
回答已采纳
2回答
我正在使用 XML消费一些数据。此API始终以UTF-8格式提供数据。
当使用WebClient类发出请求时，我能够设置编码。例如：
var result = new WebClient();
result.Encoding = Encoding.UTF8;
但是HttpClient类又如何呢？
HttpClient client = new HttpClient();
我应该使用：
client.GetByteArrayAsync(url);
然后...and将字节从编码(UTF-8)转换为字符串？
或者有没有一种方法可以直接获取UTF-8字符串形式的内容？
using (var clie
浏览 0提问于2012-06-13得票数 9
回答已采纳
我在一个应用程序中有多个httpClient实例。我想按每个具有特定标签或名称的httpClient收集指标。是否可以使用vert.x？我在收集httpClient指标的文档块中看到，我想用客户的规范来丰富每个指标。
浏览 9提问于2021-11-08得票数 0
我正在听下面的Eventbus，并使用vert.x调用HttpClient.postAbs()
public void start(Future<Void> fut) {
EventBus eb1 = MainAdminVx.serviceBack.getEventBus();
eb1.consumer("local-message-receiver", message -> {
HttpClient client = vertx.createHttpClient();
client.postAbs(&
浏览 6提问于2016-12-13得票数 0
回答已采纳
有人知道WebClient.DownloadFileAsync是如何实现的吗？我对此有几个问题：
是将流保存在内存中直到整个文件下载，还是直接缓冲到临时文件(然后复制到正确的路径)？或者直接进入所指示的文件？编写一个简单的WCF服务来响应这些调用将需要以下内容：
设置响应头-内容-类型:应用程序/八位流内容-长度:3内容-配置:附件；filename=SomeFileName.jpeg
并返回一个byte[]
我有遗漏什么吗？
浏览 1提问于2011-12-25得票数 0
回答已采纳
1回答
您好，我正在使用spring webflux中的webClient。我有一些代码，比如： @Configuration
class WebClientConfig(
@Value("\${url}")
private val url: String
) {
@Bean
@Primary
fun webClient(): WebClient {
return createWebClient(700)
}
@Bean("more_timeout")
fun webClientMor
浏览 31提问于2019-01-11得票数 0
我曾尝试过几个类实现来检索分块的数据，但都没有成功。下面是一个有问题的简化代码模块。在网上冲浪之后，似乎在过去(2009,2010；版本1.1，1.5)中出现了问题，但现在应该已经解决了。我还没有看到Android平台在这个协议上取得了任何明确的成功。
帮助!
如果我放了一个无效的令牌，我可以看到一些响应-- web服务将以应用程序错误消息响应。但是，有效的url和令牌只会响应检测到分块的协议(isChunked()返回true)，但不会读取任何内容，也不会超时，等等。
从命令行使用CURL发出的完全相同的URL按照预期工作，并显示连续的内容(从web服务发布的数据)。
是否有任何web服务端
浏览 3提问于2011-02-20得票数 9
回答已采纳
我正在将大量数据从json(带有图像)加载到我的列表视图中，这会导致我的应用程序在滚动时不会响应，但如果我按下等待，我的仿真器。我可以滚动它，但它使我的应用程序非常滞后。然而。我的应用程序中有一个详细的活动，它也来自于我的json。在我的列表视图中单击1项并继续我的详细活动之后，away.any会为此而工作吗？我把我的json文件的链接放在下面。我想我的滚动视图很难加载我的图像。在我做研究的时候，它说我应该在将图像转换成字节的同时记忆缓存。但是怎么做呢？
以下是我如何将图像转换成字节的方法。
public class ImageHelper
{
public static Bitmap
浏览 4提问于2017-03-08得票数 0
回答已采纳
在多反应堆框架(如Vert.X )中，我们可以设置事件循环线程的数目，例如：
final VertxOptions vertxOptions = new VertxOptions();
vertxOptions.setEventLoopPoolSize(16);
final Vertx myVertx = Vertx.vertx(vertxOptions);
如何在Spring 2 WebFlux / WebClient中实现等效？
浏览 0提问于2018-02-04得票数 16
回答已采纳
我们使用org.springframework.web.reactive.function.client.WebClient和reactor.netty.http.client.HttpClient作为Spring5.1.9的一部分来使用exchange()方法发出请求。此方法的突出显示以下内容：
..。在使用exchange()时，应用程序有责任使用任何响应内容，而不管场景如何(成功、错误、意外数据等等)。不这样做会导致内存泄漏。
我们对exchange()的使用是相当基本的，但是错误场景的文档对我来说并不清楚，我想确定的是，我们为所有结果正确地释放了资源。本质上，我们有一个阻塞实现
浏览 15提问于2020-02-19得票数 6
我正在使用Spring从我的服务器接收服务器发送的事件(由SSEEmitter发布)。但是，由于某种原因，我的服务器定期在新行中发布一个字符串"0“。当发生这种情况时，WebClient将关闭连接。
我深入研究并打开了Spring调试，并发现了以下信息：
+--------------------...+
| 0 1 2 3 4 5 ... |
| 30 0d 0a 0d 0a ...-|0.... |
[reactor.ipc.netty.http.client.HttpClientOperations:218
浏览 4提问于2018-07-19得票数 1
回答已采纳
我正在使用vert.x和RxJava开发Apigateway。我希望为两个Api发送响应请求，从它们获得响应，并通过HttpServer发送组合JSON。但是onComplete()执行到早期，并返回空的JSON。我认为问题来自于asynchronous字符的vert.x，但我不知道到底出了什么问题。
这里是我的方法：
private void dispatchBoth(RoutingContext routingContext) {
Observer<String> observer = new Observer<String>() {
J
浏览 1提问于2020-02-19得票数 0
回答已采纳
我有以下代码：
byte[] fileBytes = null;
using (var wc = new System.Net.WebClient())
{
fileBytes = wc.DownloadData(filename);
}
filename是一个url，其中包含类似于"file://example.com/Media-Data/thisisabigmovie.wmv“的内容
现在，我的客户似乎有非常大的文件抛出以下错误：
System.OutOfMemoryException:
at System.Net.ScatterGatherBuffers.Allo
浏览 48提问于2018-03-05得票数 1
回答已采纳
我有一个奇怪的问题使用省道HttpClient，似乎它没有阅读完整的反应之前，“完成”。这是我的代码：
HttpClient client = new HttpClient();
client.connectionTimeout = Duration(seconds: 60);
Completer<MealPlan> completer = new Completer();
RecipeSearchFilter filter = new RecipeSearchFilter();
filter.restrictions = intolerances.map((intoleranc
浏览 4提问于2019-10-28得票数 0
回答已采纳
当我的Vert.x服务器收到一些无效请求时，它的任务是不发回任何resposne，而只是增加相关的度量。我如何测试它？ 下面的代码不起作用，因为我们永远得不到响应，处理程序的代码也永远不会执行--我只是把它张贴出来，向您展示我想在测试中得到什么。 @Test
void invalidUrlTest(Vertx vertx, VertxTestContext testContext) {
HttpRequest<String> request = WebClient
.create(vertx, this.webClientOptions)
浏览 25提问于2019-04-09得票数 1
回答已采纳
2回答
我不太明白vert.x是如何应用于get服务器的。
我所知道的webserver的概念是基于线程的。
启动您的then服务器，然后运行该服务器。
然后，对于每个连接的客户端，您将得到一个套接字，然后将该套接字传递给自己的线程处理程序。
然后，线程处理程序处理这个特定套接字的任务。
因此，明确定义了哪个线程正在为哪个套接字执行工作。但是，对于每个套接字，您都需要一个新线程，从长远来看，对于许多套接字来说，这是很昂贵的。
然后是vert.x提供的基于事件的概念。据我所知，无论如何，它都应该是这样的：
Vertx实例部署Verticles。
Verticles在后台线程中
浏览 1提问于2019-05-29得票数 1
回答已采纳
2回答
我需要在本地测试一些使用WebClient对象与http服务器通信的代码。为此，我决定编写一个极其简单的模拟服务器，它从二进制文件中读取一些字节并将它们发送到客户端。以下是相关服务器的代码：
public void Listen()
{
TcpClient client;
NetworkStream netStream;
listener.Start();
try
{
client = listener.AcceptTcpClient();
netStream = client.GetStream();
浏览 0提问于2012-08-10得票数 1
回答已采纳
我有一个spring webFlux服务器，我没有为它激活SSL，它使用HTTP1.1进行请求连接。另一方面，在另一个应用程序中编写了一个spring WebClient，该应用程序可以很好地调用此服务器并接收流数据作为应答。但问题是，我已经看到，http/1.1协议不是为流设计的，它用于简单的请求和响应连接，并且可以用于流HTTP/2。我想知道是如何通过http/1.1协议接收流数据的？在其他编程语言中，还有其他webFlux客户端在http上工作吗？( RSocket除外，它可以在TCP、WebSocket和UDP上工作)。
浏览 4提问于2020-12-11得票数 1
回答已采纳
我已经在Java应用程序中编写了一个webclient实例。我已经创建了一个ssl上下文，用于我试图访问的服务器，以及基本身份验证。我正在提出一个REST帖子请求。起初，我怀疑我是否正确地创建了ssl上下文，或者是否错误地添加了基本身份验证。然而，在我看来，我的post请求根本没有到达端点，因为我既不能打印响应正文，也不能打印响应头或状态代码。这让我认为有一些本质上与我的代码无关的东西，也许是某种配置，它阻止了我的应用程序正确地发出请求并命中端点。下面是我当前的代码。 @Configuration
@SpringBootApplication
public class myApplicati
浏览 27提问于2020-11-19得票数 0
我被困在这件事上，可能需要一些帮助。在过去的几个小时里，我做过网络搜索，阅读过文档，但没有运气。
我收到一个错误，从"JObject o=JObject.Parse(响应)；“行的"response”重载条目中读取如下内容。
Argument1:无法从“System.IO.Stream”转换为“string”
static void MyFunction(out string Value1, out string Value2)
{
HttpClient client = new HttpClient();
var response = client.G
浏览 1提问于2016-09-20得票数 0
我有类似Vert.x这样的异步库的经验，但特别是对反应堆/WebFlux来说是新手。我想在web应用程序上公开一个端点，当被击中时，这个端点掉头并调用另一个web服务，将响应解析为一个Java对象，然后访问对象中的字段并对它们做一些事情。我使用WebClient进行HTTP调用，使用Jackson ObjectMapper反序列化它。我的代码看起来大致如下(注意：RequestUtil.safeDeserialize只是使用杰克逊将字符串体解析成一个对象并返回Optional<Object>，这就是为什么之后我有一个额外的map步骤)：
public Mono<Str
浏览 4提问于2021-02-12得票数 2
回答已采纳
在处理下面代码返回的非常长的JSON响应时，我将得到一个OutOfMemoryException：
HttpClient httpclient = new DefaultHttpClient();
HttpGet httpGETRequest = new HttpGet(url);
HttpResponse response = httpclient.execute(httpGETRequest);
return EntityUtils.toString(response.getEntity());
即使在调用http请求之前使用了System.gc()，但异常仍会发生。
我试图通过将响应
浏览 7提问于2015-05-13得票数 0
回答已采纳
我想解析网页，iam使用htmlunit，当iam运行代码时，iam会出现以下错误。
import java.net.URL;
import java.util.List;
import com.gargoylesoftware.htmlunit.WebClient;
import com.gargoylesoftware.htmlunit.html.HtmlImage;
import com.gargoylesoftware.htmlunit.html.HtmlPage;
public class scrapImage {
public static void main(S
浏览 4提问于2012-04-11得票数 1
2回答
我在本地主机上有一个vertx后端服务器:8080响应REST请求。
发送GET请求时，一切正常。
但在使用params的删除请求中，我会得到CORS错误.
我的后端服务器如下所示：
@Override
public void start(Future<Void> fut) {
Router router = Router.router(vertx);
router.route("/").handler(routingContext -> {
HttpServerResponse response = routingContex
浏览 3提问于2018-09-19得票数 0
回答已采纳
1回答
我有三个WebClients看起来像这样：
WebClient
public Mono<MyObject> getResponseOne() {
return webClient.get()
.uri(URI)
.header("header", header)
.bodyValue(body)
.retrieve()
.bodyToMono(MyObject.class);
}
然后我有一个控制器，它调用多个WebClients：
控制器
@ResponseBody
@Po
浏览 2提问于2022-03-15得票数 0
回答已采纳
当使用@Service的@Autowired WebClient类检索不同的响应JSON时，我想测试程序行为。为此，在测试中，我希望能够将从api url检索的响应体JSON替换为从文件中读取的JSON。
具体来说，我想使用和@Size注释(当JSON无效时)测试DTO中的验证，以及使用.getModel()方法检索从JSON映射的不同(有效)模型时使用@Autowired ModelService的类的行为。
我的服务看起来是这样的：
@Service
public class ModelServiceImpl implements ModelService {
@Autowired
浏览 10提问于2022-07-05得票数 0
回答已采纳
我有一个.NET Core3MVC应用程序，它需要通过HTTP从一个位置读取一个文件，然后将它重新发送回响应。其中一些文件的大小约为200 be。
我所拥有的可以工作，但在将File结果发送给客户端之前，它会将整个文件读入内存。是否有一种方法使其本质上是一个通道，其中读取流流入响应流，以便服务器上所需的内存非常少？
这是我现在拥有的，但我不认为在处理大型文件时表现很好：
if (requestedFile != null)
{
using (var client = new System.Net.Http.HttpClient())
{
using (var r
浏览 2提问于2020-05-22得票数 2
回答已采纳
我正在.net Framework3.5中开发一个手机应用程序，它使用一个API服务调用来检查来自网站的电子邮件地址。
using System.Net.Http;
HttpClient webClient = new HttpClient();
webClient.QueryString.Add("email", email);
Stream stream = webClient.OpenRead(brandEndPoint);
最初我使用WebClient而不是HttpClient，我在谷歌得到了这个错误"The type or namespace name &#
浏览 0提问于2014-06-09得票数 7
回答已采纳
我正在编写一个程序，可以从互联网上下载一张照片，并将其保存到一个名为"temp.jpg“的文件中。例如，我的程序用户BackgroundWorker和我有一个问题，当我第二次运行BackgroundWorker时，我的程序试图打开"temp.jpg“，但它仍然被第一个BackgroundWorker使用。
有什么建议可以解决这个问题吗？
一种解决方案可以是通过时间戳或类似的东西来命名文件。
将照片下载到我正在使用的temp.jpg
WebClient webClient = new WebClient();
try
{
webClient.DownloadFile(fo
浏览 0提问于2012-12-06得票数 0
回答已采纳
我正在使用Java中的HTMLUnit连接到远程URL，并从获得的网页中获取一些信息。
我使用以下代码：
final WebClient webClient = new WebClient(BrowserVersion.INTERNET_EXPLORER_6_0, "companyproxy.server", 8080);
final DefaultCredentialsProvider scp = new DefaultCredentialsProvider();
scp.addProxyCredentials("username", "passwor
浏览 1提问于2009-06-04得票数 1
1回答
请回答有关、WebClient和窃听日志的快速问题。
目前，我正在使用SpringBoot与WebClient 2.5.0一起发出出站http请求(在我是源的地方)，我需要(向目标)发出一个http请求。
我使出站http客户机如下所示：
webClientUtil.getWebClient().mutate().baseUrl(someUrl).build().post().body(BodyInserters.fromValue(someRequest)).exchangeToMono(clientResponse -> clientResponse.bodyToMono(SomeR
浏览 2提问于2021-05-24得票数 7
1回答
我正面临着vert.x的一个问题。当超时被触发时，它会生成一个响应，然后实际的响应(耗时10秒)出现并尝试执行响应，因此我得到了一个：
java.lang.IllegalStateException:响应已经写好了
我是Vert.x的新手，我不确定所需的行为，我应该如何做呢?因为代码是异步的，所以我找不到检查响应是否已经发送的方法。
有什么办法可以轻松地做这件事吗？
我有这样的代码：
private void setExternalCallAccessibleWithCircuitBreaker() {
CircuitBreaker breaker = CircuitBr
浏览 2提问于2020-01-27得票数 0
回答已采纳
2回答
在C#中快速下载HTML源代码
、、、、
我正在尝试从一个网站()下载C#的HTML源代码。
问题是，下载一个30 is的HTML页面源需要10秒。互联网连接不是一个问题，因为我可以下载10兆文件在这个程序中立即。
以下内容已在单独的线程和主线程中执行。下载还需要10-12秒。
1)
using (var httpClient = new HttpClient())
{
using (var request = new HttpRequestMessage(new HttpMethod("GET"), url))
{
var response = awa
浏览 2提问于2020-12-08得票数 0
回答已采纳
我正面临着一个非常奇怪的问题。
我正在编写Vert.x，从处理程序中使用Vert.x的HttpClientRequest调用REST。现在我有了一个CompletableFuture，我正在HttpClientRequest的响应处理程序中完成它。稍后，我将使用CompletableFuture.get()。但是，每当调用get()方法时，主线程就会被阻塞(正如预期的那样)，但是它将永远被阻塞。我没有看到回调发生在我的响应处理程序上，而且它被永远卡住了。
这是代码：
import io.vertx.core.http.HttpClientRequest;
import io.vertx.cor
浏览 2提问于2018-10-05得票数 2
回答已采纳
我希望能够为使用Spring5 WebClient (SpringBootVersion2.0.0.RELEASE)发出的请求设置一个超时值。我的第一次尝试是按照这个答案: WebClient ( )上的建议配置。如果服务器没有及时响应，这将正确地超时。但这也有其他含义:在成功地发出响应(在.retrive()或.exchange()之后)之后，计时器继续进行，因此如果达到超时值，则会引发超时异常。
这似乎是预期的行为，因为配置的时间已经过去，并且网络通道没有读取任何数据(不考虑以前读取的数据)，因此ReadTimeoutHandler超时。换句话说:使用WebClient (配置了Read
浏览 1提问于2018-04-03得票数 1
回答已采纳
3回答
我们正在为我们的一个项目评估反应式编程框架。我刚刚看了一下vert.x教程。我检查了一下RxJava演示文稿。RxJava似乎更接近CompletableFuture。但是，尽管有底层模式，RxJava和Vert.x都提供了非阻塞编程的访问。我搞不懂它们之间的区别是什么。我将感谢在这方面的任何帮助。
浏览 3提问于2017-05-24得票数 20
1回答
我试图使用VB.NET向PHP发布一些数据。PHP脚本，如下所示，只是两行实验。
$arr = array('code' => '110', 'description' => $_POST['updateDate']);
echo json_encode($arr);
在VB中，我尝试使用WebClient、HttpClient和HttpWebRequest发布。只有WebClient按预期工作。另外两个返回“未定义的索引: updateDate”，这意味着POST不正确。下面是VB代码。
Imports System
浏览 3提问于2020-02-18得票数 0
回答已采纳
我需要帮助转换这个WebClient到HttpClient代码，如果这是可能的，我会真的很高兴。 我一直在寻找能把它转换成我的东西/人，但遗憾的是我什么也没找到。 谢谢! private void bunifuFlatButton9_Click(object sender, EventArgs e)
{
{
using (WebClient webClient = new WebClient())
{
webClient.Encoding = Encoding.UTF8;
浏览 21提问于2021-01-16得票数 0
回答已采纳
我正在尝试理解Vert.x框架，我的任务是创建一个HTTP服务器，它将执行简单的数学计算，还有一个客户机将向该服务器发送多个请求。我需要计算发送所有请求和得到响应所需的时间。我成功地创建了客户机、服务器以及发送请求和检索响应，但我在测量执行这些操作所需的时间方面遇到了问题。
我的客户端垂直有以下start()方法：
@Override
public void start() throws Exception {
WebClient client = WebClient.create(vertx);
IntStream.range(0, MathCli
浏览 0提问于2018-03-08得票数 1
回答已采纳
1回答
使用异步函数迭代
、、
使用和vert.x -我希望不断地使用WebClient和Twitch的cursor响应向Twitch的API发送请求，以便逐页执行。然而，由于vert.x的异步特性，我不确定如何返回并继续执行查询，直到满足某个条件。
到目前为止，我的代码如下
public void getEntireStreamList(Handler<AsyncResult<JsonObject>> handler) {
JsonObject data = new JsonObject();
getLiveChannels(100, result -> {
浏览 8提问于2018-01-15得票数 0
回答已采纳
8回答
我正在尝试从URL下载文件，我必须在WebClient和HttpClient之间进行选择。我参考过的文章和互联网上的其他几篇文章。在任何地方，都建议使用HttpClient，因为它具有很好的异步支持和其他.Net 4.5特权。但我仍然不完全相信，需要更多的投入。
我正在使用下面的代码从互联网下载文件：
WebClient:
WebClient client = new WebClient();
client.DownloadFile(downloadUrl, filePath);
HttpClient:
using (HttpClient client = new HttpClient())
浏览 9提问于2017-08-16得票数 75
1回答
我正面临连接错误。日志条目是readAddress(..)失败:由对等方重置连接；嵌套异常为io.netty.channel.unix.Errors$NativeIoException: readAddress(.)失败:连接由对等方重置连接，观察到挂起的获取队列出现错误，其最大大小为1000；嵌套异常为reactor.netty.internal.shaded.reactor.pool.PoolAcquirePendingLimitException。
Webclient配置是：
@Bean
public WebClient webClient(@Autowired ObjectMapper
浏览 11提问于2021-04-29得票数 2
HttpClient from提供了各种要配置的“超时”，其中两个稍微让我感到困惑：
responseTimeout：This is time that takes to receive a response after sending a requestReadTimeoutHandler：Raises a ReadTimeoutException when no data was read within a certain period of time
谁能解释一下他们之间的关键区别吗？
一般场景--使用spring反应性WebClient进行调用，该调用在引擎盖下使用HttpClien
浏览 8提问于2020-10-02得票数 8
1回答
我的webClient调用在@GetMapping中运行良好，但@DeleteMapping甚至没有触发。下面是我使用的两种方法：
//works
MyItem myItem = webClient.get()
.uri(url + "/items/" + tenant + "/" + itemId)
.accept(MediaType.APPLICATION_JSON)
.retrieve()
.bodyToMono(MyItem.class)
.block();
//returns without triggering
浏览 3提问于2022-08-16得票数 0
回答已采纳
1回答
我使用Spring5.3.6的WebFlux 5.3.6的WebClient来流来自REST端点的响应，该端点生成text/csv内容。
我可以使用retrieve()和responseSpec.bodyToFlux来流主体，只有如下所示的：
WebClient.ResponseSpec responseSpec = headersSpec.retrieve();
Flux<DataBuffer> dataBufferFlux = responseSpec.bodyToFlux(DataBuffer.class);
DataBufferUtils
浏览 0提问于2021-08-26得票数 0
4回答
我们使用HTTPClient来实现REST。
我们使用以下方法读取服务器响应：
method = new PostMethod(url);
HttpClient client = new HttpClient();
int statusCode = client.executeMethod(method);
String responseBody = method.getResponseBodyAsString();
当我们这样做时，我们会得到这样的警告：
Dec 9, 2009 7:41:11 PM org.apache.commons.httpclient.HttpMethodBase g
浏览 0提问于2009-12-10得票数 11
回答已采纳
2回答
我使用System.Net.WebClient在异步模式下执行一些HTTP操作。使用异步操作的原因，最重要的是，我得到了进度更改指示--正如所述，这只适用于异步操作。
因此，假设我设置了我的WebClient：
this.client = new WebClient();
this.client.UploadStringCompleted +=
new UploadStringCompletedEventHandler(textUploadComplete);
代表：
private void textUploadComplete(Object sender, UploadString
浏览 6提问于2010-10-13得票数 8
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
