zookeeper 원본 분석 삼LEADER와 FOLLOWER 동기화 데이터 프로세스

2)의 분석에 의하면 만약에 zookeeper 서버가 집단의leader가 된다면 반드시 현재 모든 서버에서 데이터를 가장 많이 저장하는 서버가 될 것이다. 그래서 이 서버가leader가 된 후에 가장 먼저 해야 할 일은 집단 중의 다른 서비스기(현재는follower)와 데이터를 동기화하여 모두의 데이터가 일치하도록 하는 것이다. 이 과정이 끝나야 클라이언트로부터의 연결 요청을 정식으로 처리하기 시작한다.
먼저 Leader가 하는 일을 살펴보자. 2) 데이터를 동기화할 때 사용하는 논리 시계의 초기 값은 0이고 선거 과정마다 점차적으로 증가한다. 리더가 정식으로 취임한 후에 하는 첫 번째 일은 현재 저장된 데이터 id 값에 따라 최신 논리 시계 값을 설정하는 것이다.

long epoch = self.getLastLoggedZxid() >> 32L;
            epoch++;
            zk.setZxid(epoch << 32L);

(함수 Leader::lead() 중)
그 다음에leader는 NEW LEADER 패키지를 구축했다. 이 패키지의 데이터는 현재 최대 데이터의 id이다. 모든follower에게 방송한다. 즉follower leader가 저장한 데이터 id가 얼마인지 알려주고 동기화가 필요한지 보자.그리고 리더는follower 수량에 따라 각각follower에 라인LearnerHandler를 만들어 동기화 데이터 요청을 전문적으로 수신합니다.리더의 메인 라인이 여기에 막히기 시작하고 다른follower의 응답(즉 LearnerHandler 라인의 처리 결과)을 기다린다. 마찬가지로 절반이 넘는 폴더가 동기화된 데이터가 끝나야만 이 과정이 끝나고 리더가 정식으로 리더가 될 수 있다.
그래서 사실 리더와follower가 데이터를 동기화하는 대부분의 작업은 LearnerHandler 라인에서 처리되고 이어서 이 부분을 본다.leader가 수신한 어떤follower 패키지는 반드시 FOLLOWERINFO입니다. 이 패키지는 이 서버에 저장된 데이터 id를 알려 줍니다. 그 다음에 이 데이터 id와 본 컴퓨터에 저장된 데이터를 비교합니다. 1) 데이터가 완전히 일치하면 DIFF 패키지를 보내서 follower의 현재 수치가 최신입니다.2) 이 단계에서 이미 제출된 제안 값이 있는지 판단하고 있다면: a) 일부 데이터가 동기화되지 않으면 DIFF 패키지를 보내서 차이가 있는 데이터를 동기화합니다.follower에 없는 데이터를 하나하나COMMIT로 보내서 follower에 기록해 달라고 합니다.b) follower 데이터 id가 더 크면 TRUNC 패키지를 보내서 여분의 데이터를 차단합니다.3) 이 단계에서 제출된 제안 값이 없으면 SNAP 패키지를 보내서 스냅샷을 follower에 동기화합니다.이상의 메시지가 끝난 후, UPTODATE 패키지를 보내follower의 현재 데이터가 최신이라는 것을 알리고, 다시 NEW LEADER 패키지를 보내서 자신이leader라고 선언하고follower의 응답을 기다립니다.
그 다음에 팔로워가 하는 일을 보면 팔로워와 리더가 데이터를 동기화하는 작업은 함수 팔로워::팔로우 리더에서 진행된다.우선leader와 연결을 시도할 것입니다. 여기에는 일정한 시간 내에 연결이 없으면 오류를 보고하고 물러나 다시 선거 상태로 돌아가는 메커니즘이 있습니다.그 다음에 함수 Learner::register With Leader에서 FOLLOWERINFO 패키지를 보냅니다. 이 패키지에는 자신의 최대 데이터 id가 포함되어 있습니다. 즉, Leader 본체에 저장된 최대 데이터 id를 알려줍니다. 마지막으로 앞에서 Leader Handler에 대한 분석에 따라 Leader는 상황에 따라 DIFF, UPTODATE, TRUNC, SNAP를 보냅니다. 순서대로 처리하면 됩니다. 이때 follower와 Leader의 데이터가 동기화됩니다.leader 측에서 보내는 마지막 패키지는 UPTODATE이기 때문에 이 패키지를 받은 후 follower가 동기화 데이터 과정을 끝내고 ACK 패키지를 보내서 leader에게 답장합니다.
이 과정에서 어떠한 경우에도 오류가 발생하면 서버는 자동으로 선거 상태를 LOOKING 상태로 전환하여 선거를 다시 시작합니다.
다음으로 전송:https://www.cnblogs.com/hadoop-dev/p/5946870.html