Spring Apache Kafka传输含MultipartFile的实体类序列化问题

MultipartFile是Spring提供的接口，本身没有实现Serializable接口，直接序列化必然失败；而且它是Web请求中上传文件的临时封装对象，包含请求上下文相关的临时资源信息，并不适合作为消息体直接传输到Kafka。

最稳妥的方式是将MultipartFile转换为可序列化的文件数据结构，再进行传输。

1. 定义可序列化的文件DTO #

创建一个包含文件核心元数据和内容的可序列化类，替代MultipartFile：

import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import java.io.Serializable;

@Getter
@Setter
@AllArgsConstructor
@NoArgsConstructor
public class FileData implements Serializable {
    private String fileName; // 文件名
    private String contentType; // 文件类型
    private byte[] content; // 文件字节内容
}

2. 修改Email实体类 #

用自定义的FileData替换原有的MultipartFile属性：

package com.example.demo.multipartfile.model;

import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import java.io.Serializable;

@Getter
@Setter
@AllArgsConstructor
@NoArgsConstructor
public class Email implements Serializable {
    private String name;
    private FileData fileData; // 替换原MultipartFile属性
}

3. 在REST接口中完成转换 #

在接收Web请求时，将MultipartFile转换为FileData，再封装到Email对象中发送到Kafka：

import org.springframework.http.ResponseEntity;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;

@RestController
public class EmailController {

    private final KafkaTemplate<String, Email> kafkaTemplate;

    public EmailController(KafkaTemplate<String, Email> kafkaTemplate) {
        this.kafkaTemplate = kafkaTemplate;
    }

    @PostMapping("/send-email")
    public ResponseEntity<String> sendEmail(@ModelAttribute EmailRequest request) throws IOException {
        // 转换MultipartFile到FileData
        FileData fileData = new FileData();
        fileData.setFileName(request.getFile().getOriginalFilename());
        fileData.setContentType(request.getFile().getContentType());
        fileData.setContent(request.getFile().getBytes());

        // 封装Email对象
        Email email = new Email();
        email.setName(request.getName());
        email.setFileData(fileData);

        // 发送到Kafka
        kafkaTemplate.send("email-topic", email);
        return ResponseEntity.ok("消息已发送至Kafka");
    }

    // 仅用于Web层接收请求的临时DTO
    static class EmailRequest {
        private String name;
        private MultipartFile file;

        // getter和setter
        public String getName() { return name; }
        public void setName(String name) { this.name = name; }
        public MultipartFile getFile() { return file; }
        public void setFile(MultipartFile file) { this.file = file; }
    }
}

• 如果传输大文件，直接发送字节数组会导致Kafka消息过大，建议将文件存储到外部存储服务（如MinIO、OSS），仅在Email对象中传输文件的访问URL
• 确保Kafka生产者和消费者使用一致的序列化/反序列化方式（比如Spring Kafka默认的JsonSerializer和JsonDeserializer）

内容的提问来源于stack exchange，提问作者Th3Arock