讲师头像上传后端实现
作者:互联网
一 新建云存储微服务
1 创建模块
Artifact:service_oss
2 配置pom.xml
检查一下guli_parent中的aliyun-sdk-oss的版本,切换到3.8.0
<dependencies>
<!--aliyunOSS-->
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
</dependency>
</dependencies>
3 配置application.yml
server:
port: 8120 # 服务端口
spring:
profiles:
active: dev # 环境设置
application:
name: service-oss # 服务名
aliyun:
oss:
endpoint: <你的endpoint>
keyid: <你的keyid>
keysecret: <你的keysecret>
# bucket可以在控制台创建,也可以使用java代码创建,注意先测试bucket是否已被占用
bucketname: gulimall-cakin
4 logback-spring.xml
修改日志路径为 guli_log/oss
5 创建启动类
创建ServiceOssApplication.java
@SpringBootApplication
@ComponentScan({"com.atguigu.guli"})
public class ServiceOssApplication {
public static void main(String[] args) {
SpringApplication.run(ServiceOssApplication.class, args);
}
}
6 启动项目
测试项目初始化是否成功,报告如下错误
原因:jdbc依赖引入项目后,springboot的自动配置试图在配置文件中查找jdbc相关配置
解决方案:主类上添加注解exclude属性,禁用jdbc自动配置
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class) // 取消数据源自动配置
二 后端实现文件上传
1 从配置文件读取常量
创建常量读取工具类:OssProperties.java
@Data
@Component
@ConfigurationProperties(prefix = "aliyun.oss")
public class OssProperties {
private String endpoint;
private String keyid;
private String keysecret;
private String bucketname;
}
2 Service
public interface FileService {
/**
* 阿里云oss文件上传
* @param inputStream 输入流
* @param module 文件夹名称
* @param originalFilename 原始文件名
* @return 文件在oss服务器上的url地址
*/
String upload(InputStream inputStream, String module, String originalFilename);
}
3 实现类
@Service
public class FileServiceImpl implements FileService {
/**
* oss属性注入
*/
@Autowired
private OssProperties ossProperties;
@Override
public String upload(InputStream inputStream, String module, String originalFilename) {
//读取配置信息
String endpoint = ossProperties.getEndpoint();
String keyid = ossProperties.getKeyid();
String keysecret = ossProperties.getKeysecret();
String bucketname = ossProperties.getBucketname();
// 创建OSSClient实例
OSS ossClient = new OSSClientBuilder().build(endpoint, keyid, keysecret);
if(!ossClient.doesBucketExist(bucketname)){
ossClient.createBucket(bucketname);
ossClient.setBucketAcl(bucketname, CannedAccessControlList.PublicRead);
}
// 构建objectName:文件路径 avatar/2020/11/28/default.jpg
String folder = new DateTime().toString("yyyy/MM/dd");
String fileName = UUID.randomUUID().toString();
String fileExtension = originalFilename.substring(originalFilename.lastIndexOf("."));
String key = module +"/" + folder + "/" + fileName + fileExtension;
// 上传文件流
ossClient.putObject(bucketname, key, inputStream);
// 关闭OSSClient。
ossClient.shutdown();
// 返回url
//https://gulimall-cakin.oss-cn-chengdu.aliyuncs.com/avatar/default.jpg
return "https://" + bucketname + "." + endpoint + "/" + key;
}
}
4 控制器
@Api(description = "阿里云文件管理")
@CrossOrigin
@RestController
@RequestMapping("/admin/oss/file")
@Slf4j
public class FileController {
/**
* 文件上传服务
*/
@Autowired
private FileService fileService;
/**
* 功能描述:文件上传控制器
*
* @author cakin
* @date 2020/11/28
* @param file 文件
* @param module 文件夹
* @return R 返回给前端的数据
*/
@ApiOperation("文件上传")
@PostMapping("upload")
public R upload(@ApiParam(value = "文件", required = true) @RequestParam("file") MultipartFile file,
@ApiParam(value = "模块", required = true) @RequestParam("module") String module) {
try {
InputStream inputStream = file.getInputStream();
String originalFilename = file.getOriginalFilename();
String uploadUrl = fileService.upload(inputStream, module, originalFilename);
return R.ok().message("文件上传成功").data("url", uploadUrl);
} catch (Exception e) {
log.error(ExceptionUtils.getMessage(e));
throw new GuliException(ResultCodeEnum.FILE_UPLOAD_ERROR);
}
}
}
三 测试
标签:String,上传,oss,module,头像,bucketname,讲师,public,originalFilename 来源: https://blog.csdn.net/chengqiuming/article/details/110268829