RAG聊天应用

cd C:/workspace-team/my-webflux-mcp-server
mvn spring-boot:run

docker run -d \
  --name chatdb \
  -e POSTGRES_DB=chatdb \
  -e POSTGRES_USER=postgres \
  -e POSTGRES_PASSWORD=postgres \
  -p 5433:5432 \
  postgres:16

ollama pull qwen3-4b:Q4_K_M

cd C:/workspace-team/my-webflux-mcp-client
mvn clean compile
mvn spring-boot:run

app:
  mcp:
    stdio:
      servers:
        fs-server:
          command: "cmd"                     # Windows: cmd /c 필수 (npx는 .cmd 스크립트)
          args: ["/c", "npx", "-y",
                 "@modelcontextprotocol/server-filesystem",
                 "C:/workspace-test/upload"]

src/main/java/com/example/client/
├── ClientApplication.java
├── config/
│   ├── ChatClientConfig.java          # ChatClient, JDBC ChatMemory, MessageChatMemoryAdvisor
│   ├── EgovCommonConfig.java
│   ├── McpServerRegistry.java         # MCP 서버 per-server 상태 관리 (DISCONNECTED/CONNECTED/FAILED)
│   │                                  #   · listTools() ping으로 서버 사망 감지
│   │                                  #   · SSE(HTTP) + stdio 두 가지 연결 유형 지원
│   │                                  #   · ToolAnnotations 기반 위험 작업 제어 + wrapWithSafetyGuard
│   ├── McpOptionalConfig.java         # McpServerRegistry 빈 생성 + 기동 시 초기 연결 시도
│   ├── OllamaConfig.java              # Ollama ChatModel 설정
│   └── SwaggerConfig.java
├── controller/
│   ├── ChatController.java            # /api/chat/rag/stream, /simple/stream (SSE)
│   ├── ChatPageController.java        # / → chat.html
│   ├── ChatSessionController.java     # /api/sessions CRUD
│   ├── DocumentIngestController.java  # /api/documents/ingest → MCP ingestDocument 호출
│   ├── McpServerController.java       # /api/mcp/servers/** (상태 조회·연결·위험 작업 허용)
│   ├── OllamaModelController.java     # /api/ollama/models
│   └── IngestPageController.java      # /ingest → ingest.html
├── dto/
│   ├── ChatMessageDto.java
│   ├── ChatSessionDto.java
│   └── ServerStatusDto.java           # 서버 상태 DTO (name, type, status, lastError, tools, restrictedAllowed)
├── entity/
│   └── ChatSessionEntity.java         # JPA (spring_ai_chat_sessions 테이블)
├── handler/
│   └── McpClientEventHandler.java     # @McpLogging, @McpSampling 등 MCP 이벤트 처리
├── repository/
│   └── ChatSessionRepository.java
└── service/
    ├── ChatService.java
    ├── ChatSessionService.java
    ├── OllamaModelService.java
    └── impl/
        ├── ChatServiceImpl.java        # Simple(LLM 자율) 구현 — RAG 강제 선호출은 @Deprecated
        │                               #   · MCP 미연결 시 Flux.concat으로 경고 메시지 선행 삽입
        ├── ChatSessionServiceImpl.java
        └── OllamaModelServiceImpl.java

src/main/resources/
├── application.yml
├── static/js/
│   ├── marked.min.js                  # 마크다운 렌더링
│   └── purify.min.js                  # XSS 방어 (DOMPurify)
└── templates/
    ├── chat.html                      # 채팅 UI (단일 탭, 서버 상태 사이드바, SSE 스트리밍)
    └── ingest.html                    # 문서 적재 UI (구 upload.html)

spring:
  datasource:
    url: jdbc:postgresql://localhost:5433/chatdb
  ai:
    ollama:
      base-url: http://localhost:11434
      chat.options.model: qwen3-4b:Q4_K_M
    mcp:
      client:
        type: ASYNC
        streamable-http.connections.mcp-server.url: http://localhost:9090
        request-timeout: 60000          # MCP 요청 타임아웃 (ms)
    chat.memory.repository.jdbc:
      initialize-schema: always         # 최초 실행 시 테이블 자동 생성
server:
  port: 8080

app:
  mcp-client-id: webflux-mcp-client    # 서버가 적재 문서의 출처 식별에 사용. 다중 클라이언트 배포 시 고유값으로 변경
  mcp-api-key: "${MCP_API_KEY:}"       # 서버 ingestDocument 도구 인증 키
  mcp:
    stdio:
      servers: {}                       # stdio MCP 서버 설정 (선택)
  rag:
    query-transform:
      translation-enabled: false        # 질의 한국어 번역 (기본 off)
      rewrite-enabled: false            # 질의 재작성 (기본 off)