如何使用Spring Webflux路由配置将图像上载到MySQL数据库

Question

我想将图像上传到MySQL DB，我使用spring web flux、hibernate Responsive mutiny，我使用控制器方法保存文件，使用路由配置方法，我得到错误“415 Unsupported Media Type”。

下面是代码，

控制器

@RouterOperation
    @Bean
    public RouterFunction<ServerResponse> uploadImage(CommonHandler handler) {
        return route().POST("/uploadImage/{id}", accept(APPLICATION_JSON), handler::uploadImage,
                ops -> ops.beanClass((CommonHandler.class).beanMethod("uploadImage")).build();
    }

处理程序

@Operation(summary = "Upload Image", description = "Upload User Image", requestBody = @RequestBody(description = "Upload Image", content = @Content(schema = @Schema(implementation = FilePart.class))), responses = {
            @io.swagger.v3.oas.annotations.responses.ApiResponse(responseCode = "200", description = "success", content = @Content(schema = @Schema(implementation = String.class, description = "Returns Id"))) })
    public Mono<ServerResponse> uploadImage(ServerRequest req) {
        String userId = req.pathVariable(ID);
        if (uuidString.isEmpty()) {
            return ServerResponse.badRequest()
                    .body(BodyInserters.fromValue(new ApiResponse(400, ID_CANNOT_BE_NULL, null)));
        } else {
            return req.bodyToMono(FilePart.class)
                    .flatMap(a -> ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(
                            BodyInserters.fromValueuploadImage(a, UUID.fromString(uuidString)))))
                    .switchIfEmpty(ServerResponse.notFound().build());
        }
    }

邮递员请求

这就是错误所在

Resolved [UnsupportedMediaTypeStatusException: 415 UNSUPPORTED_MEDIA_TYPE "Content type 'multipart/form-data;boundary=----WebKitFormBoundaryFq3IABrSBSF51xcR' not supported for bodyType=org.springframework.http.codec.multipart.FilePart"] for HTTP POST

我尝试将内容类型更改为image/png、image/jpg，并完全删除内容类型，但仍然不起作用。

控制器方法（工作正常）

@RequestMapping(value = "/uploadImage/{id}", method = RequestMethod.POST)
    public ResponseEntity<String> uploadImage(@PathVariable String id,
            @RequestPart("image") FilePart image) { 
        Flux<DataBuffer> imageDataBuffer = image.content(); 
        Mono<byte[]> imageBytes = DataBufferUtils.join(image.content()).map(dataBuffer -> dataBuffer.asByteBuffer().array());
        String userId = service.uploadImageToUser(imageBytes, id);
        return new ResponseEntity<String>(userId, HttpStatus.CREATED);
    }

非常感谢您的帮助。

提前谢谢。

Answer 1

在关系数据库中存储图像/文档（二进制数据）不是一个好主意，因为数据库的设计不是为了处理大量的BLOB数据。您可以将文件存储在文件系统中，并将文件路径作为字符串存储在数据库中。