一、前言
今天小編帶大家一起整合一下easyExcel?，之所以用這個，是因為easyExcel?性能比較好，不會報OOM！
市面上常見的導入導出Excel分為三種：
hutool和easyExcel?都是對poi?的封裝，使用起來更加方便！
二、導入依賴
小編這里是3.0.X版本的，版本不同可能導致部分有出入，如果大家版本是3.1.X，可以去官方文檔看看有不一樣的！
官方文檔：https://easyexcel.opensource.alibaba.com/
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>easyexcel</artifactId>
<version>3.0.5</version>
</dependency>
三、實體類
這里可以自帶的轉換器：
- @DateTimeFormat("yyyy年MM月dd日HH時mm分ss秒")
- LocalDateTimeStringConverter
或者自定義轉化器：實現：implements Converter<T>。
具體文檔：官方文檔：https://easyexcel.opensource.alibaba.com/docs/3.0.x/quickstart/read#%E6%97%A5%E6%9C%9F%E6%95%B0%E5%AD%97%E6%88%96%E8%80%85%E8%87%AA%E5%AE%9A%E4%B9%89%E6%A0%BC%E5%BC%8F%E8%BD%AC%E6%8D%A2
@ExcelProperty參數注意：
這里不建議 index 和 name 同時用，要么一個對象只用index，要么一個對象只用name去匹配。
用名字去匹配，這里需要注意，如果名字重復，會導致只有一個字段讀取到數據。
/**
* @author wangzhenjun
* @date 2022/12/2 15:52
*/
@Data
public class Test {
@TableId
private Integer id;
@ExcelProperty(index = 0)
private String name;
@ExcelProperty(index = 1)
private Integer age;
@ExcelProperty(index = 2,converter = LocalDateTimeStringConverter.class)
private LocalDateTime time;
}
四、編寫監聽器
注意點：這個監聽器一定不要是單例的，被spring管理默認為單例，如果要使用?@Component?，一定要加上：@Scope("prototype")?，這樣在創建完后spring不會進行管理，每次都會是新bean！不加?@Component?在導入時要進行new ImportDataListener！小編這里不想new了直接這樣寫！！如果不想這樣，可以使用構造器set進行使用！BATCH_COUNT?：數據閾值，超過了就會清理list，在之前可以進行保存到數據庫中，方便內存回收，防治OOM！這里保存到數據庫中一般使用?批量保存，不要解析到一行就去保存數據庫中，這樣數據量大會給數據庫增加IO，導致掛掉！這里小編使用ServiceImpl的saveBatch()方法，也可以自己寫一下，像小編這樣寫，會出現循環依賴，加上@Lazy就行！
/**
* @author wangzhenjun
* @date 2022/12/2 15:38
*/
@Slf4j
@Component
// 每次bean都是新的，不要單例
@Scope("prototype")
public class ImportDataListener implements ReadListener<Test> {
@Autowired
@Lazy
private TestService testService;
/**
* 每隔5條存儲數據庫，實際使用中可以100條，然后清理list ，方便內存回收
*/
private static final int BATCH_COUNT = 100;
/**
* 緩存的數據
*/
private List<Test> importExcelDataList = ListUtils.newArrayListWithExpectedSize(BATCH_COUNT);
/**
* 這個每一條數據解析都會來調用
*
* @param data one row value. Is is same as {@link AnalysisContext#readRowHolder()}
* @param context
*/
@Override
public void invoke(Test data, AnalysisContext context) {
log.info("解析到一條數據:{}", JSON.toJSONString(data));
importExcelDataList.add(data);
// 達到BATCH_COUNT了，需要去存儲一次數據庫，防止數據幾萬條數據在內存，容易OOM
if (importExcelDataList.size() >= BATCH_COUNT) {
saveData();
// 存儲完成清理 list
importExcelDataList = ListUtils.newArrayListWithExpectedSize(BATCH_COUNT);
}
}
/**
* 所有數據解析完成了 都會來調用
*
* @param context
*/
@Override
public void doAfterAllAnalysed(AnalysisContext context) {
// 這里也要保存數據，確保最后遺留的數據也存儲到數據庫
saveData();
log.info("所有數據解析完成！");
}
/**
* 加上存儲數據庫
*/
private void saveData() {
log.info("{}條數據，開始存儲數據庫！", importExcelDataList.size());
testService.saveBatch(importExcelDataList);
log.info("存儲數據庫成功！");
}
}
五、Controller
/**
* @author wangzhenjun
* @date 2022/10/26 16:51
*/
@Slf4j
@RestController
@RequestMapping("/test")
public class TestController {
@Autowired
private TestService testService;
@PostMapping("/import")
public Result importExcel(@RequestBody MultipartFile multipartFile){
testService.importExcel(multipartFile);
return Result.success("ok");
}
}
六、Service
/**
* @author wangzhenjun
* @date 2022/10/26 16:55
*/
public interface TestService extends IService<Test> {
void importExcel(MultipartFile multipartFile);
}
七、ServiceImpl
/**
* @author wangzhenjun
* @date 2022/10/26 16:56
*/
@Service
public class TestServiceImpl extends ServiceImpl<TestDbMapper, Test> implements TestService{
@Autowired
private ImportDataListener importDataListener;
@SneakyThrows
@Override
public void importExcel(MultipartFile multipartFile) {
InputStream inputStream = multipartFile.getInputStream();
// 這里 需要指定讀用哪個class去讀，然后讀取第一個sheet 文件流會自動關閉
EasyExcel.read(inputStream, Test.class, importDataListener).sheet().doRead();
}
}
八、Mapper
/**
* @author wangzhenjun
* @date 2022/10/26 17:07
*/
public interface TestDbMapper extends BaseMapper<Test> {
}
九、測試
準備Excel數據：
postman上傳：
控制臺打印：
數據庫查看：
完美搞定！！
十、總結
這樣就完成了easyExcel批量導入Excel到數據庫，還是有很多要注意的點：
- 自定義轉換器
- 監聽器不要單例
- 保存數據庫采用批量
- 版本差距
