feat: 실시간 알림(Realtime) 및 AI 메시징 인프라 구축 by csh1668 · Pull Request #6 · Team-StackUp/stackup

csh1668 · 2026-05-08T14:56:03Z

주요 작업 내용

이번 PR은 실시간 알림 시스템과 AI 메시지 처리 인프라를 구축하는 기초 작업(Bootstrap)을 포함하고 있습니다. AI 서버에서 발생한 이벤트를 RabbitMQ를 거쳐 Realtime 서버가 SSE(Server-Sent Events)를 통해 클라이언트에게 전달하는 전체 파이프라인을 구성했습니다.

Realtime 서버 (Go)

SSE 전송 계층: Chi 라우터 기반의 SSE 서버를 구현하여 클라이언트와 실시간 연결을 관리합니다.
세션 레지스트리: 활성화된 클라이언트 연결을 추적하고 관리하는 SessionRegistry를 도입했습니다.
메시지 디스패처: RabbitMQ에서 소비(Consume)한 메시지를 올바른 세션으로 라우팅하는 Dispatcher 로직을 구현했습니다.
검증: registry, dispatcher, sse 등 핵심 로직에 대한 단위 테스트를 추가했습니다.

AI 서버 (Python/FastAPI)

메시징 프레임워크: aio-pika를 사용하여 비동기 AMQP Publisher 및 Consumer 구조를 설계했습니다.
모델링: 메시지 규격을 정의하는 Envelope 및 페이로드(analyze 등)를 Pydantic 모델로 표준화했습니다.
멱등성 처리: LRU 캐시를 활용하여 중복 메시지를 방지하는 Idempotency 레이어를 추가했습니다.
부트스트랩 컨슈머: 이력서 분석 등의 요청을 처리할 수 있는 기초 ResumeConsumer를 구현했습니다.

인프라 및 설정

RabbitMQ: stackup.realtime (topic exchange) 및 session.notify 큐 설정을 definitions.json에 정의했습니다.
Docker: 두 서비스의 컨테이너화를 위한 Dockerfile 및 docker-compose.yml을 작성했습니다.
문서화: 아키텍처, 환경 변수, 메시징 규격 문서를 최신화하고 각 서비스의 CLAUDE.md 가이드를 추가했습니다.

검증 결과

AI 서버: pytest를 통한 모델 및 컨슈머 로직 검증 완료
Realtime 서버: go test를 통한 세션 및 전송 로직 검증 완료
통합: docker-compose를 통한 서비스 간 오케스트레이션 확인

Implement bridge package with envelope parsing and dispatcher for routing RabbitMQ messages to session subscribers. All 4 bridge tests pass with race detector enabled; full realtime suite (15 tests) passes. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Jaeho-Site

Go언어 재밌네요. 앞으로 리뷰 야무지게 해보겠습니다.

Jaeho-Site · 2026-05-11T10:53:44Z

+	ch, err := conn.Channel()
+	if err != nil {
+		return err
+	}
+	defer ch.Close()
+


QoS 설정이 안되어있는데, 아직 로컬용이라 그런건지 궁금합니다.

QoS prefetch is now set (prefetch=1) with contextual error handling; commit c343a57.

Jaeho-Site · 2026-05-11T10:54:49Z

+
+	closeCh := conn.NotifyClose(make(chan *amqp.Error, 1))
+
+	for {


Connection만이 아니라 Channel 닫힘도 처리해주면 좋을 것 같아요.

Channel close notifications are handled alongside connection close to trigger reconnect; commit c343a57.

Jaeho-Site · 2026-05-11T11:15:44Z

+		case err := <-closeCh:
+			return err


closeCh nil 반환 시 consumer 무음 종료되는 이슈 확인 부탁드려요

Nil/closed close notifications now normalize to ErrClosed to avoid silent exit and force reconnect; commit c343a57.

csh1668 · 2026-05-11T11:20:38Z

@copilot 이 PR을 리뷰해줘

Agent-Logs-Url: https://github.com/Team-StackUp/stackup/sessions/f38bbbdd-14f5-46b7-beae-e66a9a7870c7 Co-authored-by: csh1668 <18442452+csh1668@users.noreply.github.com>

vercel · 2026-05-11T11:27:40Z

The latest updates on your projects. Learn more about Vercel for GitHub.

Project	Deployment	Actions	Updated (UTC)
stackup	Ready	Preview, Comment	May 11, 2026 0:00am

Agent-Logs-Url: https://github.com/Team-StackUp/stackup/sessions/f38bbbdd-14f5-46b7-beae-e66a9a7870c7 Co-authored-by: csh1668 <18442452+csh1668@users.noreply.github.com>

Copilot · 2026-05-11T11:35:23Z

Just as a heads up, I was blocked by some firewall rules while working on your feedback. Expand below for details.

Warning

Firewall rules blocked me from connecting to one or more addresses (expand for details)

I tried to connect to the following addresses, but was blocked by firewall rules:

releases.astral.sh
- Triggering command: /home/REDACTED/.local/bin/uv uv sync (dns block)

If you need me to access, download, or install something from one of these locations, you can either:

Configure Actions setup steps to set up my environment, which run before the firewall is enabled
Add the appropriate URLs or hosts to the custom allowlist in this repository's Copilot coding agent settings (admins only)

Jaeho-Site

Good Code

Jaeho-Site · 2026-05-11T11:35:46Z

+    async def lifespan(app: FastAPI) -> AsyncGenerator[None, None]:
+        runtime = MessagingRuntime(settings)
+        await runtime.start()
+        app.state.messaging = runtime
+        try:
+            yield
+        finally:
+            await runtime.stop()
+


runtime.start() 실패 시 finally 블록 진입 불가로 runtime.stop()이 호출되지 않고 RabbitMQ 연결이 좀비가 되는 문제가 있을 것 같아요.

좀비 connection 막도록 try/finally 진입 순서를 변경해 runtime.start() 실패 시에도 stop() 이 호출되도록 수정했습니다. MessagingRuntime.stop() 은 내부 상태 None 가드가 있어 부분 초기화에서도 안전합니다. 회귀 방지 테스트(ai/tests/test_lifespan.py) 추가. commit 8eda222.

runtime.start()가 부분 초기화(connection open 후 exchange/queue declare 실패) 단계에서 raise하면 finally 블록 진입 불가로 stop()이 호출되지 않아 AMQP connection이 좀비가 되던 문제 수정. MessagingRuntime.stop()은 내부 상태 None 가드가 있어 부분 초기화 상태에서도 안전하다. PR #6 review (Jaeho-Site) 대응.

csh1668 and others added 27 commits May 8, 2026 21:24

chore: ignore local .worktrees/ for parallel feature development

b7deeca

feat(infra): stackup.realtime exchange 및 session.notify 큐 추가

21b2d4e

feat(ai): 메시징 관련 설정 추가

ddd7507

feat(ai): envelope 및 메시지 컨텍스트 Pydantic 모델 추가

92684bd

feat(ai): 이력서 분석 요청/콜백 페이로드 추가

5bdbe0c

refactor(ai): 공용 camel_config 헬퍼로 분리

6d141c8

feat(ai): messageId 중복 제거용 LRU 멱등 스토어 추가

3add400

feat(ai): aio-pika 연결 래퍼 및 콜백 퍼블리셔 추가

6f279e2

feat(ai): 멱등 처리 포함 resume echo 컨슈머 추가

a1beff7

feat(ai): FastAPI lifespan에 메시징 런타임 연결

e43dd29

chore(realtime): Go 모듈 초기 설정 및 의존성 추가

9d34789

feat(realtime): env 태그 기반 설정 로딩(config) 추가

1e53f1c

feat(realtime): 트레이스 컨텍스트 및 HTTP 미들웨어 추가

6b1702e

feat(realtime): 세션 구독자 레지스트리 추가(느린 컨슈머 드롭)

50f6224

feat(realtime): AMQP 연결 및 재연결 컨슈머 추가

e312e14

feat(realtime): chi 라우터 + health/SSE 엔드포인트 추가

634d6da

feat(realtime): HTTP 서버 및 AMQP 컨슈머 조립(main) 추가

ac0a9ba

feat(realtime): 멀티스테이지 Alpine Dockerfile 추가(wget 헬스체크)

d3bee9c

reword df880cd # docs(realtime): Go 서버용 CLAUDE.md 추가

bb6cdc8

feat(infra): docker-compose에 ai/realtime 서비스 추가

de7282a

fix(infra): compose 인증용 RabbitMQ stackup 사용자 추가

0898054

fix(infra): realtime 헬스체크 wget 호출 방식 수정(GET 사용)

9a22bc1

docs(messaging): stackup.realtime exchange 및 session.notify 스키마 추가

c4dc0a8

docs: 아키텍처/환경변수 정리(SSE+WS, realtime/ai)

bcaedcf

docs(claude): realtime+ai bootstrap 컨텍스트 정렬

12ce044

chore: .gitignore에 .env 추가

d64611f

csh1668 changed the title ~~feature/realtime ai bootstrap~~ feat: Realtime 서버 부트스트랩 작업 May 8, 2026

csh1668 changed the title ~~feat: Realtime 서버 부트스트랩 작업~~ feat: 실시간 알림(Realtime) 및 AI 메시징 인프라 구축 May 8, 2026

i3months self-requested a review May 11, 2026 09:51

Jaeho-Site reviewed May 11, 2026

View reviewed changes

Copilot started work on behalf of csh1668 May 11, 2026 11:20 View session

fix: add qos and close handling in realtime consumer

b78d0e4

Agent-Logs-Url: https://github.com/Team-StackUp/stackup/sessions/f38bbbdd-14f5-46b7-beae-e66a9a7870c7 Co-authored-by: csh1668 <18442452+csh1668@users.noreply.github.com>

vercel Bot deployed to Preview May 11, 2026 11:27 View deployment

chore: clarify qos prefetch handling

f48a4e8

Agent-Logs-Url: https://github.com/Team-StackUp/stackup/sessions/f38bbbdd-14f5-46b7-beae-e66a9a7870c7 Co-authored-by: csh1668 <18442452+csh1668@users.noreply.github.com>

vercel Bot deployed to Preview May 11, 2026 11:28 View deployment

chore: restore realtime go module files

2cc29fb

Agent-Logs-Url: https://github.com/Team-StackUp/stackup/sessions/f38bbbdd-14f5-46b7-beae-e66a9a7870c7 Co-authored-by: csh1668 <18442452+csh1668@users.noreply.github.com>

vercel Bot deployed to Preview May 11, 2026 11:29 View deployment

chore: refine qos naming and comment

998afe8

Agent-Logs-Url: https://github.com/Team-StackUp/stackup/sessions/f38bbbdd-14f5-46b7-beae-e66a9a7870c7 Co-authored-by: csh1668 <18442452+csh1668@users.noreply.github.com>

vercel Bot deployed to Preview May 11, 2026 11:30 View deployment

chore: clarify qos intent and close handling

31362eb

Agent-Logs-Url: https://github.com/Team-StackUp/stackup/sessions/f38bbbdd-14f5-46b7-beae-e66a9a7870c7 Co-authored-by: csh1668 <18442452+csh1668@users.noreply.github.com>

vercel Bot deployed to Preview May 11, 2026 11:31 View deployment

docs: document qos prefetch constant

4929f66

Agent-Logs-Url: https://github.com/Team-StackUp/stackup/sessions/f38bbbdd-14f5-46b7-beae-e66a9a7870c7 Co-authored-by: csh1668 <18442452+csh1668@users.noreply.github.com>

vercel Bot deployed to Preview May 11, 2026 11:32 View deployment

chore: improve qos error context

bf494f4

Agent-Logs-Url: https://github.com/Team-StackUp/stackup/sessions/f38bbbdd-14f5-46b7-beae-e66a9a7870c7 Co-authored-by: csh1668 <18442452+csh1668@users.noreply.github.com>

vercel Bot deployed to Preview May 11, 2026 11:33 View deployment

chore: refine qos error messaging

c343a57

Agent-Logs-Url: https://github.com/Team-StackUp/stackup/sessions/f38bbbdd-14f5-46b7-beae-e66a9a7870c7 Co-authored-by: csh1668 <18442452+csh1668@users.noreply.github.com>

vercel Bot deployed to Preview May 11, 2026 11:34 View deployment

Copilot finished work on behalf of csh1668 May 11, 2026 11:35

Jaeho-Site reviewed May 11, 2026

View reviewed changes

vercel Bot deployed to Preview May 11, 2026 12:00 View deployment

i3months merged commit b623a91 into dev May 13, 2026
2 checks passed

Uh oh!

Conversation

csh1668 commented May 8, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

주요 작업 내용

Uh oh!

Jaeho-Site left a comment

Choose a reason for hiding this comment

Uh oh!

Jaeho-Site May 11, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI May 11, 2026

Choose a reason for hiding this comment

Uh oh!

Jaeho-Site May 11, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI May 11, 2026

Choose a reason for hiding this comment

Uh oh!

Jaeho-Site May 11, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI May 11, 2026

Choose a reason for hiding this comment

Uh oh!

csh1668 commented May 11, 2026

Uh oh!

vercel Bot commented May 11, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

Copilot AI commented May 11, 2026

I tried to connect to the following addresses, but was blocked by firewall rules:

Uh oh!

Jaeho-Site left a comment

Choose a reason for hiding this comment

Uh oh!

Jaeho-Site May 11, 2026

Choose a reason for hiding this comment

Uh oh!

csh1668 May 11, 2026

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

4 participants

csh1668 commented May 8, 2026 •

edited

Loading

vercel Bot commented May 11, 2026 •

edited

Loading