Java Vertx无法为使用webClient的post请求提供用户id密码

Question

这个要求是，我需要通过使用Vert.x web客户端的json post body发送远程服务器和访问endpoint的用户id和密码以及post请求

我尝试了下面的代码

package com.aexp.csrt.qs.cb.resources;
import com.aexp.csrt.qs.models.cb.passTrou.SourceQueryModel;
import io.vertx.reactivex.ext.web.RoutingContext;
import io.vertx.reactivex.core.Vertx;
import io.vertx.ext.web.client.WebClient;
import io.vertx.ext.web.client.WebClientOptions;
import io.vertx.core.json.JsonObject;
import io.vertx.ext.web.client.HttpResponse;
import io.vertx.core.buffer.Buffer;

public class QueryExecutorFTS implements QueryExecutor {
    private WebClient webClient;

    @Override
    public void executeQuery(SourceQueryModel Qm, RoutingContext rc) {

        WebClientOptions options = new WebClientOptions().setMaxPoolSize(10).setConnectTimeout(5000)
                .setVerifyHost(false);

        JsonObject jreq = new JsonObject(Qm.getSourceQuery().getSourceDsl().getQuery());

        Vertx vertx = rc.vertx();
        webClient = WebClient.create(vertx.getDelegate(), options);

         webClient
         .basicAuthentication("myid", "mypassword")
        .post(8094, "lpdospdb51079.phx.aexp.com", "/api/index/Text_search_name_idx/query")
        .sendJsonObject(jreq,
                ar -> {
                    if (ar.succeeded()) {
                        HttpResponse<Buffer> response = ar.result();
                        rc.response().setStatusCode(200).end(response.bodyAsString());
                    } else {
                        ar.cause().printStackTrace();
                        rc
                              .response()
                              .setStatusCode(500)
                              .setStatusMessage(ar.cause().getMessage())
                              .end();
                    }
                })
        ;


    }

}

Answer 1

假设您在服务器端使用会话处理程序，如下所示：

    router.route().handler(CookieHandler.create());
    router.route().handler(SessionHandler.create(LocalSessionStore.create(vertx)));
    router.route().handler(UserSessionHandler.create(authProvider));

现在需要首先使用您为登录定义的url对客户端进行身份验证。

您的登录路径->/login

    router.route(HttpMethod.POST, path)
        .handler(FormLoginHandler.create(authProvider));

MultiMap form = MultiMap.caseInsensitiveMultiMap();
form.add("username", user);
form.add("password", password);

client
    .post(port, "localhost", "/login")
    .putHeader("content-type", "multipart/form-data")
    .sendForm(form, ar -> {
        if (ar.succeeded()) {
            log.info("RESOURCES: {}", ar.result().bodyAsString());
            log.info("COOKIES: {}", ar.result().cookies());//.getHeader("vertx-web.session"));
            ar.result().cookies().stream().filter(c -> c.startsWith("vertx-web.session")).findFirst().ifPresent(s -> {
                // do something with the session cookie - >cookie.accept(s.substring(0, s.indexOf(";")));
            });
        } else {
            log.error("Something went wrong", ar.cause());
        }
    });

    client.
        .get(port, "localhost", "/resource")
        .putHeader("Cookie", cookie)
        .send(ar -> { ...