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

前端之家收集整理的这篇文章主要介绍了读取S3文件时“java.net.SocketException:Socket已关闭”前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
我正在尝试从S3读取csv文本文件,然后将其每个行发送到分布式队列以进行处理.

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

  1. AmazonS3 s3 = new AmazonS3Client(new PropertiesCredentials(MyClass.class.getResourceAsStream("myCredentials.properties")));
  2.  
  3. String bucketName = "myBucket";
  4. String key = "myFile";
  5.  
  6. S3Object object = s3.getObject(new GetObjectRequest(bucketName,key));
  7.  
  8. InputStream in = object.getObjectContent();
  9.  
  10. BufferedReader readerS3 = new BufferedReader(new InputStreamReader(in,Charset.forName(fileInfo.getEncoding())));
  11.  
  12. try {
  13. String line = null;
  14. while ((line = readerS3.readLine()) != null) {
  15. // Sending the line to a distributed queue
  16. }
  17. } catch (IOException e) {
  18. e.printStackTrace();
  19. }finally {
  20. try {
  21. in.close();
  22. } catch (IOException e) {
  23. e.printStackTrace();
  24. }
  25. }

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

更新:

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

解决方法

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

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

猜你在找的Java相关文章