CAP 이론

-- 동기 복제: 대기 서버의 확인을 받아야 커밋이 끝난다 (내구성 쪽)
ALTER SYSTEM SET synchronous_standby_names = 'FIRST 1 (standby1, standby2)';
ALTER SYSTEM SET synchronous_commit = 'on';
SELECT pg_reload_conf();

SELECT application_name, state, sync_state
FROM pg_stat_replication;                         -- sync_state: sync, potential, async, quorum

-- 이 트랜잭션만 대기 서버를 기다리지 않는다 (응답 속도 쪽)
BEGIN;
SET LOCAL synchronous_commit = 'local';
UPDATE account SET balance = balance - 100 WHERE id = 1;
COMMIT;

class Node:
    def __init__(self):
        self.x = 1

class Cluster:
    def __init__(self, mode):
        self.a, self.b, self.link, self.mode = Node(), Node(), True, mode

    def write_a(self, v):
        self.a.x = v
        if self.link:
            self.b.x = v                      # 연결이 있으면 B로 복제

    def read_b(self):
        if self.link or self.mode == 'AP':
            return self.b.x                   # AP는 가진 값으로 응답
        raise TimeoutError('최신값 확인 불가')   # CP는 응답을 거절

for mode in ('CP', 'AP'):
    c = Cluster(mode)
    c.write_a(2)
    c.link = False                            # 네트워크 분할
    c.write_a(3)
    try:
        print(mode, '분할 중 읽기:', c.read_b())
    except TimeoutError as e:
        print(mode, '분할 중 읽기:', e)
    c.link = True                             # 복구 후 B가 따라잡음
    c.b.x = c.a.x
    print(mode, '복구 후 읽기:', c.read_b())

writes = [(1, 'A', 3), (2, 'B', 5)]           # (시각, 노드, 값)
print('LWW 결과:', max(writes)[2])
# CP 분할 중 읽기: 최신값 확인 불가 / CP 복구 후 읽기: 3
# AP 분할 중 읽기: 2 / AP 복구 후 읽기: 3 / LWW 결과: 5

static boolean overlaps(int n, int w, int r) { return w + r > n; }          // 쓰기와 읽기 쿼럼이 겹치는가
static boolean canServe(int reachable, int need) { return reachable >= need; }

int n = 3;
for (int[] q : new int[][]{{2, 2}, {1, 1}, {3, 1}}) {
    int w = q[0], r = q[1];
    System.out.println("W=" + w + " R=" + r + " overlap=" + overlaps(n, w, r)
        + " 소수쪽(1대) 읽기=" + canServe(1, r) + " 다수쪽(2대) 읽기=" + canServe(2, r));
}
// W=2 R=2 overlap=true  소수쪽(1대) 읽기=false 다수쪽(2대) 읽기=true
// W=1 R=1 overlap=false 소수쪽(1대) 읽기=true  다수쪽(2대) 읽기=true
// W=3 R=1 overlap=true  소수쪽(1대) 읽기=true  다수쪽(2대) 읽기=true