springboot s3文件存储

### Spring Boot 集成 AWS S3 进行文件上传和管理 #### 创建 Spring Boot 应用程序 为了实现 Spring Boot 与 AWS S3 的集成，在 `cn.juwatech` 包下创建名为 `AwsS3IntegrationApp` 类作为应用程序入口点[^1]。 ```java package cn.juwatech; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class AwsS3IntegrationApp { public static void main(String[] args) { SpringApplication.run(AwsS3IntegrationApp.class, args); } } ``` #### 添加依赖项 在项目的 `pom.xml` 文件中加入必要的 Maven 依赖，以便能够使用 Amazon Web Services (AWS) 软件开发工具包(SDK)[^2]： ```xml <dependency> <groupId>com.amazonaws</groupId> <artifactId>aws-java-sdk-s3</artifactId> <version>${aws.version}</version> </dependency> <!-- 如果需要支持本地测试 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-aws</artifactId> </dependency> ``` #### 配置 AWS 凭证和服务端点 确保已配置好环境变量或通过其他方式提供有效的 AWS 访问密钥 ID 和秘密访问密钥。可以在 application.properties 或者 application.yml 中设置如下属性: ```properties cloud.aws.region.static=us-east-1 cloud.aws.credentials.accessKey=${your-access-key-id} cloud.aws.credentials.secretKey=${your-secret-access-key} ``` #### 实现文件操作服务 定义一个用于处理文件上传和其他相关业务逻辑的服务组件。这里展示了一个简单的例子，其中包含了向指定的 S3 存储桶上传文件的方法[^3]。 ```java @Service public class FileStorageService { private final String bucketName = "my-bucket-name"; @Autowired private AmazonS3 amazonS3Client; /** * 将给定的输入流保存至 S3 并返回其 URL 地址. */ public String storeFile(InputStream inputStream, String fileName) throws IOException { ObjectMetadata metadata = new ObjectMetadata(); metadata.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE); PutObjectRequest request = new PutObjectRequest(bucketName, fileName, inputStream, metadata); amazonS3Client.putObject(request); return amazonS3Client.getUrl(bucketName, fileName).toString(); } // 下载、删除等功能可以根据需求自行扩展... } ``` #### 控制器层接口设计 为了让前端调用更加方便直观，通常会暴露 RESTful API 接口供外部请求。下面是一个基本的例子，它允许客户端提交表单数据并将其内容发送到上述提到的服务进行进一步处理. ```java @RestController @RequestMapping("/api/files") public class FileController { @Autowired private FileStorageService fileStorageService; @PostMapping(consumes = MediaType.MULTIPART_FORM_DATA_VALUE) public ResponseEntity<String> upload(@RequestParam("file") MultipartFile multipartFile){ try{ InputStream is = multipartFile.getInputStream(); String url = fileStorageService.storeFile(is,multipartFile.getOriginalFilename()); return ResponseEntity.ok(url); }catch(Exception e){ return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(e.getMessage()); } } } ```