讲师头像上传后端实现

╰+哭是因爲堅強的太久メ 2021-07-24 16:57 548阅读 0赞

# 一 新建云存储微服务 #

## 1 创建模块 ##

Artifact：service\_oss

## 2 配置pom.xml ##

检查一下guli\_parent中的aliyun-sdk-oss的版本，切换到3.8.0

<dependencies>
        
        <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 启动项目 ##

测试项目初始化是否成功，报告如下错误

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70][]

原因：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);
            }
        }
    }

# 三 测试 #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1][]

![20201128135738481.png][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70]: /images/20210724/81a71ab85c674ec2a2f07af5963399b5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1]: /images/20210724/676351fbef6d443b81d89dc20700e0da.png
[20201128135738481.png]: /images/20210724/1d6e122dbf4b403284e2226124188cf5.png