1.簡易ストレージサービスとは？

1-1. しゅとくせい

REST、SOAPインタフェースを提供します.

1-2. 主な概念

2.SpringBoot AWS 3の写真をアップロードする

2-1. AWS 3 Bucketの作成

バージョン設定:アジア太平洋(ソウル)設定

オブジェクト所有権:ACLが有効

の無効化パブリックアクセスの無効化

2-2. AWS 3 Bucket権限の設定

パケットをクリックします->アクセス権タブ->パケットポリシー->編集->ポリシージェネレータ
- principal:
- Actions: GetObject, PutObject
-ARN:コピーされたARN+/入力(パケット->プロパティタブ->コピーARNをクリック)

-Add Statement->OK->ポリシーの生成->コピーと貼付けをクリックします

2-3. IAMユーザー権限の追加

AWSアクセス・タイプの選択:アクセス・キー-プログラミング・アクセス->「次へ」をクリックします

アクセス権の設定:既存のポリシーに直接接続->AmazonS 3 FullAccessの確認->次へクリック

2-4. Spring Bootにファイルをアップロードする

cloud:
  aws:
    credentials:
      accessKey: IAM 사용자 엑세스 키
      secretKey: IAM 사용자 비밀 엑세스 키
    s3:
      bucket: 버킷 이름
    region:
      static: ap-northeast-2
    stack:
      auto: false

import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;

@SpringBootApplication
public class ImageApplication {

    public static final String APPLICATION_LOCATIONS = "spring.config.location="
            + "classpath:application.yml,"
            + "classpath:aws.yml";

    public static void main(String[] args) {
        new SpringApplicationBuilder(ImageApplication.class)
                .properties(APPLICATION_LOCATIONS)
                .run(args);
    }
}

import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.s3.AmazonS3Client;
import com.amazonaws.services.s3.AmazonS3ClientBuilder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class AmazonS3Config {

    @Value("${cloud.aws.credentials.access-key}")
    private String accessKey;

    @Value("${cloud.aws.credentials.secret-key}")
    private String secretKey;

    @Value("${cloud.aws.region.static}")
    private String region;

    @Bean
    public AmazonS3Client amazonS3Client() {
        BasicAWSCredentials awsCreds = new BasicAWSCredentials(accessKey, secretKey);
        return (AmazonS3Client) AmazonS3ClientBuilder.standard()
                .withRegion(region)
                .withCredentials(new AWSStaticCredentialsProvider(awsCreds))
                .build();
    }
}

import com.amazonaws.services.s3.AmazonS3Client;
import com.amazonaws.services.s3.model.CannedAccessControlList;
import com.amazonaws.services.s3.model.PutObjectRequest;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.Optional;
import java.util.UUID;

@Slf4j
@RequiredArgsConstructor
@Component
public class S3Uploader {

    private final AmazonS3Client amazonS3Client;

    @Value("${cloud.aws.s3.bucket}")
    public String bucket;  // S3 버킷 이름

    public String upload(MultipartFile multipartFile, String dirName) throws IOException {
        File uploadFile = convert(multipartFile)  // 파일 변환할 수 없으면 에러
                .orElseThrow(() -> new IllegalArgumentException("error: MultipartFile -> File convert fail"));

        return upload(uploadFile, dirName);
    }

    // S3로 파일 업로드하기
    private String upload(File uploadFile, String dirName) {
        String fileName = dirName + "/" + UUID.randomUUID() + uploadFile.getName();   // S3에 저장된 파일 이름 
        String uploadImageUrl = putS3(uploadFile, fileName); // s3로 업로드
        removeNewFile(uploadFile);
        return uploadImageUrl;
    }

    // S3로 업로드
    private String putS3(File uploadFile, String fileName) {
        amazonS3Client.putObject(new PutObjectRequest(bucket, fileName, uploadFile).withCannedAcl(CannedAccessControlList.PublicRead));
        return amazonS3Client.getUrl(bucket, fileName).toString();
    }

    // 로컬에 저장된 이미지 지우기
    private void removeNewFile(File targetFile) {
        if (targetFile.delete()) {
            log.info("File delete success");
            return;
        }
        log.info("File delete fail");
    }

    // 로컬에 파일 업로드 하기
    private Optional<File> convert(MultipartFile file) throws IOException {
        File convertFile = new File(System.getProperty("user.dir") + "/" + file.getOriginalFilename());
        if (convertFile.createNewFile()) { // 바로 위에서 지정한 경로에 File이 생성됨 (경로가 잘못되었다면 생성 불가능)
            try (FileOutputStream fos = new FileOutputStream(convertFile)) { // FileOutputStream 데이터를 파일에 바이트 스트림으로 저장하기 위함
                fos.write(file.getBytes());
            }
            return Optional.of(convertFile);
        }

        return Optional.empty();
    }
}

@RequiredArgsConstructor
@RestController
public class HelloController {

    private final S3Uploader s3Uploader;

    @PostMapping("/images")
    public String upload(@RequestParam("images") MultipartFile multipartFile) throws IOException {
        s3Uploader.upload(multipartFile, "static"); // 두 번째 매개변수의 이름에 따라 S3 Bucket 내부에 해당 이름의 디렉토리가 생성
        return "test";
    }
}

PostManテスト

検査S 3

3.実施時の注意事項

@RequiredArgsConstructor
@RestController
public class BoardController {
    private final BoardService boardService;

    @PostMapping("/api/boards")
    public BoardResponseDto BoardUpload(
//            @AuthenticationPrincipal UserDetailsImpl userDetails,
            @RequestPart(value = "multipartFile", required = false) MultipartFile multipartFile,
            @RequestPart(value = "data") BoardRequestDto boardRequestDto
    ) throws IOException {
//        return boardService.saveBoard(userDetails.getUser(), multipartFile, boardRequestDto);
        return boardService.saveBoard(multipartFile, boardRequestDto);
    }
}

@RequiredArgsConstructor
@Service
public class BoardService {
    private final BoardRepository boardRepository;
    private final S3Uploader s3Uploader;

    private final String imageDirName = "static";   // S3 폴더 경로

    @Transactional
//    public BoardResponseDto saveBoard(User user, MultipartFile multipartFile, BoardRequestDto boardRequestDto) {
    public BoardResponseDto saveBoard(
            MultipartFile multipartFile,
            BoardRequestDto boardRequestDto
    ) throws IOException {
        String imgUrl = "";

        if(multipartFile.getSize() != 0) {      // 이미지 첨부 있으면 S3 파일 업로드
            imgUrl = s3Uploader.upload(multipartFile, imageDirName);
        }
        Board board = Board.builder()
                .title(boardRequestDto.getTitle())
                .content(boardRequestDto.getContent())
//                .nickname(user.getNickname())
                .img(imgUrl)
                .build();
        boardRepository.save(board);

        return BoardResponseDto.builder()
                .board_id(board.getBoard_id())
                .title(board.getTitle())
                .content(board.getContent())
//                .nickname(board.getUser().getNickname())
                .img(board.getImg())
                .build();
    }
}