private String accessKeyId; private www.laipuhuo.com.String accessKeySecret; private String bucketName...ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(bytes)); } catch (OSSException...null) { ossClient.shutdown(); } } //文件访问路径规则 www.laipuhuo.com.BucketName.Endpoint...StringBuilder stringBuilder = new StringBuilder("https://"); stringBuilder .append(bucketName
: weiz-test 上面的示例中,bucketName指的就是之前创建的MinIO桶Bucket。...bucketExists(bucketName)) { minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName...(GetBucketPolicyArgs .builder() .bucket(bucketName) ....public Optional getBucket(String bucketName) { return getAllBuckets().stream().filter...(b -> b.name().equals(bucketName)).findFirst(); } /** * 根据bucketName删除Bucket,true:删除成功;
, string prefix) { BucketName = bucketName; Prefix = prefix;...} /// /// 定义缓存关键字来缓存 /// /// <param name="<em>bucketName</em>.../// 定义缓存关键字来缓存 /// /// 缓存bucket /..., string prefix, short keyIndex) : base(<em>bucketName</em>, prefix, keyIndex) { }..., string prefix, short keyIndex1, short keyIndex2) : base(<em>bucketName</em>, prefix, keyIndex1,
client.bucketExists(bucketName)) { client.makeBucket(bucketName); } }...client.bucketExists(bucketName)) { client.makeBucket(bucketName); } }...bucketName) { return client.listBuckets().stream().filter(b -> b.name().equals(bucketName...)).findFirst(); } /** * 根据bucketName删除信息 * * @param bucketName bucket名称 */ @SneakyThrows...public void removeBucket(String bucketName) { client.removeBucket(bucketName);
存储桶名称 * @return */ @SneakyThrows public boolean bucketExists(String bucketName) {...*/ @SneakyThrows public void makeBucket(String bucketName) { if (!...bucketExists(bucketName)) { MakeBucketArgs.builder().bucket(bucketName).build();...(bucketName); if (!...ObjectStat statObject = statObject(bucketName, objectName); if (statObject !
makeBucket(String bucketName) { boolean flag = bucketExists(bucketName); if (!...(bucketName); if (!...try { bucketName = StringUtils.isNotBlank(bucketName) ?...bucketName) { minioService.makeBucket(bucketName); return "创建成功!!!"...(bucketName) == true ?
isExists) { minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build(...); // } /** * @param bucketName 桶名 * @Author: yinlei * @Description: 删除桶 *...@Date: * @Return void */ public void removeBucket(String bucketName) { try {...minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());..., String objectName) { try { // String url = minioClient.getObjectUrl(bucketName,
] * @return:void **/ public FileVo upload(MultipartFile file, String bucketName) {...try { createBucket(bucketName); String oldName = file.getOriginalFilename();..., fileName] * @return:void **/ public void download(String bucketName, String fileName)...).build()); } @SneakyThrows public void createBucket(String bucketName) { if (!...(MakeBucketArgs.builder().bucket(bucketName).build()); String sb = "{\"Version\": \"2012-
*/ void removeBucket(String bucketName); /** * 上传文件 * @param bucketName bucket...Integer expires); /** * 通过bucketName和objectName删除对象 * @param bucketName * @param...amazonS3.doesBucketExistV2(bucketName) ) { amazonS3.createBucket((bucketName)); }....deleteBucket(bucketName); } /** * 上传对象 * @param bucketName bucket名称 * @param...bucketName和prefix获取对象集合 * @param bucketName bucket名称 * @param prefix 前缀 * @param recursive
("/{bucketName}") public ResponseEntity deleteBucket(@PathVariable String bucketName)文件上传 @...PutMapping("/{bucketName}/**") public ResponseEntity putObject(@PathVariable String bucketName..., HttpServletRequest request)文件删除 @DeleteMapping("/{bucketName}/**") public ResponseEntity...deleteObject(@PathVariable String bucketName, HttpServletRequest request)文件下载 @GetMapping("/{bucketName...("/{bucketName}") public ResponseEntity listObjects(@PathVariable String bucketName, HttpServletRequest
private GridFSBucket getBucket(String bucketName) { return bucketCache.computeIfAbsent(bucketName..., ignore -> GridFSBuckets.create(db, bucketName)); } @Override public void afterPropertiesSet...桶名称 * @param day 日期偏移量,单位 天 */ public void deleteBefore(String bucketName, int day) {...", bucketName, objectId, e); } }); log.info("[GridFsManager] clean bucket...", bucketName, date, sw.stop()); } deleteBefore主要通过bucket.find(Filters.lt(“uploadDate”, date))找到
(MakeBucketArgs.builder().bucket(bucketName).build()); } } /** * 根据bucketName 获取信息...(b -> b.name().equals(bucketName)).findFirst(); } /** * 根据bucketName删除信息 * * @param...bucketName 桶名称 */ @SneakyThrows(Exception.class) public void removeBucket(String bucketName...(bucketName); } return minioClient.uploadObject(UploadObjectArgs.builder().bucket(bucketName...(bucketName)) { createBucket(bucketName); } String fileMinioName = "";
外网域名:.cos..tencentcos.cn内网域名:.cos-internal....静态网站域名 .cos-website....外网域名:.cos-website....静态网站域名.cos-website....外网域名:.cos-website.
}") public ResponseEntity createBucket(@PathVariable String bucketName) Bucket删除 @DeleteMapping...("/{bucketName}") public ResponseEntity deleteBucket(@PathVariable String bucketName) 文件上传 @PutMapping...("/{bucketName}/**") public ResponseEntity putObject(@PathVariable String bucketName, HttpServletRequest...String bucketName, HttpServletRequest request) 文件下载 @GetMapping("/{bucketName}/**") public void getObject...String bucketName, HttpServletRequest request, HttpServletResponse response) 文件列表 @GetMapping("/{bucketName
* @return */ public boolean bucketExists(String bucketName){ try {...(); } return false; } /** * 创建 bucket * @param bucketName */...(bucketName); if(!...isExist) { instance.makeBucket(bucketName); } } catch (Exception...objectName, InputStream stream){ try { instance.putObject(bucketName,objectName,
CreateBucketAsync Task CreateBucketAsync(string bucketName); 创建一个储存桶。...RemoveBucketAsync Task RemoveBucketAsync(string bucketName); 移除当前储存桶。...GetBucketAclAsync Task GetBucketAclAsync(string bucketName); 获取储存桶的外部访问权限。...RemoveObjectAsync Task RemoveObjectAsync(string bucketName, string objectName); 删除储存桶中指定对象。...Task RemoveObjectAsync(string bucketName, List objectNames); 删除储存桶中多个对象。
private GridFSBucket getBucket(String bucketName) { return bucketCache.computeIfAbsent(bucketName..., ignore -> GridFSBuckets.create(db, bucketName)); } @Override public void afterPropertiesSet...", bucketName, objectId, e); } }); log.info("[GridFsManager] clean bucket({}...,再挨个执行deleteexists public boolean exists(String bucketName, String fileName) { GridFSBucket...bucket = getBucket(bucketName); GridFSFindIterable files = bucket.find(Filters.eq("filename",
String bucketName = getBucketName(fileURL); // 解析objectName String objectName...= getObjectName(bucketName, fileURL); return s3client.getObject(bucketName, bucketName).getObjectMetadata...().getInstanceLength(); } 问题就处在 s3client.getObject(bucketName, bucketName).getObjectMetadata().getInstanceLength...String bucketName = getBucketName(fileURL); // 解析objectName String objectName...= getObjectName(bucketName, fileURL); return s3client.getObjectMetadata(bucketName, objectName
这个需要自己创建 2、启动成功后,访问:127.0.0.1:9000/minio,可以进入到minio的控制台 我们可以在控制台创建bucketName,当然也可以用代码创建 create bucket...其实这个bucketName就是文件夹的意思,我们要把文件上传到哪个bucketName,就是要把文件上传到对应的目录下。...}") private String bucketName; /** * description: 判断bucket是否存在,不存在则创建 * * @return...存储bucket名称 * @return Boolean */ public Boolean makeBucket(String bucketName) {...try { minioClient.makeBucket(MakeBucketArgs.builder() .bucket(bucketName
领取专属 10元无门槛券
手把手带您无忧上云