如何使用Web客户端反应性Web客户端为POST与ZIP（压缩数据）体的请求。
我创建在存储器（bytearrayoutputstream）拉链，并希望使用Web客户端反应性Web客户端发送在POST请求体的zip数据。该REST API是一个REST PdfReactor WebService的。响应是一个二进制数据（PDF）。
当我调试我的代码，我得到以下错误：连接池观察到的错误
org.springframework.web.reactive.function.UnsupportedMediaTypeException: Content type 'application/octet-stream' not supported for bodyType=java.io.ByteArrayInputStream
at org.springframework.web.reactive.function.BodyInserters.unsupportedError(BodyInserters.java:297) ~[spring-webflux-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.web.reactive.function.BodyInserters.lambda$writeWithMessageWriters$9(BodyInserters.java:287) ~[spring-webflux-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at java.base/java.util.Optional.orElseGet(Optional.java:358) ~[na:na]
at org.springframework.web.reactive.function.BodyInserters.writeWithMessageWriters(BodyInserters.java:287) ~[spring-webflux-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.web.reactive.function.BodyInserters.lambda$fromObject$1(BodyInserters.java:85) ~[spring-webflux-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.web.reactive.function.client.DefaultClientRequestBuilder$BodyInserterRequest.writeTo(DefaultClientRequestBuilder.java:257) ~[spring-webflux-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.web.reactive.function.client.ExchangeFunctions$DefaultExchangeFunction.lambda$exchange$1(ExchangeFunctions.java:103) ~[spring-webflux-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at org.springframework.http.client.reactive.ReactorClientHttpConnector.lambda$connect$2(ReactorClientHttpConnector.java:110) ~[spring-web-5.1.2.RELEASE.jar:5.1.2.RELEASE]
at reactor.netty.http.client.HttpClientConnect$HttpClientHandler.requestWithBody(HttpClientConnect.java:528) ~[reactor-netty-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at reactor.netty.http.client.HttpClientConnect$HttpObserver.lambda$onStateChange$0(HttpClientConnect.java:396) [reactor-netty-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:44) ~[reactor-core-3.2.2.RELEASE.jar:3.2.2.RELEASE]
at reactor.core.publisher.MonoOnAssembly.subscribe(MonoOnAssembly.java:76) [reactor-core-3.2.2.RELEASE.jar:3.2.2.RELEASE]
at reactor.netty.http.client.HttpClientConnect$HttpObserver.onStateChange(HttpClientConnect.java:397) [reactor-netty-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at reactor.netty.resources.PooledConnectionProvider$DisposableAcquire.onStateChange(PooledConnectionProvider.java:501) [reactor-netty-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at reactor.netty.resources.PooledConnectionProvider$DisposableAcquire.run(PooledConnectionProvider.java:531) [reactor-netty-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) [netty-common-4.1.29.Final.jar:4.1.29.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404) [netty-common-4.1.29.Final.jar:4.1.29.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:446) [netty-transport-4.1.29.Final.jar:4.1.29.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884) [netty-common-4.1.29.Final.jar:4.1.29.Final]
at java.base/java.lang.Thread.run(Thread.java:844) [na:na]
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
|_ Mono.error ⇢ org.springframework.web.reactive.function.BodyInserters.lambda$writeWithMessageWriters$9(BodyInserters.java:287)
|_ Mono.defer ⇢ reactor.netty.http.client.HttpClientConnect$HttpObserver.onStateChange(HttpClientConnect.java:396)
configuration.json:
{
"document": "test.html",
"addBookmarks": true,
"addLinks": true
}
test.html:
<html>
<img src="img/image.png" />
<div>
Hallo, hier ist ein Testdokument von <span th:text="${userName}" />.
</div>
</html>
map.put(template, tempBytesArray);
map.put(configuration, configByteArray);
try (ByteArrayOutputStream bos = new ByteArrayOutputStream()) {
try (ZipOutputStream zos_ = new ZipOutputStream(bos)) {
map.forEach((k, v) -> {
var zipentry = new ZipEntry(k);
try {
zos_.putNextEntry(zipentry);
zos_.write(v);
zos_.closeEntry();
} catch (IOException e) {
e.printStackTrace();
}
});
byte[] b = bos.toByteArray();
BodyInserter<Object, ReactiveHttpOutputMessage> bodyInserter = BodyInserters.fromObject(bos);
byteArray = pdfReactorClient
.post()
.uri(pdfReactorUrl + PDF_REACTOR_URL_SUFFIX)
.accept(MediaType.APPLICATION_OCTET_STREAM)
.body(BodyInserters.fromObject(bos)
.exchange()
.flatMap(response -> response.bodyToMono (ByteArrayResource.class))
.map(ByteArrayResource::getByteArray)
.block();
zos_.close();
} catch (Exception e) {
// TODO: handle exception
}
如果我执行命令行下面卷曲，我得到的结果pdf文件：
curl -X POST -H "Cache-Control: no-cache" -H "Content-Type: application/zip" --data-binary @test.gzip "http://localhost:8080/service/rest/convert.pdf" > result.pdf。
同样要在Java中反应代码进行翻译。请求主体（邮编/资产包）到PDFReactor是问题所在。请帮助请...
内容类型的PDF是MediaType.APPLICATION_PDF
改变内容类型，如下所示
pdfReactorClient
.post()
.uri(pdfReactorUrl + PDF_REACTOR_URL_SUFFIX)
.accept(MediaType.APPLICATION_PDF)