|
@@ -157,18 +157,19 @@ public class ObsService {
|
|
|
private void downloadToLocalFile(ObsClient obsClient, String localFilePath, String fileName) throws ObsException, IOException {
|
|
|
String key = objectKey + fileName;
|
|
|
ObsObject obsObject = obsClient.getObject(bucketName, key, null);
|
|
|
- ReadableByteChannel rchannel = Channels.newChannel(obsObject.getObjectContent());
|
|
|
-
|
|
|
- ByteBuffer buffer = ByteBuffer.allocate(4096);
|
|
|
- WritableByteChannel wchannel = Channels.newChannel(new FileOutputStream(new File(localFilePath + "/" + fileName)));
|
|
|
- System.out.println(localFilePath + "/" + fileName);
|
|
|
- while (rchannel.read(buffer) != -1) {
|
|
|
- buffer.flip();
|
|
|
- wchannel.write(buffer);
|
|
|
- buffer.clear();
|
|
|
+ if (!new File(localFilePath + "/" + fileName).exists()) {
|
|
|
+ ReadableByteChannel rchannel = Channels.newChannel(obsObject.getObjectContent());
|
|
|
+ ByteBuffer buffer = ByteBuffer.allocate(4096);
|
|
|
+ WritableByteChannel wchannel = Channels.newChannel(new FileOutputStream(new File(localFilePath + "/" + fileName)));
|
|
|
+ System.out.println(localFilePath + "/" + fileName);
|
|
|
+ while (rchannel.read(buffer) != -1) {
|
|
|
+ buffer.flip();
|
|
|
+ wchannel.write(buffer);
|
|
|
+ buffer.clear();
|
|
|
+ }
|
|
|
+ rchannel.close();
|
|
|
+ wchannel.close();
|
|
|
}
|
|
|
- rchannel.close();
|
|
|
- wchannel.close();
|
|
|
}
|
|
|
|
|
|
private File createSampleFile() throws IOException {
|