SpringBoot读取MySQL BLOB数据的性能问题及优化方法

针对大文件存储在MySQL LONGBLOB导致API响应缓慢的问题，可通过以下几个方向优化：

1. 改用流式读取，避免一次性加载全文件到内存 #

当前实体类用byte[]存储文件会将整个文件加载到JVM内存，大文件不仅占用大量内存，还会拖慢响应速度。建议改用Blob类型配合流式输出：

修改实体类 #

@Entity
@Table(name = "MY_DEVICE_DATA")
@Getter
@Setter
@NoArgsConstructor
@AllArgsConstructor
public class MyDeviceData {
    @Id
    private Long id;

    @Lob
    @Column(name = "FILE")
    private Blob file; // 替换byte[]为Blob类型

    @Column(name = "DEVICE_NAME")
    private String deviceName;

    @Column(name = "DEVICE_CODE")
    private String deviceCode;

    @Column(name= "FILE_NAME")
    private String fileName;
}

Controller流式返回文件 #

使用Spring的StreamingResponseBody实现边读边写，既避免内存溢出，又能提升响应速度：

@GetMapping("/download/{id}")
public ResponseEntity<StreamingResponseBody> downloadFile(@PathVariable Long id) throws SQLException {
    MyDeviceData data = myDeviceDataRepository.findById(id).orElseThrow();
    
    StreamingResponseBody responseBody = outputStream -> {
        try (InputStream inputStream = data.getFile().getBinaryStream()) {
            byte[] buffer = new byte[4096]; // 用4KB缓冲区分块读取
            int bytesRead;
            while ((bytesRead = inputStream.read(buffer)) != -1) {
                outputStream.write(buffer, 0, bytesRead);
                outputStream.flush();
            }
        }
    };

    return ResponseEntity.ok()
            .header(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=\"" + data.getFileName() + "\"")
            .contentType(MediaType.APPLICATION_OCTET_STREAM)
            .body(responseBody);
}

2. 开启MySQL游标式结果集，避免一次性加载全结果 #

默认JPA会将整个查询结果集加载到内存，针对大BLOB查询，可通过JPA查询提示开启流式游标：

在Repository方法添加查询提示 #

public interface MyDeviceDataRepository extends JpaRepository<MyDeviceData, Long> {
    @QueryHints({
        @QueryHint(name = org.hibernate.jpa.QueryHints.HINT_FETCH_SIZE, value = "" + Integer.MIN_VALUE),
        @QueryHint(name = org.hibernate.jpa.QueryHints.HINT_CACHEABLE, value = "false")
    })
    Optional<MyDeviceData> findById(Long id);
}

配置JDBC连接参数 #

在application.properties中添加MySQL连接参数，启用游标获取：

spring.datasource.url=jdbc:mysql://localhost:3306/your_db?useCursorFetch=true&useSSL=false&serverTimezone=UTC

3. 延迟加载BLOB字段，按需加载 #

如果业务中存在不需要读取文件内容的查询场景，可将BLOB字段设为懒加载，避免不必要的IO操作：

修改实体类字段的加载策略 #

@Lob
@Column(name = "FILE")
@Basic(fetch = FetchType.LAZY) // 仅当调用getFile()时才从数据库读取BLOB
private Blob file;

注意：懒加载需要在事务上下文中访问getFile()，可在Service层添加@Transactional注解：

@Service
public class MyDeviceDataService {
    @Autowired
    private MyDeviceDataRepository repository;

    @Transactional
    public MyDeviceData getWithFile(Long id) {
        MyDeviceData data = repository.findById(id).orElseThrow();
        // 触发懒加载：调用getFile()相关方法会在事务内读取BLOB
        data.getFile().length();
        return data;
    }
}

4. HTTP层面优化 #

• 启用分块编码：StreamingResponseBody默认会自动设置Transfer-Encoding: chunked，分块传输大文件，降低单次传输压力。
• 添加缓存头：如果文件不会频繁修改，可配置Cache-Control头让前端缓存文件，减少重复请求：

return ResponseEntity.ok()
        .header(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=\"" + data.getFileName() + "\"")
        .header(HttpHeaders.CACHE_CONTROL, "max-age=86400") // 缓存1天
        .contentType(MediaType.APPLICATION_OCTET_STREAM)
        .body(responseBody);

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