RAG文档检索与存储服务器

cd C:/workspace-team/my-webflux-mcp-server
docker-compose up -d

C:/workspace-test/upload/data/

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

{
  "servers": {
    "my-webflux-mcp-server": {
      "url": "http://localhost:9090/mcp",
      "type": "http",
      "headers": { "X-MCP-API-Key": "<발급받은 API 키>" }
    }
  }
}

{
  "mcpServers": {
    "my-webflux-mcp-server": {
      "url": "http://localhost:9090/mcp",
      "type": "streamableHttp",
      "headers": { "X-MCP-API-Key": "<발급받은 API 키>" },
      "disabled": false,
      "autoApprove": []
    }
  }
}

src/main/java/com/example/webflux/
├── McpServerApplication.java
├── config/
│   ├── AsyncConfig.java                  # 비동기 스레드풀
│   ├── EgovCommonConfig.java
│   ├── HybridIndexInitializer.java       # pg_trgm GIN 인덱스 자동 생성 (hybrid.enabled=true 시)
│   ├── McpResourcePromptConfig.java      # @McpResource, @McpPrompt 등록
│   ├── McpTransportConfig.java           # WebFluxStreamableServerTransportProvider 오버라이드
│   │                                     #   → X-MCP-API-Key 헤더를 transportContext에 주입
│   └── SecurityProperties.java           # app.security.api-keys 바인딩
├── controller/
│   └── DocumentController.java           # REST /api/documents/**
├── dto/
│   └── DocumentStatusResponse.java
├── etl/
│   ├── ETLPipelineConfig.java
│   ├── readers/                          # MarkdownDocumentReader, PagePdfDocumentReader
│   ├── transformers/                     # ContentFormatTransformer, DocumentChunkTransformer, KoreanSentenceSplitter(선택)
│   └── writers/                          # VectorStoreDocumentWriter
├── model/
│   └── DocumentMetadata.java             # JPA 엔티티 (filename, hash, sourceClient 등)
├── repository/
│   └── DocumentMetadataRepository.java
├── security/
│   └── ApiSecurityFilter.java            # WebFilter: REST IP·API 키 검증
├── service/
│   ├── DateTimeService.java
│   ├── DocumentIngestService.java
│   ├── DocumentManagementService.java
│   ├── DocumentSearchService.java
│   └── impl/
│       ├── DateTimeServiceImpl.java               # @McpTool: getCurrentDateTimeWithZone
│       ├── DocumentIngestServiceImpl.java         # @McpTool: ingestDocument
│       ├── DocumentManagementServiceImpl.java     # REST reindex 처리 (ETL 파이프라인)
│       └── DocumentSearchServiceImpl.java         # @McpTool: searchDocuments, describeKnowledgeBase
└── util/
    ├── DocumentHashUtil.java              # SHA-256 해시 계산
    ├── DocumentOverwriteForbiddenException.java
    ├── KoreanSentenceSupport.java          # 한국어 문장 경계 판정 유틸 (KoreanSentenceSplitter가 사용)
    ├── PromptInjectionDetector.java       # 자연어 프롬프트 인젝션 패턴 탐지
    ├── PromptInjectionDetectedException.java
    ├── RrfFusion.java                     # Reciprocal Rank Fusion (하이브리드 검색)
    └── StaleVectorCleaner.java            # 재임베딩 전 기존 벡터 선삭제

spring:
  ai:
    mcp:
      server:
        type: ASYNC
        protocol: STREAMABLE
        instructions: |
          이 서버는 RAG 지식 베이스 검색과 문서 적재를 제공합니다.
          - searchDocuments: 질문에 관련된 문서 청크를 벡터 유사도로 검색
          - ingestDocument: PDF/MD 적재 (전용 클라이언트에서만 호출)
        streamable-http:
          keep-alive-interval: 30s      # idle 연결 유지
    embedding.transformer.onnx:
      modelUri: file:${EMBEDDING_MODEL_PATH:${user.home}/spring-ai-Config/model/model.onnx}
    vectorstore.pgvector:
      dimensions: 768
      distance-type: COSINE_DISTANCE

server:
  port: 9090

app:
  security:
    api-keys:
      - "${MCP_API_KEY:}"               # 빈 문자열은 유효 키로 불인정 → 적재 차단
  rag:
    similarity-threshold: 0.30
    top-k: 5
    hybrid:
      enabled: false                    # true 시 dense + lexical RRF 융합 검색
      lexical.word-similarity-threshold: 0.30
  document:
    chunk-size: 4000
    min-chunk-size-chars: 350
    max-num-chunks: 500
    min-chunk-length-to-embed: 50
    chunking:
      korean-sentence:
        enabled: false                  # true 시 문장경계 인지 스플리터(KoreanSentenceSplitter) 사용
    normalization:
      normalize-newlines: true          # true면 문단 경계(빈 줄) 규칙 무력화 — 아래 "한국어 문장경계 청킹" 참고

springdoc:
  paths-to-exclude: /mcp/**            # Swagger에서 MCP 경로 제외