华为云对象存储连接测试

华为云
对象存储服务 OBS

//<!--        华为云-->
//<dependency>
//<groupId>com.huaweicloud</groupId>
//<artifactId>esdk-obs-java</artifactId>
//<version>[3.21.4,)</version>
//</dependency>

server

package test;import com.obs.services.ObsClient;
import com.obs.services.exception.ObsException;
import com.obs.services.model.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;import javax.annotation.PostConstruct;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.util.Date;@Service
public class HuaweiServer {public  ObsClient obsClient;@Value("${hw.accessKey}")private String accessKey;@Value("${hw.secretKey}")private String secretKey;@Value("${hw.endPoint}")private String endPoint;@Value("${hw.bucketName}")private String bucketName;
//    @Value("${s3.donwloadpath}")
//    private String filepath;@PostConstructprivate void init(){obsClient = new ObsClient(accessKey, secretKey, endPoint);obsClient.createBucket(bucketName,"cn-south-1");}public  void upload(String objectKey, String fileparent){File list=new File(fileparent);for(File file:list.listFiles()){if(!file.getName().endsWith(".zip")){continue;}FileInputStream fis;try {fis = new FileInputStream(file);} catch (FileNotFoundException e) {e.printStackTrace();return;}System.out.println(">>>> start upload file <<<< time:"+ new Date() + " ,文件名：" + objectKey + " ,文件大小：" + file.length() / (1024 * 1024));obsClient.putObject(bucketName, objectKey, fis);PutObjectRequest request = new PutObjectRequest(bucketName, objectKey);request.setFile(file);request.setProgressListener(new ProgressListener() {@Overridepublic void progressChanged(ProgressStatus status) {// 获取上传平均速率System.out.println("AverageSpeed:" + status.getAverageSpeed());// 获取上传进度百分比System.out.println("TransferPercentage:" + status.getTransferPercentage());}});// 每上传1MB数据反馈上传进度request.setProgressInterval(20*1024 * 1024L);System.out.println(">>>> end upload file <<<< time:"+ new Date());obsClient.putObject(request);}}public void download(String objectKey) {// 创建ObsClient实例ObsClient obsClient = new ObsClient(accessKey, secretKey, endPoint);DownloadFileRequest request = new DownloadFileRequest(bucketName, objectKey);
// 设置下载对象的本地文件路径request.setDownloadFile("localfile");
// 设置分段下载时的最大并发数request.setTaskNum(5);
// 设置分段大小为10MBrequest.setPartSize(10 * 1024 * 1024);
// 开启断点续传模式request.setEnableCheckpoint(true);request.setProgressListener(new ProgressListener() {@Overridepublic void progressChanged(ProgressStatus status) {// 获取下载平均速率System.out.println("AverageSpeed:" + status.getAverageSpeed());// 获取下载进度百分比System.out.println("TransferPercentage:" + status.getTransferPercentage());}});
// 每下载1MB数据反馈下载进度request.setProgressInterval(20*1024 * 1024L);try{// 进行断点续传下载DownloadFileResult result = obsClient.downloadFile(request);}catch (ObsException e) {// 发生异常时可再次调用断点续传下载接口进行重新下载}}
}

controller

package test;import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;import java.io.File;@Api(value = "HuaWeiCloud", tags = "华为云测试")
@RestController
@RequestMapping("/test")
public class TestConller {@Value("${hw.uploadpath}")private String uploadpath;@Autowiredprivate HuaweiServer huaweiServer;@ApiOperation(value = "华为云上传", notes = "")@RequestMapping(value = "/upload", method = RequestMethod.GET)public void upload (@RequestParam String path){File file = new File(path);String name= file.getName();huaweiServer.upload(name,file.getParentFile().getAbsolutePath());}@ApiOperation(value = "华为云下载", notes = "")@RequestMapping(value = "/download", method = RequestMethod.GET)public void download (@RequestParam String name){huaweiServer.download(name);}
}

华为云对象存储连接测试相关推荐

华为云对象存储OBS，为不同企业提供云存储方案，助力企业更好经营
我们正处于一个信息爆炸的时代,不管是日常通讯还是看视频玩游戏,只要是和网络相关的服务,就离不开数据的存储和读取,对于企业来说也是如此.企业的生产经营需要大量的数据支持,因此企业对于数据存储的要求也很高 ...
华为云对象存储服务OBS教你一招轻松解决存储难题
身处于信息爆炸的时代,各种各样的数据琳琅满目,需要记录存储的资料和信息数不胜数,有时候个人都会感觉到存储空间不足,更何况是一些正处于发展阶段中小型企业?那对于存储的需求就更迫切了. 遇见这种问题,很多 ...
uniapp vue 微信小程序前端直传华为云对象存储OBS
前言: 因项目服务器性能需要需要前端直传华为云对象存储绕过后端个人在华为云官网SDK文档研究分享出来避免大家踩坑报错定位 web端报 Error: Network Error 高频问 ...
华为云对象存储浏览器直接打开，而不是下载
基于安全合规要求,华为云对象存储服务OBS禁止通过OBS的默认域名(桶访问域名或静态网站访问域名)在线预览桶内对象,即使用上述域名从浏览器访问桶内对象(如视频.图片.网页等)时,不会显示对象内容,而是 ...
华为云对象存储OBS，助力企业降本增效
信息化时代,互联网信息技术在企业发展中扮演着越来越重要的角色,对于网络信息数据的依赖程度也在不断提高.企业可以通过使用计算机进行信息管理,将各种资源有效利用起来.但是每天产生的大量数据信息,需要花费很 ...
华为云对象存储服务OBS，海量存储安全可靠，让云存储更加简单
随着产业数字化转型大潮的到来,企业生产经营过程中产生的数据也越来越多,不管是大型企业还是小微企业对数据存储备份的要求也越来越高,有的企业选择自购硬件设备进行存储,一方面需要付出高昂的成本,另一方面如果 ...
commvault备份mysql_CommVault备份到华为云对象存储实践
本文来自客户使用CommVault备份软件备份到华为云对象存储的实践.使用CommVault备份软件的可以参考.备份到华为云的优势:公有云可以天生充当客户的异地备份中心,省去客户自建异地备份中心的成本 ...
华为云对象存储OBS，安全可靠的云存储服务，让企业轻松上云
随着时代的不断发展,不管是个人还是企业对数据的存储要求也越来越高,对于普通人来说,我们可以把文件.视频.图片等等存储到电脑.手机或者U盘等硬件设备中,但对于企业来说,庞大的数据量必须依靠专业的存储设备 ...
海量、安全、高可靠的华为云对象存储服务OBS，助力企业数据存储降本提效
在信息化.数字化时代,企业的数据量日渐增长,对存储的需求也在不断变化,企业自建存储服务器受限于搭建存储服务器时使用的硬件设备,如果存储量不够,需重新购买存储硬盘,进行人工扩容,而且人力物力成本较高,为 ...

华为云对象存储连接测试

华为云对象存储连接测试相关推荐

最新文章

热门文章