赞
踩
前两天系统出现系统宕机的问题,通过生成的hprof文件发现是系统在执行一个定时任务时,查询大量的数据导入内存,导致系统内存溢出了。为了避免一次性查询大量数据,需要改成分页查询的方法,在进行其他操作。进行大量数据分页查询操作如下:
- private void jobDetail() {
- long startTime = System.currentTimeMillis();
- logger.info("开始执行定时数据迁移到文件...");
- //查询需要迁移的总数量
- long count = historyDataService.getDataCount();
- //每次按1000条记录查询,计算需要查询的次数
- //double batchNum = Math.ceil(count / 1000);
- int batchNum = (int) Math.ceil((double) count/ 1000);
- logger.info("需要迁移的数据总数:{},查询分批:{}", count, batchNum + 1);
- //分批写入文件
- List<HistoryQuote> historyQuoteList;
- for (int i = 0; i <= batchNum; i++) {
- //查询历史数据,按照每次1000条记录查询
- historyQuoteList= historyDataService.getHistoryDataByPage(i + 1, 1000);
- //写入文件
- writeFile(historyQuoteList);
- logger.info("第{}批迁移近30天数据至文件中", i + 1);
- }
- //写入文件后,批量删除30天前的数据
- historyDataService.batchDeleteData(30);
- logger.info("执行定时迁移30天数据到文件中定时任务结束,耗时:{}ms", System.currentTimeMillis() - startTime);
- }
分页查询:
- public List<HistoryQuote> getHistoryDataByPage(int page, int size) {
- PageHelper.startPage(page > 1 ? page : 1, size > 0 ? size : 10, false);
- List<HistoryQuote> historyQuoteList = historyQuoteQueryMapper.getHistoryDataByPage();
- return historyQuoteList ;
- }
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。