스프링 부트 애플리케이션 입장에서 샤딩된 DB를 쓰기 위해서 직접 “복잡한” 코드를 많이 짤 필요는 없습니다. 대신, 주로 다음 두 가지 레벨 중 하나의 방식으로 샤딩을 처리하게 됩니다.

1. 외부 프록시/미들웨어 사용 (Mycat, Vitess, ProxySQL 등)

• 애플리케이션 변경 제로 또는 최소화

  • 샤드별 DB URL(호스트/포트) 대신, 프록시의 단일 접점(가상 호스트/포트)을 spring.datasource.url에 지정
  • 트래픽·샤드 키 기반 분기 로직은 프록시가 대신 수행

• 구현 사항

  1. application.yml에 한번만 프록시 접점 정보 등록

     spring:
       datasource:
         url: jdbc:mysql://proxy.example.com:3306/app_db
         username: app
         password: secret
     

  2. 필요 시 트랜잭션 격리, 커넥션 풀, 리플리카 읽기 전용 설정 등 추가 구성

데이터베이스(DB) 샤딩(DB Sharding)이란 대용량 데이터를 효율적으로 분산·관리하기 위해 하나의 거대한 데이터베이스를 여러 개의 작은 조각(샤드, shard)으로 나누어 각각을 별도의 서버에 분산 저장하고 처리하는 기법을 말합니다.

1. 왜 샤딩이 필요한가?

• 성능 확장성(Scalability)

  • 단일 서버에 모든 데이터를 저장하면 저장 용량·처리 능력이 한계에 부딪힙니다.
  • 데이터와 트래픽이 늘어날수록 로드가 집중되어 응답 지연(latency)이나 병목(bottleneck)이 발생합니다.

• 고가용성(High Availability)

  • 각 샤드를 독립된 노드에 두면, 일부 노드 장애 시에도 전체 시스템이 완전히 다운되지 않고 가용성을 유지할 수 있습니다.

• 관리 용이성

배경

• local, dev, prod 등 프로파일에선 mysql 셋팅
• test 프로파일은 h2에 schema.sql, data.sql로 데이터 셋팅
• nativeQuery를 사용하는 경우 DATE_FORMAT 같은 mysql 함수 사용.

spring:
  datasource:
    url: jdbc:h2:mem:testdb;MODE=MYSQL;DB_CLOSE_DELAY=-1

DATE_FORMAT 대체

public class H2Functions {
    public static String formatDate(java.sql.Timestamp timestamp, String format) {
        return new java.text.SimpleDateFormat(format).format(timestamp);
    }
}

schema.sql

CREATE ALIAS IF NOT EXISTS DATE_FORMAT FOR "com.example.H2Functions.formatDate";

Repository

@Query(value = "SELECT DATE_FORMAT(order_date, 'yyyy-MM-dd') AS formatted_date, COUNT(*) " +
               "FROM orders GROUP BY formatted_date", nativeQuery = true)
List<Object[]> findOrderCountGroupedByDate();

위의 코드는 예시이며, 실제로는 h2와 mysql에서 format으로 넘겨주는 형태가 다릅니다. mysql에서는 %m%d, %Y 등으로 쓰고 h2에선 ‘MMdd’, ‘yyyy’ 등을 사용합니다.

MySQL에서 Slow Query(슬로우 쿼리) 를 모니터링하는 것은 성능 최적화를 위한 중요한 작업입니다. 다음은 슬로우 쿼리를 모니터링하는 일반적인 방법들입니다:

1. 슬로우 쿼리 로그 활성화하기

슬로우 쿼리를 기록하기 위해 MySQL 설정을 조정합니다.

방법 1: my.cnf 또는 my.ini 파일 수정

[mysqld]
slow_query_log = 1
slow_query_log_file = /var/log/mysql/slow.log
long_query_time = 1
log_queries_not_using_indexes = 1

• slow_query_log: 슬로우 쿼리 로그 기능 활성화
• slow_query_log_file: 로그 파일 위치
• long_query_time: 몇 초 이상 걸리는 쿼리를 느린 쿼리로 간주할지 설정 (초 단위)
• log_queries_not_using_indexes: 인덱스를 사용하지 않는 쿼리도 로그에 기록

설정 후 MySQL을 재시작해야 반영됩니다.

MSA(Microservices Architecture) 환경에서 서비스 간 호출 중 오류가 발생했을 때의 트랜잭션 처리 정책은 일반적으로 분산 트랜잭션 또는 사후 보상 트랜잭션(Compensating Transaction) 방식으로 구분되며, 다음과 같은 용어와 정책으로 설명됩니다.

1. SAGA 패턴

• 정의: MSA에서 가장 널리 쓰이는 트랜잭션 처리 패턴으로, 각 서비스의 로컬 트랜잭션이 성공하면 다음 서비스를 호출하고, 중간에 실패 시 이전에 수행된 작업을 보상 작업(Compensation) 으로 되돌립니다.

• 종류:

  • Choreography 기반: 서비스들이 이벤트를 발행하고 서로 구독하면서 트랜잭션을 이어감. 오케스트레이터가 없음.
  • Orchestration 기반: 중앙 컨트롤러(오케스트레이터)가 전체 트랜잭션 흐름을 제어.

• 예시: 주문 → 결제 → 배송 순서에서 결제 실패 시, 주문을 취소하는 보상 트랜잭션 수행.

자바(Java)에서 **싱글톤 패턴(Singleton Pattern)**은 특정 클래스의 인스턴스를 하나만 생성하고, 전체 애플리케이션에서 공유할 수 있도록 보장하는 디자인 패턴입니다. 주로 공통된 설정, 로깅, 스레드 풀, 캐시, DB 연결 관리 등에 사용됩니다.

✅ 싱글톤 패턴의 핵심 개념

• 클래스의 인스턴스를 하나만 생성.
• 전역 접근점(Global Access Point) 제공.
• 생성자를 private으로 숨김.
• 정적 메서드로 인스턴스를 반환.

📦 싱글톤 패턴 구현 예제

1. 기본 싱글톤 (Lazy Initialization)

public class Singleton {
    private static Singleton instance;

    // 생성자를 private으로 설정하여 외부에서 new로 인스턴스 생성하지 못하도록 함
    private Singleton() {}

    // 인스턴스를 필요할 때 생성
    public static Singleton getInstance() {
        if (instance == null) {
            instance = new Singleton();
        }
        return instance;
    }

    public void showMessage() {
        System.out.println("Hello from Singleton!");
    }
}

사용 예시: