| | |
|---|
| | | package com.stylefeng.guns.modular.api; |
|---|
| | | |
|---|
| | | import com.aliyun.oss.OSS; |
|---|
| | | import com.aliyun.oss.OSSClient; |
|---|
| | | import com.aliyun.oss.OSSClientBuilder; |
|---|
| | | import com.aliyun.oss.model.OSSObject; |
|---|
| | | import com.aliyun.oss.model.ObjectMetadata; |
|---|
| | | import com.aliyun.oss.model.PutObjectRequest; |
|---|
| | | import com.aliyun.oss.model.PutObjectResult; |
|---|
| | | import com.stylefeng.guns.modular.file.OSSService; |
|---|
| | | import io.swagger.annotations.ApiOperation; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.http.ResponseEntity; |
|---|
| | | import org.springframework.util.StreamUtils; |
|---|
| | | import org.springframework.web.bind.annotation.*; |
|---|
| | | import org.springframework.web.multipart.MultipartFile; |
|---|
| | | |
|---|
| | | import javax.servlet.http.HttpServletResponse; |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.io.InputStream; |
|---|
| | | |
|---|
| | | @RestController |
|---|
| | | @RequestMapping("") |
|---|
| | | public class FileController { |
|---|
| | | private static final String endpoint = "oss-cn-hongkong.aliyuncs.com"; |
|---|
| | | private static final String accessKeyId = "LTAI5tQZzqsZYX5gw8yRNchQ"; |
|---|
| | | private static final String accessKeySecret = "5yJVdXwRzwPZwKKXp07lRAc7tkTxQp"; |
|---|
| | | private static final String bucketName = "bizuphk"; |
|---|
| | | @PostMapping("/base/files/upload") |
|---|
| | | @ApiOperation(value = "文件上传", tags = {"文件上传"}) |
|---|
| | | public String uploadFile(@RequestParam("file") MultipartFile file) throws IOException { |
|---|
| | | // 获取原始文件名 |
|---|
| | | String originalFilename = file.getOriginalFilename(); |
|---|
| | | // 提取文件后缀 |
|---|
| | | if (originalFilename != null && originalFilename.contains(".")) { |
|---|
| | | System.err.println(originalFilename.substring(originalFilename.lastIndexOf("."))); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 创建 OSSClient 实例 |
|---|
| | | OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret); |
|---|
| | | long l = System.currentTimeMillis(); |
|---|
| | | // 创建 PutObjectRequest 对象 |
|---|
| | | PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, String.valueOf(l)+"."+originalFilename.substring(originalFilename.lastIndexOf(".") + 1), file.getInputStream()); |
|---|
| | | ObjectMetadata metadata = new ObjectMetadata(); |
|---|
| | | // 取消文件缓存，文件每次都会从OSS服务器获取 |
|---|
| | | metadata.setHeader("Cache-Control", "no-cache"); |
|---|
| | | metadata.setHeader("Expires", "0"); |
|---|
| | | // 上传文件 |
|---|
| | | PutObjectResult putObjectResult = ossClient.putObject(putObjectRequest); |
|---|
| | | // 关闭 OSSClient 实例 |
|---|
| | | ossClient.shutdown(); |
|---|
| | | String fileUrl = "https://" + bucketName + "." + |
|---|
| | | endpoint + "/" |
|---|
| | | + String.valueOf(l) |
|---|
| | | +"."+originalFilename.substring(originalFilename.lastIndexOf(".")+ 1); |
|---|
| | | return fileUrl; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // @ApiOperation(value = "服务端上传", notes = "服务端上传") |
|---|
| | | // @PostMapping(value = "upload") |
|---|
| | | // public String fileUpload(@RequestParam(value = "file") MultipartFile file) throws IOException { |
|---|
| | | // InputStream inputStream = file.getInputStream(); |
|---|
| | | // String filename = System.currentTimeMillis() + file.getOriginalFilename(); |
|---|
| | | // // Endpoint以杭州为例，其它Region请按实际情况填写。 |
|---|
| | | // final String endpoint = "oss-cn-hongkong.aliyuncs.com"; |
|---|
| | | // // 阿里云主账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维，请登录RAM控制台创建RAM账号。 |
|---|
| | | // final String accessKeyId = "LTAI5tQZzqsZYX5gw8yRNchQ"; |
|---|
| | | // final String accessKeySecret = "5yJVdXwRzwPZwKKXp07lRAc7tkTxQp"; |
|---|
| | | // final String bucketName = "bizuphk"; |
|---|
| | | // // <yourObjectName>上传文件到OSS时需要指定包含文件后缀在内的完整路径，例如abc/efg/123.jpg。 |
|---|
| | | // String objectName = AliOss.dir + filename; |
|---|
| | | // // 创建OSSClient实例。 |
|---|
| | | // OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); |
|---|
| | | // // 填写本地文件的完整路径。如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。 |
|---|
| | | // // InputStream inputStream = new FileInputStream("D:\\localpath\\examplefile.txt"); |
|---|
| | | // // 依次填写Bucket名称（例如examplebucket）和Object完整路径（例如exampledir/exampleobject.txt）。Object完整路径中不能包含Bucket名称。 |
|---|
| | | // PutObjectResult putObjectResult = ossClient.putObject(bucketName, objectName, inputStream); |
|---|
| | | // OSSObject ossObject = ossClient.getObject(bucketName, objectName); |
|---|
| | | // String uri = ossObject.getResponse().getUri(); |
|---|
| | | // // 关闭OSSClient。 |
|---|
| | | // ossClient.shutdown(); |
|---|
| | | // uri = uri.replace("http://nn-bucket.oss-cn-shanghai.aliyuncs.com",FILE_CDN); |
|---|
| | | // return uri; |
|---|
| | | // } |
|---|
| | | // @GetMapping("/base/files/download/{fileName}") |
|---|
| | | // @ApiOperation(value = "文件下载", tags = {"文件下载"}) |
|---|
| | | // public void downloadFile(@PathVariable("fileName") String fileName, HttpServletResponse response) { |
|---|
| | | // InputStream inputStream = ossService.downloadFile(fileName); |
|---|
| | | // if (inputStream != null) { |
|---|
| | | // try { |
|---|
| | | // StreamUtils.copy(inputStream, response.getOutputStream()); |
|---|
| | | // response.setContentType("application/octet-stream"); |
|---|
| | | // response.flushBuffer(); |
|---|
| | | // } catch (IOException e) { |
|---|
| | | // // 处理下载失败的逻辑 |
|---|
| | | // } |
|---|
| | | // } else { |
|---|
| | | // // 处理文件不存在的逻辑 |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | } |
|---|
