我正在尝试从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仍然是打开的,如果他们尝试对它们包装的对象做任何事情,它就会被关闭.