yoon6yo · Sep 7, 2026 · Sep 7, 2026 · Sep 7, 2026 · Sep 7, 2026 · coderabbitai
diff --git a/README.md b/README.md
@@ -36,6 +36,12 @@
 - 사용자는 원하는 GPU 용량, 기간, 이미지를 선택하여 신청.
 - 관리자 승인 시 **UsedId(UID/GID)** 자동 할당 및 **Ubuntu 계정 생성 API** 호출.
 
+### 1-1. 셀프 서비스 컨테이너 재시작
+- 사용자가 관리자 개입 없이 본인의 실행 중인 컨테이너를 직접 재시작 가능 (`POST /api/requests/{requestId}/reboot`).
+- 내부적으로는 "현재 노드를 후보에 포함한 마이그레이션"으로 동작 — 새 Pod가 정상 기동을 마친 뒤에야 기존 Pod를 정리하므로, 도중에 실패해도 기존 컨테이너가 그대로 유지됨.
+- 컨테이너 파일시스템을 이미지로 커밋한 뒤 재생성하므로 설치한 패키지·파일은 유지되지만, 접속 포트 번호는 바뀔 수 있음.
+- 반복 클릭으로 인한 과도한 재시작을 막기 위해 마지막 재시작으로부터 10분간 쿨다운 적용.
+
 ### 2. 자동화된 스케줄러 (매일 10:00 실행)
 - **만료 예고:** 만료 전 정해진 날짜(7, 3, 1일 전)에 사용자에게 알림 발송.
 - **자동 회수:** 만료일 도래 시 Linux 계정 삭제, DB 데이터 정리(Cascade), UID 반납.

diff --git a/src/main/java/DGU_AI_LAB/admin_be/domain/requests/controller/RequestController.java b/src/main/java/DGU_AI_LAB/admin_be/domain/requests/controller/RequestController.java
@@ -5,6 +5,7 @@
 import DGU_AI_LAB.admin_be.domain.requests.dto.request.SaveRequestRequestDTO;
 import DGU_AI_LAB.admin_be.domain.requests.dto.response.ChangeRequestResponseDTO;
 import DGU_AI_LAB.admin_be.domain.requests.dto.response.SaveRequestResponseDTO;
+import DGU_AI_LAB.admin_be.domain.requests.service.PodRebootService;
 import DGU_AI_LAB.admin_be.domain.requests.service.RequestCommandService;
 import DGU_AI_LAB.admin_be.domain.requests.service.RequestQueryService;
 import DGU_AI_LAB.admin_be.global.auth.CustomUserDetails;
@@ -24,6 +25,7 @@ public class RequestController implements RequestApi {
 
     private final RequestQueryService requestQueryService;
     private final RequestCommandService requestCommandService;
+    private final PodRebootService podRebootService;
 
     /**
      * 사용 신청 생성
@@ -59,6 +61,17 @@ public ResponseEntity<SuccessResponse<?>> createChangeRequest(@AuthenticationPri
         return SuccessResponse.ok(null);
     }
 
+    /**
+     * 나의 컨테이너 재시작 (FULFILLED 상태만 가능)
+     */
+    @PostMapping("/{requestId}/reboot")
+    public ResponseEntity<SuccessResponse<?>> rebootPod(@AuthenticationPrincipal(expression = "userId") Long userId,
+                                                          @PathVariable Long requestId
+    ) {
+        SaveRequestResponseDTO body = podRebootService.rebootPod(requestId, userId);
+        return SuccessResponse.ok(body);
+    }
+
     /**
      * 나의 사용 신청 조회
      */

diff --git a/src/main/java/DGU_AI_LAB/admin_be/domain/requests/controller/docs/RequestApi.java b/src/main/java/DGU_AI_LAB/admin_be/domain/requests/controller/docs/RequestApi.java
@@ -67,12 +67,37 @@ ResponseEntity<SuccessResponse<?>> createChangeRequest(
             @Valid SingleChangeRequestDTO dto
     );
 
+    @Operation(
+            summary = "내 컨테이너 재시작",
+            description = "FULFILLED 상태인 나의 컨테이너를 같은 노드에서 재시작합니다. 새 컨테이너가 정상 확인된 뒤에야 " +
+                    "기존 컨테이너가 정리되므로, 실패하더라도 기존 컨테이너는 그대로 유지됩니다. " +
+                    "즉시 status=REBOOTING인 신청 정보를 반환하며, 실제 완료 여부는 '내 승인 완료 신청 목록 조회'를 " +
+                    "폴링해 status가 FULFILLED로 돌아오는지로 확인합니다."
+    )
+    @ApiResponse(responseCode = "200", description = "재시작 접수 성공 (status=REBOOTING)",
+            content = @Content(schema = @Schema(implementation = SaveRequestResponseDoc.class)))
+    @ApiResponse(responseCode = "400", description = "본인 소유의 신청이 아님",
+            content = @Content(schema = @Schema(implementation = ErrorResponse.class)))
+    @ApiResponse(responseCode = "404", description = "신청을 찾을 수 없음",
+            content = @Content(schema = @Schema(implementation = ErrorResponse.class)))
+    @ApiResponse(responseCode = "409", description = "FULFILLED 상태가 아니거나(이미 재시작/마이그레이션 진행 중) 배치된 노드 정보가 없음",
+            content = @Content(schema = @Schema(implementation = ErrorResponse.class)))
+    @ApiResponse(responseCode = "429", description = "동시에 처리 중인 재시작 요청이 많음",
+            content = @Content(schema = @Schema(implementation = ErrorResponse.class)))
+    @PostMapping("/{requestId}/reboot")
+    ResponseEntity<SuccessResponse<?>> rebootPod(
+            @Parameter(hidden = true) Long userId,
+            @PathVariable @Parameter(description = "재시작할 신청 ID") Long requestId
+    );
+
     @Operation(summary = "내 신청 목록 조회", description = "로그인된 사용자의 모든 신청 내역(전체 상태 포함)을 조회합니다.")
     @ApiResponse(responseCode = "200", description = "조회 성공",
             content = @Content(schema = @Schema(implementation = SaveRequestListResponseDoc.class)))
     ResponseEntity<SuccessResponse<?>> getMyRequests(@Parameter(hidden = true) CustomUserDetails user);
 
-    @Operation(summary = "내 승인 완료 신청 목록 조회", description = "FULFILLED 상태인 신청 목록만 조회합니다.")
+    @Operation(summary = "내 승인 완료 신청 목록 조회",
+            description = "컨테이너가 살아있는 신청 목록(FULFILLED, 마이그레이션 중 MIGRATING, 재시작 중 REBOOTING)을 조회합니다. " +
+                    "각 항목의 status로 재시작 진행 상태를 폴링할 수 있습니다.")
     @ApiResponse(responseCode = "200", description = "조회 성공",
             content = @Content(schema = @Schema(implementation = SaveRequestListResponseDoc.class)))
     ResponseEntity<SuccessResponse<?>> getMyApprovedRequests(@Parameter(hidden = true) CustomUserDetails user);

diff --git a/src/main/java/DGU_AI_LAB/admin_be/domain/requests/dto/response/SaveRequestResponseDTO.java b/src/main/java/DGU_AI_LAB/admin_be/domain/requests/dto/response/SaveRequestResponseDTO.java
@@ -45,7 +45,7 @@ public record SaveRequestResponseDTO(
         @JsonRawValue String formAnswers,
         @Schema(description = "서버 만료 일시", example = "2026-03-02T06:17:29")
         LocalDateTime expiresAt,
-        @Schema(description = "처리 상태", example = "PENDING", allowableValues = {"PENDING", "FULFILLED", "DENIED", "MODIFICATION_REQUESTED", "MODIFICATION_APPROVED", "MODIFICATION_REJECTED"})
+        @Schema(description = "처리 상태", example = "PENDING", allowableValues = {"PENDING", "PROCESSING", "DENIED", "FULFILLED", "MIGRATING", "REBOOTING", "DELETED"})
         Status status,
         @Schema(description = "승인 일시", example = "2026-03-02T15:36:29", nullable = true)
         LocalDateTime approvedAt,

diff --git a/src/main/java/DGU_AI_LAB/admin_be/domain/requests/entity/Request.java b/src/main/java/DGU_AI_LAB/admin_be/domain/requests/entity/Request.java
@@ -10,6 +10,7 @@
 import jakarta.persistence.*;
 import lombok.*;
 
+import java.time.Duration;
 import java.time.LocalDateTime;
 import java.util.LinkedHashSet;
 import java.util.Set;
@@ -73,6 +74,9 @@ public class Request extends BaseTimeEntity {
     @Column(name = "node_name", length = 100)
     private String nodeName;
 
+    @Column(name = "last_rebooted_at")
+    private LocalDateTime lastRebootedAt;
+
     @ManyToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "rsgroup_id", nullable = false)
     private ResourceGroup resourceGroup;
@@ -209,6 +213,45 @@ public void endMigration() {
         this.status = Status.FULFILLED;
     }
 
+    /**
+     * 재시작 1회마다 config-server가 컨테이너 전체 파일시스템을 NFS에 tar로 떠서 저장하므로
+     * (같은 파일을 덮어쓰긴 하지만) 매번 실질적인 I/O 비용이 든다. 연타로 인한 반복 실행을
+     * 막기 위해 마지막 재시작 시도 이후 이 시간 동안은 재시도를 막는다.
+     */
+    private static final long REBOOT_COOLDOWN_MINUTES = 10;
+
+    /**
+     * 사용자 셀프 재시작 시작을 위해 FULFILLED -> REBOOTING으로 전환한다.
+     * beginMigration()과 같은 이유로 행 잠금 조회(findByIdForUpdate)와 같은 트랜잭션에서
+     * 호출해야 동시에 들어온 두 번째 재시작 요청이 이 상태 검증에서 실제로 막힌다.
+     */
+    public void beginReboot() {
+        if (this.status != Status.FULFILLED) {
+            throw new BusinessException("컨테이너가 실행 중일 때만 재시작할 수 있습니다. 이미 다른 작업이 진행 중입니다.", ErrorCode.INVALID_REQUEST_STATUS);
+        }
+        if (this.lastRebootedAt != null) {
+            LocalDateTime cooldownEnd = this.lastRebootedAt.plusMinutes(REBOOT_COOLDOWN_MINUTES);
+            if (cooldownEnd.isAfter(LocalDateTime.now())) {
+                long remainingMinutes = Duration.between(LocalDateTime.now(), cooldownEnd).toMinutes() + 1;
+                throw new BusinessException(
+                        String.format("최근에 재시작한 컨테이너입니다. %d분 후 다시 시도해주세요.", remainingMinutes),
+                        ErrorCode.POD_REBOOT_COOLDOWN);
+            }
+        }
+        this.status = Status.REBOOTING;
+        this.lastRebootedAt = LocalDateTime.now();
+    }
+
+    /**
+     * 재시작 시도가 끝나면(성공/실패 모두) REBOOTING -> FULFILLED로 되돌린다.
+     */
+    public void endReboot() {
+        if (this.status != Status.REBOOTING) {
+            throw new BusinessException(ErrorCode.INVALID_REQUEST_STATUS);
+        }
+        this.status = Status.FULFILLED;
+    }
+
     public void assignUbuntuIds(Long ubuntuUid, Long ubuntuGid) {
         if (ubuntuUid == null || ubuntuGid == null || ubuntuUid <= 0 || ubuntuGid <= 0) {
             throw new BusinessException(ErrorCode.UID_ALLOCATION_FAILED);
@@ -240,7 +283,7 @@ public void delete() {
         if (this.status == Status.DELETED) {
             throw new BusinessException("이미 삭제된 요청입니다.", ErrorCode.INVALID_REQUEST_STATUS);
         }
-        if (this.status == Status.FULFILLED || this.status == Status.MIGRATING) {
+        if (this.status == Status.FULFILLED || this.status == Status.MIGRATING || this.status == Status.REBOOTING) {
             throw new BusinessException("컨테이너가 실행 중입니다. 인프라 정리 후 삭제해주세요.", ErrorCode.INVALID_REQUEST_STATUS);
         }
         if (this.status == Status.PROCESSING) {

diff --git a/src/main/java/DGU_AI_LAB/admin_be/domain/requests/entity/Status.java b/src/main/java/DGU_AI_LAB/admin_be/domain/requests/entity/Status.java
@@ -3,14 +3,16 @@
 import java.util.List;
 
 public enum Status {
-    PENDING, PROCESSING, DENIED, FULFILLED, MIGRATING, DELETED;
+    PENDING, PROCESSING, DENIED, FULFILLED, MIGRATING, REBOOTING, DELETED;
 
     /**
      * 실제 인프라(Pod/우분투 계정)가 살아있는 상태 집합.
      * "내 서버" 조회, 리소스 사용량 집계 등 FULFILLED를 기준으로 하던 조회 로직은
-     * 마이그레이션 중에도 자원이 계속 점유돼 있으므로 이 집합을 사용해야 한다.
+     * 마이그레이션/재시작 중에도 자원이 계속 점유돼 있으므로 이 집합을 사용해야 한다.
+     * 특히 재시작은 사용자가 진행 상태를 "내 승인 완료 신청" 조회로 폴링하므로,
+     * REBOOTING이 빠지면 재시작 도중 자기 컨테이너가 목록에서 사라진다.
      */
     public static List<Status> activeStatuses() {
-        return List.of(FULFILLED, MIGRATING);
+        return List.of(FULFILLED, MIGRATING, REBOOTING);
     }
 }
diff --git a/src/main/java/DGU_AI_LAB/admin_be/domain/requests/entity/StatusFilter.java b/src/main/java/DGU_AI_LAB/admin_be/domain/requests/entity/StatusFilter.java
@@ -5,5 +5,5 @@
  * ALL은 "모든 상태 조회" 의미의 sentinel 값입니다.
  */
 public enum StatusFilter {
-    PENDING, PROCESSING, DENIED, FULFILLED, MIGRATING, DELETED, ALL
+    PENDING, PROCESSING, DENIED, FULFILLED, MIGRATING, REBOOTING, DELETED, ALL
 }
diff --git a/src/main/java/DGU_AI_LAB/admin_be/domain/requests/service/AdminRequestCommandService.java b/src/main/java/DGU_AI_LAB/admin_be/domain/requests/service/AdminRequestCommandService.java
@@ -81,7 +81,7 @@ public class AdminRequestCommandService {
     // corePoolSize=maxPoolSize=3, queueCapacity=0(AsyncConfig 참고) — 이 이상 동시에 승인이
     // 몰리면 큐잉하지 않고 즉시 TaskRejectedException으로 거부해, 관리자에게 명확한 에러로
     // 실패시킨다 (기존 Semaphore(3) fail-fast 정책과 동일한 사용자 체감 동작 유지).
-    private final ThreadPoolTaskExecutor approvalExecutor;
+    private final @Qualifier("approvalExecutor") ThreadPoolTaskExecutor approvalExecutor;
 
     @Transactional(propagation = Propagation.NOT_SUPPORTED)
     public SaveRequestResponseDTO approveRequest(ApproveRequestDTO dto) {

diff --git a/src/main/java/DGU_AI_LAB/admin_be/domain/requests/service/PodMigrationService.java b/src/main/java/DGU_AI_LAB/admin_be/domain/requests/service/PodMigrationService.java
@@ -42,7 +42,9 @@ public class PodMigrationService {
     // 무의미한 케이스). config-server 자체는 건드리지 않고 이미 있는 계약만 활용한다.
     // Double(래퍼)로 선언 — 삼항연산자에서 한쪽이 primitive double이면 다른 쪽 Double이
     // null이어도 타입 프로모션 때문에 무조건 언박싱되어 NPE가 난다.
-    private static final Double FORCE_MIGRATION_RATIO = -1000.0;
+    // 셀프 재시작(PodRebootService)도 개선 비율 검사를 건너뛴 채 같은 노드로 재배치해야 하므로
+    // 같은 패키지에서 재사용한다.
+    static final Double FORCE_MIGRATION_RATIO = -1000.0;
 
     public MigratePodResponseDTO migratePod(Long requestId, MigratePodRequestDTO dto) {
         TransactionTemplate tx = new TransactionTemplate(transactionManager);
@@ -80,19 +82,7 @@ public MigratePodResponseDTO migratePod(Long requestId, MigratePodRequestDTO dto
                         .orElseThrow(() -> new BusinessException(ErrorCode.RESOURCE_NOT_FOUND));
 
                 if (response.isMigrated()) {
-                    req.assignPodInfo(response.newPod(), response.to());
-
-                    podExternalPortRepository.deleteByRequestRequestId(requestId);
-                    if (response.ports() != null) {
-                        for (CreatePodResponseDTO.PortInfo port : response.ports()) {
-                            podExternalPortRepository.save(PodExternalPort.builder()
-                                    .request(req)
-                                    .internalPort(port.internalPort())
-                                    .externalPort(port.externalPort())
-                                    .usagePurpose(port.usagePurpose())
-                                    .build());
-                        }
-                    }
+                    applyMigratedPodInfo(requestId, req, response);
                 }
                 req.endMigration();
                 return null;
@@ -128,6 +118,28 @@ public MigratePodResponseDTO migratePod(Long requestId, MigratePodRequestDTO dto
         return response;
     }
 
+    /**
+     * config-server가 새로 만든 Pod의 위치와 포트 매핑을 Request에 반영한다. 기존 포트 행은
+     * 새 Pod에서 더 이상 유효하지 않으므로 통째로 지우고 다시 심는다.
+     * 셀프 재시작(PodRebootService)도 같은 /migrate 응답을 받으므로 이 반영 로직을 공유한다.
+     * 호출자의 트랜잭션 안에서 실행되어야 하며, 상태 전환(endMigration/endReboot)은 호출자 책임이다.
+     */
+    void applyMigratedPodInfo(Long requestId, Request req, MigratePodResponseDTO response) {
+        req.assignPodInfo(response.newPod(), response.to());
+
+        podExternalPortRepository.deleteByRequestRequestId(requestId);
+        if (response.ports() != null) {
+            for (CreatePodResponseDTO.PortInfo port : response.ports()) {
+                podExternalPortRepository.save(PodExternalPort.builder()
+                        .request(req)
+                        .internalPort(port.internalPort())
+                        .externalPort(port.externalPort())
+                        .usagePurpose(port.usagePurpose())
+                        .build());
+            }
+        }
+    }
+
     /**
      * 2단계(외부 호출) 또는 3단계(DB 반영) 실패 시 MIGRATING에 갇힌 요청을 FULFILLED로 되돌린다.
      * 이 복구 자체가 실패하면(예: 그 사이 상태가 다른 경로로 바뀐 경우) 수동 확인이 필요하므로