레플리케이션 — Master-Slave 구조와 동기화 원리

소스 서버 (Source)         복제본 서버 (Replica)
┌──────────────┐         ┌──────────────┐
│  쓰기 + 읽기  │ ──────→ │   읽기 전용    │
└──────────────┘  Binlog  └──────────────┘
                  전달          ↑
                          복제본 2, 3...도 가능

소스 서버                    복제본 서버
┌─────────────┐            ┌─────────────────────┐
│             │            │  I/O Thread          │
│ Binlog Dump │ ─Binlog──→ │  (Binlog 수신)        │
│ Thread      │  이벤트     │       │              │
│             │            │       ▼              │
│             │            │  Relay Log           │
│             │            │       │              │
│             │            │       ▼              │
│             │            │  SQL Thread          │
│             │            │  (이벤트 적용)         │
└─────────────┘            └─────────────────────┘

1. 소스에서 트랜잭션 커밋 → Binlog에 기록
2. 복제본의 I/O Thread가 소스에 연결
3. Binlog Dump Thread가 이벤트를 전송
4. I/O Thread가 수신한 이벤트를 relay log에 기록
5. SQL Thread가 relay log를 읽어 순서대로 적용
6. 적용 완료된 포지션/GTID를 기록

소스: COMMIT → Binlog 기록 → 클라이언트에 성공 반환 (여기서 끝)
              ↓
              (비동기로) 복제본에 전달 → 복제본 적용

소스: COMMIT → Binlog 기록 → 복제본에 전달 → ACK 대기
                                              ↓
복제본: 이벤트 수신 → relay log 기록 → ACK 전송 (적용은 아직 안 함)
                                              ↓
소스: ACK 수신 → 클라이언트에 성공 반환

-- 소스에서 반동기 복제 플러그인 설치
INSTALL PLUGIN rpl_semi_sync_source SONAME 'semisync_source.so';
SET GLOBAL rpl_semi_sync_source_enabled = ON;

-- 복제본에서
INSTALL PLUGIN rpl_semi_sync_replica SONAME 'semisync_replica.so';
SET GLOBAL rpl_semi_sync_replica_enabled = ON;

-- 타임아웃 설정 (ACK 대기 시간, 기본 10초)
SET GLOBAL rpl_semi_sync_source_timeout = 10000;

┌──────┐  ┌──────┐  ┌──────┐
│ 멤버1 │──│ 멤버2 │──│ 멤버3 │
│(R/W)  │  │(R/O)  │  │(R/O)  │
└──────┘  └──────┘  └──────┘
    ↕          ↕          ↕
    합의 프로토콜 (Paxos 기반)

-- 그룹 복제 설정 (각 멤버)
SET GLOBAL group_replication_group_name = "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee";
SET GLOBAL group_replication_local_address = "10.0.1.1:33061";
SET GLOBAL group_replication_group_seeds = "10.0.1.1:33061,10.0.1.2:33061,10.0.1.3:33061";

-- 그룹 시작 (첫 번째 멤버)
SET GLOBAL group_replication_bootstrap_group = ON;
START GROUP_REPLICATION;
SET GLOBAL group_replication_bootstrap_group = OFF;

-- 다른 멤버 추가
START GROUP_REPLICATION;

-- 복제본에서 실행
SHOW REPLICA STATUS\G
-- Seconds_Behind_Source: 복제본이 소스보다 뒤처진 초 수
-- 0이면 동기화 완료, NULL이면 복제 중단

-- 복제본에서 병렬 적용 활성화
SET GLOBAL replica_parallel_workers = 8;           -- 병렬 워커 수
SET GLOBAL replica_parallel_type = 'LOGICAL_CLOCK'; -- 소스의 병렬성 재현
SET GLOBAL replica_preserve_commit_order = ON;      -- 커밋 순서 보장

-- 나쁜 예: 한 번에 100만 행 업데이트
UPDATE orders SET status = 'archived' WHERE created_at < '2024-01-01';

-- 좋은 예: 배치로 나눠서 실행
REPEAT
    UPDATE orders SET status = 'archived'
    WHERE created_at < '2024-01-01' AND status != 'archived'
    LIMIT 10000;
UNTIL ROW_COUNT() = 0 END REPEAT;

// 쓰기는 소스, 읽기는 복제본으로 라우팅
@Transactional(readOnly = false)
public void createOrder(Order order) {
    // 소스 서버에 연결
    orderRepository.save(order);
}

@Transactional(readOnly = true)
public List<Order> findOrders() {
    // 복제본 서버에 연결
    return orderRepository.findAll();
}

클라이언트 → ProxySQL → 쓰기: 소스
                      → 읽기: 복제본 (라운드 로빈)

1. 주문 생성 (소스에 쓰기)
2. 주문 조회 (복제본에서 읽기) → 아직 반영 안 됨!

-- 복제 상태 전체 확인
SHOW REPLICA STATUS\G

-- 핵심 지표
-- Replica_IO_Running: I/O Thread 상태 (Yes/No)
-- Replica_SQL_Running: SQL Thread 상태 (Yes/No)
-- Seconds_Behind_Source: 지연 시간
-- Last_IO_Error: I/O Thread 에러
-- Last_SQL_Error: SQL Thread 에러

-- Performance Schema로 상세 모니터링
SELECT * FROM performance_schema.replication_connection_status\G
SELECT * FROM performance_schema.replication_applier_status_by_worker\G