[feat/#11]: Kafka 기반 Event-Driven 아키텍처를 도입하고 Non-blocking 처리를 구현한다 #12

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged

woong2e merged 54 commits into main from feature/#11/kafka

Jan 13, 2026

.github/workflows/cicd.yml

            
                      Original file line number
                      Diff line number
                      Diff line change
                  
    @@ -40,37 +40,60 @@ jobs:
  
          - name: Build & Run Tests

            run: ./gradlew clean build

          - name: Upload Build Artifact

      # [API] JAR 파일 업로드

          - name: Upload API Artifact

            uses: actions/upload-artifact@v4

            with:

              name: build-artifacts

              path: build/libs/*.jar

              name: api-jar

              path: coupon-api/build/libs/*.jar

      # [Consumer] JAR 파일 업로드

          - name: Upload Consumer Artifact

            uses: actions/upload-artifact@v4

            with:

              name: consumer-jar

              path: coupon-consumer/build/libs/*.jar

      # 2. 도커 이미지 빌드 및 푸시

      docker-build-and-push:

        name: Build & Push Docker Image

        name: Build & Push Docker Images

        runs-on: ubuntu-latest

        needs: build-and-test

        steps:

          - name: Checkout Repository

            uses: actions/checkout@v4

          - name: Download Build Artifact

          # (1) API JAR 다운로드

          - name: Download API Artifact

            uses: actions/download-artifact@v4

            with:

              name: api-jar

              path: coupon-api/build/libs/

          # (2) Consumer JAR 다운로드

          - name: Download Consumer Artifact

            uses: actions/download-artifact@v4

            with:

              name: build-artifacts

              path: build/libs/

              name: consumer-jar

              path: coupon-consumer/build/libs/

          - name: Log in to Docker Hub

            uses: docker/login-action@v3

            with:

              username: ${{ secrets.DOCKER_HUB_USERNAME }}

              password: ${{ secrets.DOCKER_HUB_ACCESS_TOKEN }}

          - name: Build and Push Docker Image

          # (3) API 이미지 빌드 & 푸시

          - name: Build & Push API Image

            run: |

              docker build -t ${{ secrets.DOCKER_HUB_USERNAME }}/coupon-api:latest -f coupon-api/Dockerfile coupon-api

              docker push ${{ secrets.DOCKER_HUB_USERNAME }}/coupon-api:latest

          # (4) Consumer 이미지 빌드 & 푸시

          - name: Build & Push Consumer Image

            run: |

              docker build -t ${{ secrets.DOCKER_HUB_USERNAME }}/couponsystem:latest .

              docker push ${{ secrets.DOCKER_HUB_USERNAME }}/couponsystem:latest

              docker build -t ${{ secrets.DOCKER_HUB_USERNAME }}/coupon-consumer:latest -f coupon-consumer/Dockerfile coupon-consumer

              docker push ${{ secrets.DOCKER_HUB_USERNAME }}/coupon-consumer:latest

      # 3. 서버 배포

      deploy:

    @@ -84,18 +107,19 @@ jobs:
  
          - name: Checkout Repository

            uses: actions/checkout@v4

          # (1) 설정 파일들 서버로 전송 (SCP)

          # (1) 설정 파일 전송 (docker-compose 폴더 등)

          - name: Copy Config Files via SCP

            uses: appleboy/scp-action@master

            with:

              host: ${{ secrets.AWS_EC2_HOST }}

              username: ${{ secrets.AWS_EC2_USER }}

              key: ${{ secrets.AWS_SSH_PRIVATE_KEY }}

              # docker-compose 폴더, nginx, deploy 스크립트 등 필요한 파일 전송

              source: "docker-compose/*,nginx/*,deploy/*"

              target: "/home/${{ secrets.AWS_EC2_USER }}/deploy"

              strip_components: 1

          # (2) 서버 접속, .env 생성 및 배포 스크립트 실행

          # (2) 배포 스크립트 실행

          - name: Execute Deploy Script

            uses: appleboy/[email protected]

            env:

    @@ -107,8 +131,14 @@ jobs:
  
              envs: ENV_FILE_CONTENT

              script: |

                cd /home/${{ secrets.AWS_EC2_USER }}/deploy

                # .env 파일 생성

                echo "$ENV_FILE_CONTENT" > .env

                # 스크립트 위치 확인 및 실행

                if [ -f "deploy/deploy.sh" ]; then

                    cd deploy

                fi

                chmod +x deploy.sh

                ./deploy.sh

.gitignore

-Original file line number
+Diff line change
@@ Expand Up / @@ -52,3 +52,5 @@ out/ @@
     /mysql-data-local/
     /src/main/resources/.env
     /src/main/resources/application.yml
+    /coupon-consumer/src/main/resources/.env
+    /coupon-api/src/main/resources/.env

build.gradle.kts

-Original file line number
+Diff line change
@@ -1,57 +1,49 @@
-    plugins {
-    	kotlin("jvm") version "2.2.21"
-    	kotlin("plugin.spring") version "2.2.21"
-        kotlin("plugin.jpa") version "2.2.21"
-    	id("org.springframework.boot") version "4.0.0"
-    	id("io.spring.dependency-management") version "1.1.7"
-    }
+    import org.gradle.api.plugins.JavaPluginExtension
+    import org.gradle.jvm.toolchain.JavaLanguageVersion
+    import org.jetbrains.kotlin.gradle.dsl.JvmTarget
+    import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
-    group = "com.woong2e"
-    version = "0.0.1-SNAPSHOT"
-    description = "FCFS-EventSystem"
-    java {
-    	toolchain {
-    		languageVersion = JavaLanguageVersion.of(21)
-    	}
-    }
-    repositories {
-    	mavenCentral()
+    plugins {
+        kotlin("jvm") version "1.9.25" apply false
+        kotlin("plugin.spring") version "1.9.25" apply false
+        kotlin("plugin.jpa") version "1.9.25" apply false
+        id("org.springframework.boot") version "3.4.1" apply false
+        id("io.spring.dependency-management") version "1.1.7" apply false
     }
-    dependencies {
-        implementation("org.springframework.boot:spring-boot-starter-web")
-        implementation("org.springframework.boot:spring-boot-starter-validation")
-        implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
-        implementation("org.jetbrains.kotlin:kotlin-reflect")
-        implementation("org.jetbrains.kotlin:kotlin-stdlib")
+    allprojects {
+        group = "com.woong2e"
+        version = "0.0.1-SNAPSHOT"
-        implementation("org.springframework.boot:spring-boot-starter-jdbc")
-        implementation("org.springframework.boot:spring-boot-starter-data-jpa")
-        runtimeOnly("com.mysql:mysql-connector-j")
-        runtimeOnly("com.h2database:h2")
-    	implementation("org.springframework.boot:spring-boot-starter-actuator")
-        implementation("io.micrometer:micrometer-registry-prometheus")
-        implementation("com.github.f4b6a3:ulid-creator:5.2.2")
-        implementation("org.springframework.boot:spring-boot-starter-data-redis")
-        implementation("org.redisson:redisson-spring-boot-starter:4.1.0")
-        testImplementation("org.springframework.boot:spring-boot-starter-test")
-    	testImplementation("org.jetbrains.kotlin:kotlin-test-junit5")
-    	testRuntimeOnly("org.junit.platform:junit-platform-launcher")
+        repositories {
+            mavenCentral()
+        }
     }
-    kotlin {
-    	compilerOptions {
-    		freeCompilerArgs.addAll("-Xjsr305=strict", "-Xannotation-default-target=param-property")
-    	}
-    }
-    tasks.withType<Test> {
-    	useJUnitPlatform()
-    }
+    subprojects {
+        // 하위 모듈에 플러그인 적용
+        apply(plugin = "org.jetbrains.kotlin.jvm")
+        apply(plugin = "org.jetbrains.kotlin.plugin.spring")
+        apply(plugin = "org.jetbrains.kotlin.plugin.jpa")
+        apply(plugin = "org.springframework.boot")
+        apply(plugin = "io.spring.dependency-management")
+        // Java 21 설정
+        configure<JavaPluginExtension> {
+            toolchain {
+                languageVersion.set(JavaLanguageVersion.of(21))
+            }
+        }
+        // 컴파일 옵션
+        tasks.withType<KotlinCompile> {
+            compilerOptions {
+                freeCompilerArgs.add("-Xjsr305=strict")
+                jvmTarget.set(JvmTarget.JVM_21)
+            }
+        }
+        tasks.withType<Test> {
+            useJUnitPlatform()
+        }
+    }

Dockerfile → coupon-api/Dockerfile

-Original file line number
+Diff line change
@@ -1,11 +1,8 @@
-    # 1. Base Image (JDK 21 환경)
+    # coupon-api/Dockerfile
     FROM eclipse-temurin:21-jdk-alpine
-    # 2. 작업 디렉토리 설정
     WORKDIR /app
-    # 3. JAR 파일 복사
     COPY build/libs/*.jar app.jar
-    # 4. 실행 명령어
     ENTRYPOINT ["java", "-jar", "app.jar"]

coupon-api/build.gradle.kts

-Original file line number
+Diff line change
@@ -0,0 +1,35 @@
+    dependencies {
+        // Kotlin & Core
+        implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
+        implementation("org.jetbrains.kotlin:kotlin-reflect")
+        implementation("org.jetbrains.kotlin:kotlin-stdlib")
+        // Web & Validation
+        implementation("org.springframework.boot:spring-boot-starter-web")
+        implementation("org.springframework.boot:spring-boot-starter-validation")
+        // Kafka
+        implementation("org.springframework.kafka:spring-kafka")
+        // DB & JPA
+        implementation("org.springframework.boot:spring-boot-starter-data-jpa")
+        implementation("org.springframework.boot:spring-boot-starter-jdbc")
+        runtimeOnly("com.mysql:mysql-connector-j")
+        runtimeOnly("com.h2database:h2")
+        // Redis & Redisson
+        implementation("org.springframework.boot:spring-boot-starter-data-redis")
+        implementation("org.redisson:redisson-spring-boot-starter:3.25.0")
+        // Monitoring
+        implementation("org.springframework.boot:spring-boot-starter-actuator")
+        implementation("io.micrometer:micrometer-registry-prometheus")
+        // Utils
+        implementation("com.github.f4b6a3:ulid-creator:5.2.2")
+        // Test
+        testImplementation("org.springframework.boot:spring-boot-starter-test")
+        testImplementation("org.jetbrains.kotlin:kotlin-test-junit5")
+        testRuntimeOnly("org.junit.platform:junit-platform-launcher")
+    }

...e/couponsystem/CouponsystemApplication.kt → ...ouponsystem/CouponsystemApiApplication.kt

            
                      Original file line number
                      Diff line number
                      Diff line change
                  
    @@ -1,11 +1,11 @@
  
    package com.woong2e.couponsystem

    package main.kotlin.com.woong2e.couponsystem

    import org.springframework.boot.autoconfigure.SpringBootApplication

    import org.springframework.boot.runApplication

    @SpringBootApplication

    class CouponsystemApplication

    class CouponsystemApiApplication

    fun main(args: Array<String>) {

    	runApplication<CouponsystemApplication>(*args)

    	runApplication<CouponsystemApiApplication>(*args)

    }

...coupon/api/controller/CouponController.kt → ...coupon/api/controller/CouponController.kt

            
                      Original file line number
                      Diff line number
                      Diff line change
                  
    @@ -1,16 +1,16 @@
  
    package com.woong2e.couponsystem.coupon.api.controller

    package main.kotlin.com.woong2e.couponsystem.coupon.api.controller

    import com.woong2e.couponsystem.coupon.api.request.CouponCreateRequest

    import com.woong2e.couponsystem.coupon.api.request.CouponIssueRequest

    import com.woong2e.couponsystem.coupon.api.request.CouponStockInitRequest

    import com.woong2e.couponsystem.coupon.application.response.CouponIssueResponse

    import com.woong2e.couponsystem.coupon.application.response.CouponResponse

    import com.woong2e.couponsystem.coupon.application.service.CouponIssueService

    import com.woong2e.couponsystem.coupon.application.service.CouponService

    import com.woong2e.couponsystem.coupon.status.CouponErrorStatus

    import com.woong2e.couponsystem.global.exception.CustomException

    import com.woong2e.couponsystem.global.response.ApiResponse

    import com.woong2e.couponsystem.global.response.status.SuccessStatus

    import main.kotlin.com.woong2e.couponsystem.coupon.api.request.CouponCreateRequest

    import main.kotlin.com.woong2e.couponsystem.coupon.api.request.CouponIssueRequest

    import main.kotlin.com.woong2e.couponsystem.coupon.api.request.CouponStockInitRequest

    import main.kotlin.com.woong2e.couponsystem.coupon.application.response.CouponIssueResponse

    import main.kotlin.com.woong2e.couponsystem.coupon.application.response.CouponResponse

    import main.kotlin.com.woong2e.couponsystem.coupon.application.service.CouponIssueService

    import main.kotlin.com.woong2e.couponsystem.coupon.application.service.CouponService

    import main.kotlin.com.woong2e.couponsystem.coupon.status.CouponErrorStatus

    import main.kotlin.com.woong2e.couponsystem.global.exception.CustomException

    import main.kotlin.com.woong2e.couponsystem.global.response.ApiResponse

    import main.kotlin.com.woong2e.couponsystem.global.response.status.SuccessStatus

    import org.springframework.http.ResponseEntity

    import org.springframework.web.bind.annotation.DeleteMapping

    import org.springframework.web.bind.annotation.PathVariable

...coupon/api/request/CouponCreateRequest.kt → ...coupon/api/request/CouponCreateRequest.kt

-Original file line number
+Diff line change
@@ -1,4 +1,4 @@
-    package com.woong2e.couponsystem.coupon.api.request
+    package main.kotlin.com.woong2e.couponsystem.coupon.api.request
     data class CouponCreateRequest(
         val title: String,
@@ Expand Down @@

.../coupon/api/request/CouponIssueRequest.kt → .../coupon/api/request/CouponIssueRequest.kt

-Original file line number
+Diff line change
@@ -1,4 +1,4 @@
-    package com.woong2e.couponsystem.coupon.api.request
+    package main.kotlin.com.woong2e.couponsystem.coupon.api.request
     import java.util.UUID
@@ Expand Down @@

...pon/api/request/CouponStockInitRequest.kt → ...pon/api/request/CouponStockInitRequest.kt

-Original file line number
+Diff line change
@@ -1,4 +1,4 @@
-    package com.woong2e.couponsystem.coupon.api.request
+    package main.kotlin.com.woong2e.couponsystem.coupon.api.request
     import java.util.UUID
@@ Expand Down @@

.../src/main/kotlin/com/woong2e/couponsystem/coupon/application/event/CouponIssueDltEvent.kt

-Original file line number
+Diff line change
@@ -0,0 +1,11 @@
+    package main.kotlin.com.woong2e.couponsystem.coupon.application.event
+    import main.kotlin.com.woong2e.couponsystem.coupon.value.DltSource
+    import java.util.UUID
+    data class CouponIssueDltEvent(
+        val source: DltSource,
+        val couponId: UUID,
+        val userId: Long,
+        val reason: String? = null,
+    )

...api/src/main/kotlin/com/woong2e/couponsystem/coupon/application/event/CouponIssueEvent.kt

-Original file line number
+Diff line change
@@ -0,0 +1,8 @@
+    package main.kotlin.com.woong2e.couponsystem.coupon.application.event
+    import java.util.UUID
+    data class CouponIssueEvent(
+        val couponId: UUID,
+        val userId: Long
+    )

.../kotlin/com/woong2e/couponsystem/coupon/application/port/out/CouponIssueEventPublisher.kt

-Original file line number
+Diff line change
@@ -0,0 +1,7 @@
+    package main.kotlin.com.woong2e.couponsystem.coupon.application.port.out
+    import java.util.UUID
+    interface CouponIssueEventPublisher {
+        fun publish(couponId: UUID, userId: Long)
+    }

...c/main/kotlin/com/woong2e/couponsystem/coupon/application/response/CouponIssueResponse.kt

-Original file line number
+Diff line change
@@ -0,0 +1,27 @@
+    package main.kotlin.com.woong2e.couponsystem.coupon.application.response
+    import java.util.UUID
+    data class CouponIssueResponse(
+        val isSuccess: Boolean = true,
+        val issuedCouponId: UUID? = null,
+        val message: String? = null
+    ) {
+        companion object {
+            fun asyncIssued(): CouponIssueResponse {
+                return CouponIssueResponse(
+                    isSuccess = true,
+                    issuedCouponId = null,
+                    message = "쿠폰 발급 요청이 대기열에 추가되었습니다. 잠시 후 보관함을 확인해주세요."
+                )
+            }
+            fun syncIssued(id: UUID): CouponIssueResponse {
+                return CouponIssueResponse(
+                    isSuccess = true,
+                    issuedCouponId = id,
+                    message = "쿠폰 발급이 완료되었습니다."
+                )
+            }
+        }
+    }

...on/application/response/CouponResponse.kt → ...on/application/response/CouponResponse.kt

-Original file line number
+Diff line change
@@ -1,4 +1,4 @@
-    package com.woong2e.couponsystem.coupon.application.response
+    package main.kotlin.com.woong2e.couponsystem.coupon.application.response
     import java.util.UUID
@@ Expand Down @@

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[feat/#11]: Kafka 기반 Event-Driven 아키텍처를 도입하고 Non-blocking 처리를 구현한다 #12

Uh oh!

Diff view

Diff view

There are no files selected for viewing

Uh oh!