[클라이언트 요청]
     ↓
[NGINX Reverse Proxy]
     ↓
[Spring Boot 컨테이너]
     ├── Agent가 DispatcherServlet, Service, Repository 등 Hook
     ├── Transaction 및 Span 객체 생성
     └── 비동기로 APM Server로 전송
         ↓
[APM Server]
     └── JSON 수신 후 Elasticsearch로 전송
         ↓
[Elasticsearch]
     └── 문서화된 데이터 저장
         ↓
[Kibana]
     └── 트랜잭션 시각화 및 분석

  # APM Server 추가
  apm-server:
    image: docker.elastic.co/apm/apm-server:7.11.1
    container_name: apm-server
    environment:
      - output.elasticsearch.hosts=["elasticsearch:9200"]
      - apm-server.host=0.0.0.0:8200
      - apm-server.frontend.enabled=true
      - apm-server.frontend.rate_limit=100000
      - apm-server.read_timeout=1m
      - apm-server.shutdown_timeout=2m
      - apm-server.write_timeout=1m
      - logging.level=info
    ports:
      - "8200:8200"
    networks:
      - elk
    depends_on:
      - elasticsearch

  # Spring app에 필요한 매개변수 추가	
  spring:
    image: ghcr.io/anonichat/app/anonichat
    expose:
      - "8080"
    environment:
      - ELASTICSEARCH_HOST=elasticsearch:9200
		...생략
		ELASTIC_APM_SERVICE_NAME=anonichat-app          # APM에서 표시될 서비스명
		ELASTIC_APM_SERVER_URLS=http://apm-server:8200  # APM 서버 주소
		ELASTIC_APM_APPLICATION_PACKAGES=com.anonichat  # 모니터링할 패키지
		ELASTIC_APM_ENVIRONMENT=docker                  # 환경 구분
		ELASTIC_APM_LOG_LEVEL=INFO                      # 로그 레벨
		ELASTIC_APM_ENABLE_LOG_CORRELATION=true         # 로그 연관성 활성화
    depends_on:
      - elasticsearch
      - mysql
    networks:
      - elk
      - data

# Kibana APM 활성화에 필요한 매개변수 추가
  kibana:
    image: docker.elastic.co/kibana/kibana:7.11.1
    ports:
      - "5601:5601"
    networks:
      - elk
    environment:
      ... 생략
      - xpack.apm.ui.enabled=true # Kibana에서 APM 메뉴 활성화
    depends_on:
      - elasticsearch

# apm agent jar 추가
RUN curl -o /app/elastic-apm-agent.jar \  
    https://repo1.maven.org/maven2/co/elastic/apm/elastic-apm-agent/1.28.4/elastic-apm-agent-1.28.4.jar

# apm agent 실행 명령어 추가
ENTRYPOINT ["java", "-javaagent:/app/elastic-apm-agent.jar", "-jar", "/app/AnoniChatApp.jar"]

# dependency 추가

// Elastic APM Agent (프로그래밍 방식 연결용)
implementation 'co.elastic.apm:apm-agent-attach:1.50.0'

// APM Spring Boot Starter (자동 설정 - Spring Boot 3.x 호환)
implementation 'co.elastic.apm:elastic-apm-spring-boot-starter:1.50.0'

// APM과 로그 연동 (ECS 로그 형식)
implementation 'co.elastic.logging:logback-ecs-encoder:1.6.0'

# APM 설정
elastic.apm.service-name=${ELASTIC_APM_SERVICE_NAME:anonichat-app}
elastic.apm.server-urls=${ELASTIC_APM_SERVER_URLS:http://localhost:8200}
elastic.apm.application-packages=${ELASTIC_APM_APPLICATION_PACKAGES:Anoni}
elastic.apm.environment=${ELASTIC_APM_ENVIRONMENT:local}
elastic.apm.enabled=${ELASTIC_APM_ENABLED:true}
elastic.apm.transaction-sample-rate=${ELASTIC_APM_SAMPLE_RATE:1.0}

<?xml version="1.0" encoding="UTF-8"?>
<configuration>

	... 생략

    <!-- ECS 형식 appender (Elastic Stack 최적화, APM 완벽 연동) -->
    <appender name="ECS_LOGSTASH" class="net.logstash.logback.appender.LogstashTcpSocketAppender">
        <destination>logstash:5000</destination>  <!-- 기존 포트 5000 사용 -->
        <encoder class="co.elastic.logging.logback.EcsEncoder">
            <!-- APM 서비스명 설정 -->
            <serviceName>${elastic.apm.service-name:-anonichat-app}</serviceName>
            <!-- APM 트레이스 정보 자동 포함 -->
            <includeMarkers>true</includeMarkers>
            <includeMdc>true</includeMdc>
        </encoder>
        <keepAliveDuration>5 minutes</keepAliveDuration>
    </appender>

	... 생략

    <!-- APM 관련 로그 레벨 설정 -->
    <logger name="co.elastic.apm" level="INFO" additivity="false">
        <appender-ref ref="CONSOLE" />
    </logger>

</configuration>

input {
    beats {
        port => 5044
    }
    tcp {
        port => 5000
        codec => json_lines
        type => "main_log"
    }

}

filter {
    if [type] == "main_log" {
        if [log.level] in ["ERROR", "INFO", "FATAL"] { # INFO는 현재 기능 테스트를 위해 넣음
            mutate {
                add_field => { "alert_needed" => "true" }
            }
        }
    }
}

output {
	# 5000번 포트로 오는 모든 알림은 `main_log로 들어와 elastic에 저장`
    if [type] == "main_log" {
        elasticsearch {
            hosts => ["http://elasticsearch:9200"]
            index => "main_log"
        }
    }

######################## 추가 부분 ##########################
	# ["ERROR", "INFO", "FATAL"] 에 해당 하는 알림은 슬렉으로 output 처리
    if [alert_needed] == "true" { # error 레벨 발생 시 알려줌
        http {
            url => "https://hooks.slack.com/services/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"  # output 플러그인 사용
            http_method => "post" # Slack Webhook URL로 `POST` 요청 전송.
            content_type => "application/json"
            format => "json"
            mapping => { # 메시지는 `%{}` 문법으로 필드 값을 문자열에 삽입:
                "text" => 
				"🚨 *AnoniChat 에러 발생!*```
                레벨: %{[log.level]}
				시간: %{[@timestamp]}
				스레드: %{[process.thread.name]}
				로거: %{[log.logger]}
				메시지: %{message}
				Trace ID: %{[trace.id]}
				서비스: %{[service.name]}
				```"
                "channel" => "#anonichat-error-log"
            }
        }
    }
    
##########################################################
}

docker-compose restart logstash

@GetMapping(GlobalURL.MAIN_URL)  
public ModelAndView mainView() {  
    log.info("[MainController Log] mainView 접속 TEST");  
  
    List<TestEntity> list = testRepository.findAll();  
    log.info("[MainController Log] test_table data: {}", list);  
  
    return new ModelAndView("main");  
}