如何解决必需的正文 [文件] 未指定 Micronaut 分段上传 客户端和服务器 MultipartBody客户端 HTTP 标头MIME 类型固定实现
尝试使用声明式 HTTP 客户端上传文件,如下所示
Http 客户端
@Client("http://localhost:8080/product")
public interface IHttpClient {
@Post(consumes = MediaType.MULTIPART_FORM_DATA,produces = MediaType.MULTIPART_FORM_DATA)
public String post(@Body MultipartBody file);
}
对客户端的依赖注入
@Controller("/productManager")
public class ProductManagerController implements IProductOperation{
private final IHttpClient iProduct;
public ProductManagerController(IHttpClient iProduct) {
this.iProduct = iProduct;
}
@Override
public String post(CompletedFileUpload file) throws IOException {
MultipartBody requestBody = MultipartBody.builder().addPart("file",file.getFilename(),MediaType.MULTIPART_FORM_DATA_TYPE,file.getBytes()).build();
return this.iProduct.post(requestBody);
}
}
产品控制器
@Controller("/product")
public class ProductController implements IProductOperation {
@Post(consumes = MediaType.MULTIPART_FORM_DATA,produces = MediaType.MULTIPART_FORM_DATA)
public String post(@Body MultipartBody file) {
return null;
}
}
卷曲
curl --location --request POST 'http://localhost:8080/productManager' \
--form 'file=@"/Users/macbook/Downloads/anand 001.jpg"'
我面临的一个例外
02:32:24.519 [main] INFO io.micronaut.runtime.Micronaut - Startup completed in 7442ms. Server Running: http://localhost:8080
02:32:33.985 [default-nioEventLoopGroup-1-4] DEBUG i.m.h.client.netty.DefaultHttpClient - Sending HTTP POST to http://localhost:8080/product
02:32:33.990 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - Accept: multipart/form-data
02:32:33.993 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - content-type: multipart/form-data; boundary=ac4442578cac3c2
02:32:33.994 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - transfer-encoding: chunked
02:32:33.994 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - host: localhost:8080
02:32:33.995 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - connection: close
02:32:35.260 [default-nioEventLoopGroup-1-4] DEBUG i.m.h.client.netty.DefaultHttpClient - Received response 400 from http://localhost:8080/product
02:32:35.260 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - Content-Type: application/json
02:32:35.260 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - content-length: 119
02:32:35.260 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - connection: close
02:32:35.260 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - Response Body
02:32:35.261 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - ----
02:32:35.261 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - {"message":"Required Body [file] not specified","path":"/file","_links":{"self":{"href":"/product","templated":false}}}
02:32:35.261 [default-nioEventLoopGroup-1-4] TRACE i.m.h.client.netty.DefaultHttpClient - ----
02:32:35.364 [default-nioEventLoopGroup-1-3] ERROR i.m.r.intercept.RecoveryInterceptor - Type [com.example.IProduct$Intercepted] executed with error: Required Body [file] not specified
io.micronaut.http.client.exceptions.HttpClientResponseException: Required Body [file] not specified
at io.micronaut.http.client.netty.DefaultHttpClient$12.channelRead0(DefaultHttpClient.java:2140)
at io.micronaut.http.client.netty.DefaultHttpClient$12.channelRead0(DefaultHttpClient.java:2055)
at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
at io.micronaut.http.netty.stream.HttpStreamsHandler.channelRead(HttpStreamsHandler.java:193)
at io.micronaut.http.netty.stream.HttpStreamsClientHandler.channelRead(HttpStreamsClientHandler.java:183)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)
at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:719)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:655)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:581)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:832)
解决方法
您的实施中似乎存在多个问题,下面是详细信息。
客户端和服务器 MultipartBody
这篇文章忽略了诊断错误的最重要的部分,即类 import
s。
当以编程方式构建 multipart 请求时,Micronaut 提供 io.micronaut.http.client.multipart.MultipartBody
类型来构建 multipart/form-data 请求。
请注意 MultipartBody
的 FQN(完全限定名称),它是 io.micronaut.http.client.*
API 的一部分。
另一方面,@Controller
端点应使用相应的服务器类型,即:io.micronaut.http.server.multipart.MultipartBody
。
还要注意 FQN,它是 io.micronaut.http.server.*
API 的一部分。
客户端 HTTP 标头
在幕后,生成的 Micronaut 客户端会将您的 @Client
方法注释转换为适当的 HTTP 标头(Content-Type HTTP 标头是兴趣在这里)。这些标头显然应该与您的控制器端点预期相匹配。
虽然简单的方法是为客户端和控制器使用相同的端点注释,但不幸的是这是错误的:@Client
和 @Controller
各自的方法必须颠倒produces
和 consumes
注释字段,以便:
- 客户端产生控制器在发送请求时消耗的
- 客户端使用控制器在收到响应时产生的
MIME 类型
在您的客户端和控制器实现中,您都返回一个 String
。
内容类型规范的端点注释字段应匹配返回的类型,即 MediaTye.TEXT_PLAIN
的 java.lang.String
而不是 MediaType.MULTIPART_FORM_DATA
固定实现
@Client
声明式接口应如下所示(包含完整的 import
,固定输入和结果 MIME 类型):
import io.micronaut.http.MediaType;
import io.micronaut.http.annotation.Body;
import io.micronaut.http.annotation.Post;
import io.micronaut.http.client.annotation.Client;
import io.micronaut.http.client.multipart.MultipartBody;
@Client("http://localhost:8080/product")
public interface IHttpClient {
@Post(consumes = MediaType.TEXT_PLAIN,produces = MediaType.MULTIPART_FORM_DATA)
public String post(@Body MultipartBody file);
}
这里的 @Controller
端点实现是什么(具有适当的 MultipartBody
和固定结果 MIME 类型):
import io.micronaut.http.MediaType;
import io.micronaut.http.annotation.Body;
import io.micronaut.http.annotation.Controller;
import io.micronaut.http.annotation.Post;
import io.micronaut.http.server.multipart.MultipartBody;
@Controller("/product")
public class ProductController implements IProductOperation {
@Post(consumes = MediaType.MULTIPART_FORM_DATA,produces = MediaType.TEXT_PLAIN)
public String post(@Body MultipartBody file) {
return null;
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。