Merge pull request #120 from CommitField/dev

fix: 레디스 권한오류 해결

Author: seoyeonson

.github/workflows/deploy.yml

@@ -21,12 +21,12 @@ jobs:
         id: create_tag
         uses: mathieudutour/[email protected]
         with:
-          github_token: ${{ secrets.GITHUB_TOKEN }}
+          github_token: ${{ secrets.TOKEN_GITHUB }}
       - name: Create Release
         id: create_release
         uses: actions/create-release@v1
         env:
-          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+          GITHUB_TOKEN: ${{ secrets.TOKEN_GITHUB }}
         with:
           tag_name: ${{ steps.create_tag.outputs.new_tag }}
           release_name: Release ${{ steps.create_tag.outputs.new_tag }}
@@ -46,7 +46,7 @@ jobs:
         with:
           registry: ghcr.io
           username: ${{ github.actor }}
-          password: ${{ secrets.GITHUB_TOKEN }}
+          password: ${{ secrets.TOKEN_GITHUB }}
       - name: set lower case owner name
         run: |
           echo "OWNER_LC=${OWNER,,}" >> ${GITHUB_ENV}

src/main/java/cmf/commitField/domain/chat/chatRoom/controller/ChatRoomController.java

@@ -7,6 +7,7 @@
 import cmf.commitField.domain.chat.chatRoom.dto.ChatRoomUserDto;
 import cmf.commitField.domain.chat.chatRoom.service.ChatRoomService;
 import cmf.commitField.domain.user.entity.CustomOAuth2User;
+import cmf.commitField.global.aws.s3.S3Service;
 import cmf.commitField.global.error.ErrorCode;
 import cmf.commitField.global.globalDto.GlobalResponse;
 import cmf.commitField.global.security.LoginCheck;
@@ -28,25 +29,25 @@
 @RequestMapping("/chat")
 public class ChatRoomController {
     private final ChatRoomService chatRoomService;
-    private final FileService fileService;
+    private final S3Service s3Service; // S3 파일 저장을 위한 서비스
+    private final FileService fileService; //local file 저장을 위한 서비스
 
     // 채팅방 생성 (파일 업로드 포함)
     @PostMapping(value = "/room", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
     public GlobalResponse<Object> createRoom(
             @ModelAttribute @Valid ChatRoomRequest chatRoomRequest) throws IOException {
 
-
         // 인증 확인
         Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
 
         if (authentication instanceof OAuth2AuthenticationToken) {
             CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
-            Long userId = principal.getId();  // getId()를 통해 userId를 추출
+            Long userId = principal.getId();  // getId()를 통해 userId 추출
 
             // 파일 업로드 처리
             String imageUrl = null;
             if (chatRoomRequest.getFile() != null && !chatRoomRequest.getFile().isEmpty()) {
-                imageUrl = fileService.saveFile(chatRoomRequest.getFile());  // 파일 저장
+                imageUrl = s3Service.uploadFile(chatRoomRequest.getFile(), "chat-room"); // S3에 업로드
             }
 
             // 채팅방 생성 서비스 호출 (이미지 URL 포함)
@@ -58,6 +59,7 @@ public GlobalResponse<Object> createRoom(
         }
     }
 
+
     //채팅방 입장
     @PostMapping("/room/join/{roomId}")
     public GlobalResponse<Object> joinRoom(@PathVariable Long roomId, @RequestBody ChatRoomRequest chatRoomRequest) {
@@ -253,8 +255,33 @@ public GlobalResponse<Object> searchRoomName(
         }
     }
 
-
-
+//    // 채팅방 생성 (파일 업로드 포함)
+//    @PostMapping(value = "/room", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
+//    public GlobalResponse<Object> createRoom(
+//            @ModelAttribute @Valid ChatRoomRequest chatRoomRequest) throws IOException {
+//
+//
+//        // 인증 확인
+//        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+//
+//        if (authentication instanceof OAuth2AuthenticationToken) {
+//            CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
+//            Long userId = principal.getId();  // getId()를 통해 userId를 추출
+//
+//            // 파일 업로드 처리
+//            String imageUrl = null;
+//            if (chatRoomRequest.getFile() != null && !chatRoomRequest.getFile().isEmpty()) {
+//                imageUrl = fileService.saveFile(chatRoomRequest.getFile());  // 파일 저장
+//            }
+//
+//            // 채팅방 생성 서비스 호출 (이미지 URL 포함)
+//            chatRoomService.createRoom(chatRoomRequest, userId, imageUrl);
+//
+//            return GlobalResponse.success("채팅방을 생성하였습니다.");
+//        } else {
+//            throw new IllegalArgumentException("로그인 후에 이용해 주세요.");
+//        }
+//    }
 
 
 }

src/main/java/cmf/commitField/domain/chat/chatRoom/controller/response/ChatRoomResponse.java

@@ -1,4 +1,4 @@
-//package cmf.commitField.domain.chat.chatRoom.controller.response;
-//
-//public class ChatRoomResponse {
-//}
+package cmf.commitField.domain.chat.chatRoom.controller.response;
+
+public class ChatRoomResponse {
+}

src/main/java/cmf/commitField/global/aws/s3/S3Cleaner.java

@@ -1,11 +1,7 @@
 package cmf.commitField.global.aws.s3;
 
-import jakarta.annotation.PreDestroy;
 import org.springframework.stereotype.Component;
 import software.amazon.awssdk.services.s3.S3Client;
-import software.amazon.awssdk.services.s3.model.ListObjectsV2Request;
-import software.amazon.awssdk.services.s3.model.ListObjectsV2Response;
-import software.amazon.awssdk.services.s3.model.S3Object;
 
 @Component
 public class S3Cleaner {
@@ -17,21 +13,21 @@ public S3Cleaner(S3Client s3Client) {
         this.s3Client = s3Client;
     }
 
-    @PreDestroy
-    public void cleanup() {
-        // S3에서 테스트 파일 삭제
-        ListObjectsV2Request listObjects = ListObjectsV2Request.builder()
-                .bucket(bucketName)
-                .build();
-
-        // 파일 목록을 가져옵니다.
-        ListObjectsV2Response listObjectsResponse = s3Client.listObjectsV2(listObjects);
-
-        // 각 파일을 삭제합니다.
-        for (S3Object s3Object : listObjectsResponse.contents()) {
-            s3Client.deleteObject(builder -> builder.bucket(bucketName).key(s3Object.key()));
-        }
-
-        System.out.println("S3에 있는 테스트 파일들을 삭제했습니다.");
-    }
+//    @PreDestroy
+//    public void cleanup() {
+//        // S3에서 테스트 파일 삭제
+//        ListObjectsV2Request listObjects = ListObjectsV2Request.builder()
+//                .bucket(bucketName)
+//                .build();
+//
+//        // 파일 목록을 가져옵니다.
+//        ListObjectsV2Response listObjectsResponse = s3Client.listObjectsV2(listObjects);
+//
+//        // 각 파일을 삭제합니다.
+//        for (S3Object s3Object : listObjectsResponse.contents()) {
+//            s3Client.deleteObject(builder -> builder.bucket(bucketName).key(s3Object.key()));
+//        }
+//
+//        System.out.println("S3에 있는 테스트 파일들을 삭제했습니다.");
+//    }
 }

src/main/java/cmf/commitField/global/aws/s3/S3Service.java

@@ -25,6 +25,7 @@ public String uploadFile(MultipartFile file, String dirName) throws IOException
                 .bucket(BUCKET_NAME)
                 .key(fileName)
                 .contentType(file.getContentType())
+//                .acl(ObjectCannedACL.PUBLIC_READ) // Public Read 권한 추가
                 .build();
 
         s3Client.putObject(putObjectRequest,

src/main/java/cmf/commitField/global/config/RedisConfig.java

@@ -1,5 +1,8 @@
 package cmf.commitField.global.config;
 
+import org.redisson.Redisson;
+import org.redisson.config.Config;
+import org.redisson.api.RedissonClient;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -19,6 +22,18 @@ public class RedisConfig {
     @Value("${spring.redis.port}")
     public int port;
 
+    @Value("${spring.redis.password}")
+    public String password;
+
+    @Bean
+    public RedissonClient redissonClient() {
+        Config config = new Config();
+        config.useSingleServer()
+                .setAddress("redis://127.0.0.1:6379")
+                .setPassword(password); // 비밀번호 추가
+        return Redisson.create(config);
+    }
+
     @Bean
     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
         RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
@@ -33,6 +48,7 @@ public RedisConnectionFactory redisConnectionFactory() {
         RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration();
         configuration.setHostName(host);
         configuration.setPort(port);
+        configuration.setPassword(password);  // 비밀번호 설정
         return new LettuceConnectionFactory(configuration);
     }
 

src/main/resources/application-prod.yml

@@ -16,7 +16,7 @@ spring:
     redis:
       host: 172.17.0.1
       port: 6379
-      password: ${custom.secret.spring.data.redis.password}
+      password: ${spring.redis.password}
   jpa:
     hibernate:
       ddl-auto: update

src/main/resources/application.yml

@@ -33,14 +33,25 @@ spring:
       frontUrl: "http://${custom.dev.cookieDomain}:5173"
       backUrl: "http://${custom.dev.cookieDomain}:${server.port}"
     prod:
-      cookieDomain: cmfd.seoez.site
+      cookieDomain: cmf.seoez.site
       frontUrl: "https://www.${custom.prod.cookieDomain}/"
       backUrl: "https://api.${custom.prod.cookieDomain}/"
     site:
       name: "commit-field"
       cookieDomain: "${custom.dev.cookieDomain}"
       frontUrl: "${custom.dev.frontUrl}"
       backUrl: "${custom.dev.backUrl}"
+    # Lettuce 클라이언트 설정 (Redis 연결을 관리하는 클라이언트)
+  redis:
+    host: localhost  # Redis 서버의 호스트명 (Docker를 사용할 경우 `localhost` 또는 `host.docker.internal` 사용)
+    port: 6379  # Redis 서버 포트
+
+  lettuce:
+    pool:
+      max-active: 10  # 최대 활성 커넥션 수
+      max-wait: -1  # 커넥션 풀에서 대기할 수 있는 최대 시간 (-1은 무제한 대기)
+      max-idle: 8  # 커넥션 풀에서의 최대 유휴 커넥션 수
+      min-idle: 4  # 커넥션 풀에서의 최소 유휴 커넥션 수
 
 # swagger 설정
 springdoc:
@@ -53,8 +64,6 @@ springdoc:
 #  paths-to-match:
 #    - /api/** # swagger-ui에 표시할 api의 엔드포인트 패턴
 
-  kafka:
-    bootstrap-servers: localhost:9092
 
 logging:
   level: