Опубликовать файл и тело JSON вместе, используя WSClient в игровой среде 2.5

Я пытаюсь опубликовать данные из нескольких частей (файл и json) на стороннем клиенте, используя WSClient в Play фреймворк.

Source<ByteString, ?> file = FileIO.fromFile(new File("hello.txt"));
FilePart<Source<ByteString, ?>> fp = new FilePart<>("hello", "hello.txt", "text/plain", file);
DataPart dp = new DataPart("key", "value");

ws.url(url).post(Source.from(Arrays.asList(fp, dp)));

Согласно их документам, они упомянули, чтобы отправить это как выше.

Я получаю ошибку как плохой запрос. Кажется, запрос сформирован неправильно. Может кто-нибудь объяснить, как это можно сделать?

Это то, что я получаю в ответ

    NettyResponse {
    statusCode=400
    headers=
        Cache-Control: must-revalidate,no-cache,no-store
        Content-Type: text/html; charset=ISO-8859-1
        Date: Mon, 30 Jan 2017 15:33:20 GMT
        Content-Length: 310
        Connection: keep-alive
    body=
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/>
<title>Error 400 Bad Request</title>
</head>
<body><h2>HTTP ERROR 400</h2>
<p>Problem accessing /client/document/upload. Reason:
<pre>    Bad Request</pre></p><hr><i><small>Powered by Jetty://</small></i><hr/>

</body>
</html>

}
Источник

1 ответ

У меня есть этот класс, который вы можете использовать для пересылки Multipart Request или Nornmal Json. Адаптируйтесь к вашему варианту использования. Расширьте класс в вашем контроллере и вызовите return this.forwardRequest(request()); или вернуть forwardMultipartRequest(request());

import akka.stream.javadsl.FileIO;
import akka.stream.javadsl.Source;
import akka.util.ByteString;
import play.mvc.Controller;
import play.mvc.*;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CompletionStage;
import java.util.stream.Collectors;
import javax.inject.Inject;
import org.apache.commons.lang3.tuple.Pair;
import play.libs.ws.WSClient;
import java.util.Objects;
import org.apache.commons.lang.StringUtils;
import play.libs.ws.WSRequest;
import play.mvc.Http.MultipartFormData.*;

/**
 *
 * @author poseidon
 */
public class RequestMaker extends Controller {

    @Inject
    WSClient wSClient;

    protected CompletionStage<Result> forwardRequest(Http.Request request) {

       return forwardRequest(request, false);
    }

    protected CompletionStage<Result> forwardMultipartRequest(Http.Request request) {
        //select only needed headers
        Map<String, List<String>> headers = request.headers().entrySet().stream().filter(g -> g.getKey().equalsIgnoreCase("authorization")).map(f -> Pair.of(f.getKey(), Arrays.asList(f.getValue()))).collect(Collectors.toMap(g -> g.getLeft(), g -> g.getRight()));
        Map<String, List<String>> queryParams = request.queryString().entrySet().stream().map(f -> Pair.of(f.getKey(), Arrays.asList(f.getValue()))).collect(Collectors.toMap(g -> g.getLeft(), g -> g.getRight()));
        String path = request.path();
        WSRequest wSRequest = wSClient.url(String.format("%s%s", System.getenv("API_SERVER_URL"), request.path())).setHeaders(headers).setQueryString(queryParams);

        Http.MultipartFormData<java.io.File> asMultipartFormData = request.body().asMultipartFormData();
        List<Http.MultipartFormData.Part<Source<ByteString, ?>>> files = asMultipartFormData.getFiles().stream().map(g -> {
            FilePart<Source<ByteString, ?>> fp = new FilePart<>(g.getKey(), g.getFilename(), g.getContentType(), FileIO.fromFile(g.getFile()));
            return fp;
        }).collect(Collectors.toList());
        return wSRequest.post(Source.from(files)).thenApply(fn -> {
            if (StringUtils.isNotBlank(fn.getBody())) {
                return status(fn.getStatus(), fn.getBody()).as(fn.getContentType());
            }
            return status(fn.getStatus()).as(fn.getContentType());
        }).exceptionally(fn -> {
            play.Logger.error("Failed to call path = {}, headers = {}, query = {}", path, headers, queryParams, fn);
            return badRequest(fn.getMessage());
        });
    }

    protected CompletionStage<Result> forwardRequestWithByteResponse(Http.Request request) {

      return forwardRequest(request, true);
    }

    protected CompletionStage<Result> forwardRequest(Http.Request request, boolean byteResponse) {

        Map<String, List<String>> headers = request.headers().entrySet().stream().map(f -> Pair.of(f.getKey(), Arrays.asList(f.getValue()))).collect(Collectors.toMap(g -> g.getLeft(), g -> g.getRight()));
        Map<String, List<String>> queryParams = request.queryString().entrySet().stream().map(f -> Pair.of(f.getKey(), Arrays.asList(f.getValue()))).collect(Collectors.toMap(g -> g.getLeft(), g -> g.getRight()));
        String path = request.path();
        WSRequest wSRequest = wSClient.url(String.format("%s%s", System.getenv("API_SERVER_URL"), request.path())).setHeaders(headers).setQueryString(queryParams);
        if (request.hasBody() && Objects.nonNull(request.body().asJson())) {
            wSRequest = wSRequest.setBody(request.body().asJson());
        }
        return wSRequest.setMethod(request.method()).execute().thenApply(fn -> {
            if (byteResponse && Objects.nonNull(fn.asByteArray())) {
                return status(fn.getStatus(), fn.asByteArray()).as(fn.getContentType());
            }
            if (StringUtils.isNotBlank(fn.getBody())) {
                return status(fn.getStatus(), fn.getBody()).as(fn.getContentType());
            }
            return status(fn.getStatus()).as(fn.getContentType());
        }).exceptionally(fn -> {
            play.Logger.error("Failed to call path = {}, headers = {}, query = {}", path, headers, queryParams, fn);
            return badRequest(fn.getMessage());
        });
    }
}
Источник

Уже поздно, но может кому-нибудь помочь. Это может быть связано с тем, что сервер не принимает chinked-передачу. В игровом фреймворке на основе кода https://github.com/playframework/playframework/blob/2.5.x/framework/src/play-java-ws/src/main/java/play/libs/ws/ahc/AhcWSRequest.java#L520-L533

// Если тело имеет потоковый интерфейс, пользователь должен самостоятельно указать Content-Length

// иначе каждый контент будет Transfer-Encoding: разбит

// Если Content-Length равен -1, Async-Http-Client устанавливает Transfer-Encoding: chunked

// Если Content-Length больше -1, Async-Http-Client будет использовать правильную Content-Length

Я столкнулся с той же проблемой, добавив заголовок Content-Length, решенный в моем случае. Добавлен заголовок, как показано ниже, в WSRequest,

wsRequest.setHeader("Content-Length", String.valueOf(fileToUpload.length()));

Здесь fileToUpload - это объект java.io.File, который вы пытаетесь загрузить.

Источник
Другие вопросы по тегам