forked from uav/ard-uav-server
blame | history | patch | commit | commitdiff | show whitespace
Xiajijian
2025-11-10 c42829d221533c790799c008f9dd297708335c30 
 ard-oss/src/main/java/com/ard/oss/service/impl/MinIOServiceImpl.java


@@ -127,7 +127,10 @@


    @Override


    public Boolean deleteObject(String bucket, String objectKey) {


        try {


            client.removeObject(RemoveObjectArgs.builder().bucket(bucket).object(objectKey).build());


            client.removeObject(RemoveObjectArgs.builder()


                    .bucket(bucket)


                    .object(objectKey)


                    .build());


        } catch (MinioException | NoSuchAlgorithmException | IOException | InvalidKeyException e) {


            log.error("Failed to delete file.");


            e.printStackTrace();


@@ -139,7 +142,10 @@


    @Override


    public InputStream getObject(String bucket, String objectKey) {


        try {


            GetObjectResponse object = client.getObject(GetObjectArgs.builder().bucket(bucket).object(objectKey).build());


            GetObjectResponse object = client.getObject(GetObjectArgs.builder()


                    .bucket(bucket)


                    .object(objectKey)


                    .build());


            return new ByteArrayInputStream(object.readAllBytes());


        } catch (ErrorResponseException | InsufficientDataException | InternalException | InvalidKeyException | InvalidResponseException | IOException | NoSuchAlgorithmException | ServerException | XmlParserException e) {


            e.printStackTrace();


@@ -150,7 +156,10 @@


    @Override


    public void putObject(String bucket, String objectKey, InputStream input) {


        try {


            client.statObject(StatObjectArgs.builder().bucket(bucket).object(objectKey).build());


            client.statObject(StatObjectArgs.builder()


                    .bucket(bucket)


                    .object(objectKey)


                    .build());


            throw new RuntimeException("The filename already exists.");


        } catch (MinioException | InvalidKeyException | IOException | NoSuchAlgorithmException e) {


            log.info("The file does not exist, start uploading.");


@@ -158,7 +167,11 @@


                // 设置 partSize 为 10MB


                long partSize = 10 * 1024 * 1024;


                ObjectWriteResponse response = client.putObject(


                        PutObjectArgs.builder().bucket(bucket).object(objectKey).stream(input, -1, partSize).build());


                        PutObjectArgs.builder()


                                .bucket(bucket)


                                .object(objectKey)


                                .stream(input, -1, partSize)


                                .build());


                log.info("Upload File: {}", response.etag());


            } catch (MinioException | IOException | InvalidKeyException | NoSuchAlgorithmException ex) {


                log.error("Failed to upload File {}.", objectKey);


@@ -170,7 +183,10 @@


    public void putObject(String bucket, String objectKey, InputStream input, String contentType) {


        try {


            // 检查文件是否已经存在


            client.statObject(StatObjectArgs.builder().bucket(bucket).object(objectKey).build());


            client.statObject(StatObjectArgs.builder()


                    .bucket(bucket)


                    .object(objectKey)


                    .build());


            throw new RuntimeException("The file already exists: " + objectKey);


        } catch (ErrorResponseException e) {


            // 如果文件不存在，则继续上传