记一次多线程写入文件出现IOException：Stream Closed的问题

背景

网关在解析1000个05文件（txt）写入到SFTP文件时，是每次读取1000 * 5条数据，然后每1000笔数据创建一个线程逐条数据进行字段数值映射转换，一共创建5个线程扔到线程池进行处理。每条数据解析完都会将数据写入到SFTP的DAT文件，并且累加条数写入到CTL文件。

原来是1000笔数据才进行解析，每个文件造数据10条，导入没问题。为了方便测试，把条数调小到每次读取5 * 2 条数据，每个文件有10条数据，方便验证多线程读取有无问题。

问题来了：预期是DAT文件会写入10笔数据，CTL文件记录的条数增加10，但是每次解析写到几条就抛异常了：IOException：Stream Closed，有时候能写2条，有时候能写4条，有时候能写8条.......

分析

怀疑是不是因为改了网关的代码导致的，因为原来代码写死的1000，导入是没问题的，分析一波发现，原来每个文件只有10条数据，达不到1000，所以每次导入只会创建一个线程就处理完了，回检了一遍代码应该不是调小引发的问题；
改成每次只读取5 * 2条，一次读取就把文件10条数据读完了，但是还是出现报错；改成每次只读取1 * 2条数据，要读取10 / 2 = 5次，才能读完，也还是会报错；
是不是数据有问题呢？应该也不是，因为在配置1000的时候是能够把这10条数据正常写入的，打了断点也没发现write的时候写入的数据有啥问题为什么会出现有时候能够写入2条就挂了，有时候写到4条呢.....发现是由于debug断点打的位置导致多个线程执行的快慢不一致导致的，如果不是debug的话正常postman触发是每次写了2条就报错了。补充一下：读取到数据并不是马上就写入到文件中，而是将数据加到一个dataList中存放，达到1000笔才写入；还有一个写入时机，那就是执行完每个线程会调用flush（）方法，将dataList中的数据写入到txt
原来每个线程处理完只返回boolean，主线程使用Future<Boolean>接收，看不到具体报错信息，在线程run（）里面加了日志打印，也只能看到catch中的stream closed异常，看不到其他什么有效信息......
试试其他思路：百度了一下Stream Closed这个报错原因，如果一个文件流对象已经关闭过了在finally再重复关闭一次的话会报这个错，由此猜测是不是因为我在write的时候文件流对象就被关闭了呢？ debug断点打在写入前文件流对象那里，发现抛异常之前这个文件流对象一直都是正常的不为null，那为啥写入的时候会抛stream closed异常呢（有个误区：我一直以为closed了对象就会为null，后面才发现只是关闭只是跟句柄断开联系对象还不是null的）
为啥其他文件的导入也是调用的ConvertIn这个通用的文件解析没有问题，我调用这个就有问题了呢。查看了一下其他文件的导入代码，发现其他文件的导入每次读取完1000条数据之后，并不是写入到文件，而是调用了作业条进行发送就返回了，不存在我这种写入文件的场景，自然就不会出现stream Closed的问题
我这种场景跟导出的时候ConvertOut类似，读取文件数据之后再写入到txt中，对比了一个多线程里面的run（）方法，发现我每次处理完一批数据就调用数据源的close（）方法对文件流对象进行释放了，而导出的ConvertOut的话里面并没有closed文件对象，而是在处理完所有数据在finally才关闭文件流对象。每次创建线程的时候都将这个文件流对象传进去，导致有些线程在执行的时候将这个对象close了，其他线程在写的时候发现已经被关闭了，所以就报Stream Closed异常了
至此，终于发现问题所在了，修改一下代码每个线程处理完不马上关闭这个文件流对象，而是在主线程外面的finally统一关闭一次，这样就不会出现多线程写入的时候报Stream Closed异常了