Версия
vert.x core: 3.3.0
Контекст
Я просто пытаюсь запустить http-клиент в основных примерах io.vertx.example.core.http.simple.Client. При выполнении этого примера было обнаружено, что установленное соединение не закрывается после завершения запроса.
На стороне сервера я не видел никаких проблем. Так как при попытке с jmeter и сервером все работает нормально. Так что я думаю, что проблема в HttpClient.
Кто-нибудь может помочь мне в этом?
Заранее спасибо. Действия по воспроизведению
running io.vertx.example.core.http.simple.Server code
running io.vertx.example.core.http.simple.Client code
Дополнительный
Следующее показано даже после завершения запроса и ответа. при предоставлении LINUX
lsof -i -P
java 32551 USER 223u IPv4 16264097 0t0 TCP localhost:8080->localhost:26980 (ESTABLISHED)
java 32634 USER 218u IPv4 16264087 0t0 TCP localhost:26980->localhost:8080 (ESTABLISHED)
ОКНА
TCP 127.0.0.1:8080 FSSCHND12957:56893 ESTABLISHED
TCP 127.0.0.1:56893 FSSCHND12957:8080 ESTABLISHED
Пробовал как в LINUX, так и в WINDOWS.
Код клиента
package io.vertx.example.core.http.simple;
import io.vertx.core.AbstractVerticle;
import io.vertx.example.util.Runner;
/*
@author Tim Fox
*/
public class Client extends AbstractVerticle {
// Convenience method so you can run it in your IDE
public static void main(String[] args) {
Runner.runExample(Client.class);
}
@Override
public void start() throws Exception {
vertx.createHttpClient().getNow(8080, "localhost", "/", resp -> {
System.out.println("Got response " + resp.statusCode());
resp.bodyHandler(body -> {
System.out.println("Got data " + body.toString("ISO-8859-1"));
});
});
}
}
Код сервера
package io.vertx.example.core.http.simple;
import io.vertx.core.AbstractVerticle;
import io.vertx.example.util.Runner;
/*
@author Tim Fox
*/
public class Server extends AbstractVerticle {
// Convenience method so you can run it in your IDE
public static void main(String[] args) {
Runner.runExample(Server.class);
}
@Override
public void start() throws Exception {
vertx.createHttpServer().requestHandler(req -> {
req.response().putHeader("content-type", "text/html").end("
Hello from vert.x!
");
}).listen(8080);
}
}