Обязательный Body [файл] не указан Micronaut Multipart upload

Попытка загрузить файл с помощью декларативного 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

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)

java micronaut micronaut-client micronaut-rest
person San Jaisy    schedule 06.03.2021    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Кажется, что в вашей реализации есть несколько проблем, и вот подробности.

Клиент и сервер MultipartBody

В сообщении отсутствует самая важная часть для диагностики ошибки, а именно класс imports.

При программном создании запросов multipart Micronaut предоставляет тип io.micronaut.http.client.multipart.MultipartBody для создания запросов multipart / form-data. Обратите внимание на FQN (полное имя) для MultipartBody, которое является частью io.micronaut.http.client.* API.

С другой стороны, конечная точка @Controller должна использовать соответствующий тип сервера: io.micronaut.http.server.multipart.MultipartBody. Также обратите внимание на FQN, который является частью io.micronaut.http.server.* API.

Заголовки HTTP клиента

Под капотом сгенерированный клиент Micronaut преобразует аннотации ваших @Client методов в соответствующие HTTP-заголовки (HTTP-заголовок Content-Type здесь представляет интерес). Эти заголовки, очевидно, должны соответствовать ожидаемым заголовкам конечной точки вашего контроллера.

Хотя тривиальный подход заключался бы в том, чтобы иметь одну и ту же аннотацию конечной точки для клиента и контроллера, это, к сожалению, неверно: соответствующие методы @Client и @Controller должны иметь перевернутые поля аннотации produces и consumes, чтобы:

  • клиент производит то, что контроллер потребляет при отправке запроса, затем
  • клиент потребляет то, что контроллер при получении ответа

Типы MIME

И в реализации клиента, и в контроллере вы возвращаете String. Поля аннотации конечной точки для спецификации типов контента должны соответствовать возвращаемому типу, который равен MediaTye.TEXT_PLAIN для java.lang.String, а не MediaType.MULTIPART_FORM_DATA

Фиксированная реализация

Тогда @Client декларативный интерфейс должен выглядеть, как показано ниже (с полными imports, фиксированным вводом и типами 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;
    }
}
person tmarwen    schedule 06.03.2021