SpringBoot2.x系列教程24--SpringBoot实现文件上传到OSS阿里云存储

packagecom.yyg.boot.config;
importlombok.Data;
importlombok.Getter;
importlombok.Setter;
importorg.springframework.beans.factory.annotation.Value;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.stereotype.Component;
/*** 把配置文件中的配置信息读取到该类中.*/@Data@ConfigurationpublicclassOssConfiguration {
@Value("${endpoint}")
privateStringendPoint;
@Value("${accessKeyId}")
privateStringaccessKeyId;
@Value("${accessKeySecret}")
privateStringaccessKeySecret;
@Value("${filehost}")
privateStringfileHost;
@Value("${bucketName}")
privateStringbucketName;
}

packagecom.yyg.boot.util;
importcom.aliyun.oss.OSSClient;
importcom.aliyun.oss.model.CannedAccessControlList;
importcom.aliyun.oss.model.CreateBucketRequest;
importcom.aliyun.oss.model.PutObjectRequest;
importcom.aliyun.oss.model.PutObjectResult;
importcom.yyg.boot.config.OssConfiguration;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.stereotype.Component;
importjava.io.File;
importjava.text.SimpleDateFormat;
importjava.util.Date;
importjava.util.UUID;
/*** 封装文件上传方法*/@ComponentpublicclassAliyunOssUtil {
@AutowiredprivateOssConfigurationconfig;
publicStringupload(Filefile) {
if (file==null) {
returnnull;
        }
StringendPoint=config.getEndPoint();
StringkeyId=config.getAccessKeyId();
StringkeySecret=config.getAccessKeySecret();
StringbucketName=config.getBucketName();
StringfileHost=config.getFileHost();
//定义子文件的格式SimpleDateFormatformat=newSimpleDateFormat("yyyy-MM-dd");
StringdateStr=format.format(newDate());
//阿里云文件上传客户端OSSClientclient=newOSSClient(endPoint, keyId, keySecret);
try {
//判断桶是否存在if (!client.doesBucketExist(bucketName)) {
//创建桶client.createBucket(bucketName);
CreateBucketRequestcreateBucketRequest=newCreateBucketRequest(bucketName);
//设置访问权限为公共读createBucketRequest.setCannedACL(CannedAccessControlList.PublicRead);
//发起创建桶的请求client.createBucket(createBucketRequest);
            }
//当桶存在时,进行文件上传//设置文件路径和名称StringfileUrl=fileHost+"/"+ (dateStr+"/"+UUID.randomUUID().toString().replace("-", "") +"-"+file.getName());
PutObjectResultresult=client.putObject(newPutObjectRequest(bucketName, fileUrl, file));
client.setBucketAcl(bucketName, CannedAccessControlList.PublicRead);
//文件上传成功后,返回当前文件的路径if (result!=null) {
returnfileUrl;
            }
        } catch (Exceptione) {
e.printStackTrace();
        } finally {
if (client!=null) {
client.shutdown();
            }
        }
returnnull;
    }
}

packagecom.yyg.boot.web;
importcom.yyg.boot.util.AliyunOssUtil;
importlombok.extern.slf4j.Slf4j;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.stereotype.Controller;
importorg.springframework.web.bind.annotation.GetMapping;
importorg.springframework.web.bind.annotation.PostMapping;
importorg.springframework.web.bind.annotation.RequestParam;
importorg.springframework.web.multipart.MultipartFile;
importjava.io.File;
importjava.io.FileOutputStream;
@ControllerpublicclassOssController {
@AutowiredprivateAliyunOssUtilossUtil;
@GetMapping("/")
publicStringshowUploadFile() {
return"upLoad";
    }
@PostMapping("/uploadFile")
publicStringupload(@RequestParam("file") MultipartFilefile) {
try {
if (file!=null) {
StringfileName=file.getOriginalFilename();
if (!"".equals(fileName.trim())) {
FilenewFile=newFile(fileName);
FileOutputStreamos=newFileOutputStream(newFile);
os.write(file.getBytes());
os.close();
//把file里的内容复制到奥newFile中file.transferTo(newFile);
Stringupload=ossUtil.upload(newFile);
//图片回显地址://http://yiyige.oss-cn-hangzhou.aliyuncs.com/images/2019-10-21/6c964702b67d4eeb920e7f1f4358189b-dishu.jpgSystem.out.println("path="+upload);
                }
            }
        } catch (Exceptione) {
e.printStackTrace();
        }
return"success";
    }
}

packagecom.yyg.boot;
importorg.springframework.boot.SpringApplication;
importorg.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplicationpublicclassOssApplication {
publicstaticvoidmain(String[] args) {
SpringApplication.run(OssApplication.class, args);
    }
}