4.6. HTTP 的更改

以下示例演示了如何在 Eclipse Vert.x 3.x 版本中发送 GET 请求。

HttpClientRequest request = client.get(80, "example.com", "/", response -> {
  int statusCode = response.statusCode();
  response.exceptionHandler(err -> {
    // Handle connection error, for example, connection closed
  });
  response.bodyHandler(body -> {
    // Handle body entirely
  });
});
request.exceptionHandler(err -> {
  // Handle connection error OR response error
});
request.end();

以下示例演示了如何在 Eclipse Vert.x 4 中发送 GET 请求。

client.request(HttpMethod.GET, 80, "example.com", "/", ar -> {
  if (ar.succeeded()) {
    HttpClientRequest = ar.result();
    request.send(ar2 -> {
      if (ar2.succeeded()) {
        HttpClientResponse = ar2.result();
        int statusCode = response.statusCode();
        response.body(ar3 -> {
          if (ar3.succeeded()) {
            Buffer body = ar3.result();
            // Handle body entirely
          } else {
            // Handle server error, for example, connection closed
          }
        });
      } else {
        // Handle server error, for example, connection closed
      }
    });
  } else {
    // Connection error, for example, invalid server or invalid SSL certificate
  }
});

您可以在新的 HTTP 客户端中看到错误处理效果更好。

以下示例演示了如何在 Eclipse Vert.x 4 中的 GET 操作中使用未来组成。

Future<Buffer> fut = client.request(HttpMethod.GET, 80, "example.com", "/")
  .compose(request -> request.send().compose(response -> {
    int statusCode = response.statusCode();
    if (statusCode == 200) {
      return response.body();
    } else {
      return Future.failedFuture("Unexpectd status code");
    }
  })
});
fut.onComplete(ar -> {
  if (ar.succeeded()) {
    Buffer body = ar.result();
    // Handle body entirely
  } else {
    // Handle error
  }
});

未来组成提高了异常处理。示例检查状态代码是否为 200，否则返回了错误。

在 Eclipse Vert.x 3.x 版本中，您可以使用 end （） 方法发送请求。

request.end();

您还可以在请求中发送正文。

request.end(Buffer.buffer("hello world));

因为 HttpClientRequest 是一个 Writestream<Buffer >，所以您也可以使用管道来流传输请求。

writeStream.pipeTo(request, ar -> {
  if (ar.succeeded()) {
    // Sent the stream
  }
});

在 Eclipse Vert.x 4 中，您可以使用 get （） 方法执行示例中显示的所有操作。您还可以使用新的 send （） 方法来执行这些操作。您可以将缓冲区、字符串或 ReadStream 作为输入传递给 send （） 方法。该方法返回 HttpClientResponse 实例。

// Send a request and process the response
request.onComplete(ar -> {
  if (ar.succeeded()) {
    HttpClientResponse response = ar.result();
    // Handle the response
  }
})
request.end();

// The new send method combines all the operations
request.send(ar -> {
  if (ar.succeeded()) {
    HttpClientResponse response = ar.result();
    // Handle the response
  }
}));

HttpClientResponse 接口已经使用以下方法更新并改进：

您还可以使用方法（如 onSucces （）、Compose （）、 bodyHandler （） 等）处理响应。以下示例演示了使用 onSuccess （） 方法处理响应。

以下示例演示了如何将 HTTP 客户端与 Eclipse Vert.x 3.x 版本的 result （） 方法搭配使用。

HttpClient client = vertx.createHttpClient(options);

    client.request(HttpMethod.GET, 8443, "localhost", "/")
      .onSuccess(request -> {
        request.onSuccess(resp -> {

        //Code to handle HTTP response
        });
      });

以下示例演示了如何将 HTTP 客户端与 Eclipse Vert.x 4 中的 result （） 方法搭配使用。

HttpClient client = vertx.createHttpClient(options);

    client.request(HttpMethod.GET, 8443, "localhost", "/")
      .onSuccess(request -> {
        request.response().onSuccess(resp -> {

        //Code to handle HTTP response
        });
      });

HttpClient 和 HttpClientRequest 方法已更新，以使用异步处理程序。该方法使用 Handler<AsyncResult<HttpClientResponse> 作为输入，而不是 Handler<HttpClientResponse>。

在较早版本的 Eclipse Vert.x 中，HttpClient 方法 get Now （）、选项 Now （）和 headNow （） 用于返回 HttpClient Request，您必须进一步发送请求。getNow （）、 optionsNow （） 和 headNow （） 方法已被删除。在 Eclipse Vert.x 4 中，您可以使用 Handler<AsyncResult<HttpClientResponse& gt; 直接发送包含所需信息的请求。

以下示例演示了如何在 Eclipse Vert.x 3.x 中发送请求。

在 Eclipse Vert.x 4 中，您可以使用 请求 方法创建 HttpClientRequest 实例。这些方法可用于基本交互，例如：

以下示例演示了如何在 Eclipse Vert.x 4 中创建 HTTPClientRequest。

client.request(HttpMethod.GET, 8080, "example.com", "/resource", ar -> {
  if (ar.succeeded()) {
    HttpClientRequest request = ar.result();
    request.putHeader("content-type", "application/json")
    request.send(new JsonObject().put("hello", "world"))
      .onSuccess(response -> {
      //
      }).onFailure(err -> {
      //
       });
     }
})

HttpClientRequest.connectionHandler （） 方法已被删除。使用 HttpClient.connectionHandler （） 方法调用应用中客户端请求的连接处理程序。

以下示例演示了如何在 Eclipse Vert.x 3.x 版本中使用 HttpClientRequest.connectionHandler （） 方法。

client.request().connectionHandler(conn -> {
  // Connection related code
}).end();

以下示例演示了如何使用新的 HttpClient.connectionHandler （） 方法。

client.connectionHandler(conn -> {
// Connection related code
});

可以使用 HttpClientResponse.netSocket （） 方法创建 HTTP 隧道。在 Eclipse Vert.x 4 中，此方法已更新。

要获得用于请求连接的 net socket，请在请求中发送套接字处理程序。当收到 HTTP 响应标头时，调用该处理程序。套接字可以进行隧道连接，可以发送和接收缓冲区。

以下示例演示了如何在 Eclipse Vert.x 3.x 版本中获取连接的 net socket。

client.request(HttpMethod.CONNECT, uri, ar -> {
  if (ar.succeeded()) {
    HttpClientResponse response = ar.result();
    if (response.statusCode() == 200) {
      NetSocket so = response.netSocket();
   }
  }
}).end();

以下示例演示了如何在 Eclipse Vert.x 4 中获取连接的 net socket。

client.request(HttpMethod.CONNECT, uri, ar -> {
}).netSocket(ar -> {
  if (ar.succeeded()) {
   // Got a response with a 200 status code
   NetSocket so = ar.result();
   // Go for tunneling
  }
}).end();

HttpClient 类中提供了一个新的 send （） 方法。

以下代码演示了如何在 Eclipse Vert.x 4 中发送请求。

Future<HttpClientResponse> f1 = client.send(HttpMethod.GET, 8080, "localhost", "/uri", HttpHeaders.set("foo", "bar"));

在 Eclipse Vert.x 4 中，HttpHeaders 是一个接口。在较早版本的 Eclipse Vert.x 中，H ttpHeaders 是一个类。

在 HttpHeaders 界面中添加了以下新的 MultiMap 方法。使用这些方法创建 MultiMap 实例。

以下示例演示了如何在 Eclipse Vert.x 3.x 版本中创建 MultiMap 实例。

MultiMap headers = MultiMap.caseInsensitiveMultiMap();

以下示例演示了如何在 Eclipse Vert.x 4 中创建 MultiMap 实例。

MultiMap headers = HttpHeaders.headers();

MultiMap headers = HttpHeaders.set("content-type", "application.data");

CaseIn sensitiveHeaders 类不再是公共的。使用 MultiMap.caseInsensitiveMultiMap （） 方法创建一个具有不区分大小写的键的多映射实施。

以下示例演示了如何在 Eclipse Vert.x 3.x 版本中使用 CaseInsensitiveHeaders 方法。

CaseInsensitiveHeaders headers = new CaseInsensitiveHeaders();

以下示例演示了如何在 Eclipse Vert.x 4 中使用 MultiMap 方法。

MultiMap multiMap = MultiMap#caseInsensitiveMultiMap();

或者

MultiMap headers = HttpHeaders.headers();

在较早版本的 Eclipse Vert.x 中，只有在应用程序明确调用 HttpServerRequest.version （） 方法时，才会检查服务器上运行的 HTTP 版本。如果 HTTP 版本是 HTTP/1.x，该方法会返回 501 HTTP 状态，并关闭连接。

在向服务器发送请求前，从 Eclipse Vert.x 4 onward 中，通过调用 HttpServerRequest.version （） 方法自动检查服务器上的 HTTP 版本。当找到无效的 HTTP 版本时，方法会返回 HTTP 版本而不是抛出异常。

在 Eclipse Vert.x 4 中，RequestOptions 类中提供了以下新方法：

以下示例演示了如何使用新方法。

client.request(HttpMethod.GET, 8080, "example.com", "/resource", ar -> {
  if (ar.succeeded()) {
    HttpClientRequest request = ar.result();
    request.putHeader("content-type", "application/json")
    request.send(new JsonObject().put("hello", "world"))
      .onSuccess(response -> {
      //
      }).onFailure(err -> {
      //
       });
     }
})