OSS文件上传utils

痛定思痛。 2022-12-01 01:18 158阅读 0赞

package com.ddbuy.testController;
    
    import com.alibaba.dubbo.config.annotation.Reference;
    import com.aliyun.oss.OSS;
    import com.aliyun.oss.OSSClientBuilder;
    import com.aliyun.oss.model.ObjectMetadata;
    import com.ddbuy.conten.sevice.ConentService;
    import com.ddbuy.entity.TbContent;
    import com.ddbuy.utils.IdWorker;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.multipart.MultipartFile;
    
    import java.io.InputStream;
    
    /** * @Auther: Mr.zhou * @Date: 2020/8/20 14:03 */
    @Controller
    @RequestMapping("/content/")
    public class ConentController { 
        @Reference(interfaceClass = ConentService.class,check = false)
        private ConentService conentService;
        @Autowired(required = false)
        private IdWorker idWorker;
    
        @Value("${aliyun.oss.file.endpoint}")
        private String endpoint;
        @Value("${aliyun.oss.file.keyid}")
        private String keyid;
        @Value("${aliyun.oss.file.keysecret}")
        private String keysecret;
        @Value("${aliyun.oss.file.bucketname}")
        private String bucketname;
    
        @RequestMapping("addContent")
        public String addContent(@RequestParam(value = "contentpic") MultipartFile file, TbContent tbContent) { 
            // 获取上传文件名
            String filename = file.getOriginalFilename();
            System.out.println("所要上传的文件名：" + filename);
            // 创建唯一文件名覆盖原来要上传的文件名
            filename = idWorker.nextId() + filename.substring(filename.lastIndexOf("."));
            // 手动拼出阿里云上的文件路径
            String path = "http://" + bucketname + "." + endpoint + "/" + filename;
            tbContent.setPic(path);
            try { 
                // 获取文件流
                InputStream inputStream = file.getInputStream();
                // 直接设置 content_type 解决直接下载无法预览效果
                ObjectMetadata objectMetadata = new ObjectMetadata();
                objectMetadata.setContentType("image/jpg");
                // 上传文件到OSS服务器，创建OSSClient实例
                OSS client = new OSSClientBuilder().build(endpoint, keyid, keysecret);
                // 上传文件流
                client.putObject(bucketname, filename, inputStream,objectMetadata);
                System.out.println(path);
                conentService.addContent(tbContent);
                // 关闭资源
                client.shutdown();
            } catch (Exception e) { 
                e.printStackTrace();
                System.out.println("上传失败");
                return "redirect:/jsp/erro.jsp";
            }
            System.out.println("上传成功");
            return "redirect:/jsp/developer/addContent.jsp";
        }
    }