JUC高并发编程(二)之多线程下载支付宝对账文件

2021-12-25 11:34:24 阅读：313 来源： 互联网

标签：JUC int list 对账线程 executor 多线程 public size

1.背景

在实际开发中,经常会遇到支付需求,当然就会有支付对账的需求....

2.项目结构

3.代码

3.1.线程池配置对象

@Configuration
@EnableAsync
public class ExecutorConfig {
    /**
     * @return
     */
    @Bean
    public Executor asyncServiceExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //配置核心线程数
        executor.setCorePoolSize(30);
        //配置最大线程数
        executor.setMaxPoolSize(40);
        //配置队列大小
        executor.setQueueCapacity(99999);
        //配置线程池中的线程的名称前缀
        executor.setThreadNamePrefix("async-service-");
        // rejection-policy：当pool已经达到max size的时候，如何处理新任务
        // CALLER_RUNS：不在新线程中执行任务，而是有调用者所在的线程来执行
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //执行初始化
        executor.initialize();
        return executor;
    }
}

3.2.controller层代码

@RestController
public class BillController {
    @Autowired
    private IBillService billService;
    /**
     * 下载对账单
     *
     * @return
     */
    @RequestMapping("/api/downBill")
    public Object downBill() {
        Object result = billService.billDown();
        return "ok::" + result;
    }
}

3.3.业务层代码-下载

/**
 * @author 姿势帝-博客园
 * @address https://www.cnblogs.com/newAndHui/
 * @WeChat 851298348
 * @create 10/30 11:27
 * @description <p>
 * 以下载支付宝对账单为案例进行演示
 * 接口文档:https://opendocs.alipay.com/open/02ivbw
 * 关于支付支付课程可以查看:https://www.cnblogs.com/newAndHui/p/14258491.html
 * </p>
 */
@Service
@Slf4j
public class BillServiceImpl implements IBillService {
    @Autowired
    private IOrderService orderService;

    @Override
    public Object billDown() {
        // 以下载支付宝对账单为案例进行演示
        // 这里模拟一个对账文件
        ExcelReader reader = ExcelUtil.getReader(FileUtil.file("F:\\test\\t1.xlsx"));
        // 分页取值,每页10条
        boolean flag = true;
        int pageIndex = 1;
        int pageSize = 10;
        int sum = 0;
        while (flag) {
            int startIndex = pageSize * (pageIndex - 1) + 1;
            int endIndex = startIndex + pageSize - 1;
            List<Map<String, Object>> list = reader.read(0, startIndex, endIndex);
            int size = list.size();
            if (size > 0) {
                sum += size;
                // 异步保存数据
                orderService.saveBillOrder(list);
            }
            if (list.size() < pageSize) {
                flag = false;
            } else {
                pageIndex++;
            }
        }
        return "共:" + sum + "交易记录";
    }
}

3.4.业务层代码-保存

@Service
@Slf4j
public class IOrderServiceImpl implements IOrderService {
    @Override
    @Async("asyncServiceExecutor")
    public void saveBillOrder(List<Map<String, Object>> list) {
        int size = list.size();
        log.info("保存数据:" + size);
        int i = 1;
        for (Map<String, Object> bIllOrder : list) {
            log.info("保存第:" + i + "/" + size + ",bIllOrder=" + bIllOrder);
            // 模拟保存耗时(0到5秒)
            ThreadUtil.sleepRandom();
            i++;
            log.info("数据保存完成");
        }
    }
}

3.5.对账文件模板

4.测试

    @Test
    void downBill() {
        String url = "http://localhost:8001/api/downBill";
        HttpRequest request = HttpUtil.createGet(url);
        String response = request.execute().body();
        System.out.println(response);
    }

测试结果:

5.完美!

标签：JUC,int,list,对账,线程,executor,多线程,public,size
来源： https://www.cnblogs.com/newAndHui/p/15730081.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9