加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程开发 > Java > 正文

读取S3文件时“java.net.SocketException:Socket已关闭”

发布时间:2020-12-14 05:41:49 所属栏目:Java 来源:网络整理
导读:我正在尝试从S3读取csv文本文件,然后将其每个行发送到分布式队列以进行处理. 当试图读取它时,我得到“java.net.SocketException:Socket is closed”正在读取的文件的不同点的异常(在不同的执行中).这是代码: AmazonS3 s3 = new AmazonS3Client(new Propert
我正在尝试从S3读取csv文本文件,然后将其每个行发送到分布式队列以进行处理.

当试图读取它时,我得到“java.net.SocketException:Socket is closed”正在读取的文件的不同点的异常(在不同的执行中).这是代码:

AmazonS3 s3 = new AmazonS3Client(new PropertiesCredentials(MyClass.class.getResourceAsStream("myCredentials.properties")));

        String bucketName = "myBucket";
        String key = "myFile";  

        S3Object object = s3.getObject(new GetObjectRequest(bucketName,key));

        InputStream in = object.getObjectContent();

        BufferedReader readerS3 = new BufferedReader(new InputStreamReader(in,Charset.forName(fileInfo.getEncoding())));

        try {
            String line = null;
            while ((line = readerS3.readLine()) != null) {
                // Sending the line to a distributed queue
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                in.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

有关如何解决这个问题的任何想法?

更新:

从我第二次运行该方法时发生此异常,如果我停止整个程序并再次运行它,那么我第一次运行该方法就可以了.

解决方法

也许你应该在最后关闭readerS3而不是’in’.即关闭最外面的对象,它可以关闭它的包装儿童.

如果先关闭’in’,那么InputStreamReader和BufferedReader仍然是打开的,如果他们尝试对它们包装的对象做任何事情,它就会被关闭.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读