@SpringBootTest

class QiniuDemoApplicationTests

{

    @Value("${qiniu.accessKey}")

    private String accessKey;

    @Value("${qiniu.secretKey}")

    private String secretKey;

    @Value("${qiniu.bucket}")

    private String bucket;

    @Value("${qiniu.path}")

    private String path;

    @Test

    void upload()

    {

        // 本地文件

        File file = new File("E:\\demo\\基础.mp4");

        // 获取文件后缀名

        String fileName = file.getName().substring(file.getName().lastIndexOf("."));

        // 实例带 Region.autoRegion () 的配置对象

        Configuration configuration = new Configuration(Region.autoRegion());

        // 指定分片上传的版本为 V2 版本

        configuration.resumableUploadAPIVersion = Configuration.ResumableUploadAPIVersion.V2;

        // 实例化上传对象并传入配置信息

        UploadManager uploadManager = new UploadManager(configuration);

        // 创建时间对象

        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        // 序列化当前时间

        String format = simpleDateFormat.format(new Date());

        // 通过 UUID + 当前时间 + 文件后缀名 创建出一个不容易碰撞的文件名

        String randomName = UUID.randomUUID().toString().replace("-", "") + format + fileName;

        // 将 access_key 和 secret_key 传入上传策略中

        Auth auth = Auth.create(accessKey, secretKey);

        // 上传时指定桶的名称

        String uploadToken = auth.uploadToken(bucket);

        try

        {

            // 上传分片文件，最后一个参数说明：true，断点续传，false，没有断点续传（默认）

            uploadManager.put(file, randomName, uploadToken, null, null, true);

        } catch (QiniuException e)

        {

            System.out.println("上传失败, 原因：" + e.getMessage());

        }

        System.out.println("上传路径：" + path + "/" + randomName);

    }

    @Test

    void download()

    {

    }

}

@Test

void download()

{

   // 要下载到的路径

   String loadPath = "E:\\";

   // 下载资源 url

   String downloadUrl = "http://saqvg00o7.hb-bkt.clouddn.com/0a79c8333bb94d768ebb2f6cac84aa482024-03-22%2019:42:18.mp4";

   // 获取文件的名称

   String substring = downloadUrl.substring(path.lastIndexOf("/") + 1);

   // 实例化 HttpClient 对象

   CloseableHttpClient httpClient = HttpClientBuilder.create().build();

   // 实例化请求对象传入请求 url

   HttpGet httpGet = new HttpGet(downloadUrl);

   CloseableHttpResponse response = null;

   InputStream content = null;

   FileOutputStream os = null;

   try

   {

      // 执行请求并返回响应对象

      response = httpClient.execute(httpGet);

      // 获取响应实体

      HttpEntity entity = response.getEntity();

      // 判断实体是否为空

      if (entity != null)

      {

         // 创建对应的目录 上面的文件名有 % : 这个是不允许的会创建文件 / 目录失败所以先进行转换下次上传时注意格式就行

         File file = new File(loadPath + substring.replace(":", "-").replace("%", "-"));

         // 通过 content 返回输入流对象

         content = entity.getContent();

         // 创建输出流写出文件数据到指定位置

         os = new FileOutputStream(file);

         int i = 0;

         byte[] bytes = new byte[1024];

         while (((i = content.read(bytes)) != -1))

         {

            os.write(bytes, 0, i);

         }

      }

   } catch (IOException e)

   {

      throw new RuntimeException(e);

   } finally

   {

      // 关闭流释放资源

      try

      {

         if (os != null)

         {

            os.close();

         }

         if (content != null)

         {

            content.close();

         }

      } catch (IOException e)

      {

         throw new RuntimeException(e);

      }

   }

}

@Test

void delete() {

   // 资源 url 这里就需要注意了，上面的文件名 带 %(是空格自转的) 带 - 的会导致删除部分成功 也就是会返回 298 状态码 然后 文件并没有删除 就是这样 我就把文件名改了才删除成功的

   String fileName = "http://saqvg00o7.hb-bkt.clouddn.com/0a7.mp4";

   // 获取文件名

   String substring = fileName.substring(path.lastIndexOf("/") + 1);

   System.out.println(substring);

   // 实例带 Region.autoRegion () 的配置对象

   Configuration configuration = new Configuration(Region.region0());

   // 将 access_key 和 secret_key 传入策略中

   Auth auth = Auth.create(accessKey, secretKey);

   // 实例化资源管理对象

   BucketManager bucketManager = new BucketManager(auth, configuration);

   // 批量请求文件数量不能超 1000

   BucketManager.BatchOperations batchOperations = new BucketManager.BatchOperations();

   // 批量删除

   batchOperations.addDeleteOp(bucket, substring);

   try

   {

      // 请求批量删除

      Response batch = bucketManager.batch(batchOperations);

      // 获取请求的状态码

      int statusCode = batch.statusCode;

      System.out.println(statusCode);

      // 判断状态码

      //todo 298 记 这一个被文件名坑的一次

      if(statusCode == 200)

      {

         System.out.println("删除成功");

      } else

      {

         System.out.println("删除失败");

      }

   } catch (QiniuException e)

   {

      throw new RuntimeException(e);

   }

}