原文鏈接:https://blog.csdn.net/coder_ken/article/details/50920606
應(yīng)用場景
假設(shè)我們在做一個通訊錄軟件吃粒,我們可以在多個客戶端對服務(wù)端的數(shù)據(jù)進行增刪改。那么這篇文章中我們要解決的問題是如何在客戶端與服務(wù)端只傳輸經(jīng)過增刪改操作的數(shù)據(jù),來使得客戶端與服務(wù)端的數(shù)據(jù)是同步的。
名詞解釋
Anchor:同步錨點,用時間戳來表示,用來發(fā)現(xiàn)兩端數(shù)據(jù)變化的部分
客戶端表設(shè)計
每條記錄包含兩個用來同步用的字段:
status : 用來標識記錄的狀態(tài)
anchor : 記錄服務(wù)端同步過來的時間戳
anchor | 含義 |
---|---|
0 | 本地新增 |
-1 | 標記刪除 |
1 | 本地更新 |
9 | 已同步 |
服務(wù)端表設(shè)計
modified : 服務(wù)端修改記錄的時間戳
雙向同步過程
初始狀態(tài)下秒旋,我們假設(shè)客戶端和服務(wù)端的表各有兩條數(shù)據(jù)
客戶端:
id | name | phone | status | anchor |
---|---|---|---|---|
1 | Ken | 18612345678 | 9 | 2 |
2 | Jim | 13888888888 | 9 | 3 |
服務(wù)端:
id | name | phone | modified |
---|---|---|---|
1 | Ken | 18612345678 | 2 |
2 | Jim | 13888888888 | 3 |
此時,客戶端與服務(wù)端的數(shù)據(jù)是完全同步好了的
Client增加1條記錄
id | name | phone | status | anchor |
---|---|---|---|---|
1 | Ken | 18612345678 | 9 | 2 |
2 | Jim | 13888888888 | 9 | 3 |
3 | Tim | 12345678 | 0 | 0 |
Client修改1條記錄
id | name | phone | status | anchor |
---|---|---|---|---|
1 | Ken | 18612345678 | 9 | 2 |
2 | Jim | 13888888888 | 1 | 3 |
3 | Tim | 12345678 | 0 | 0 |
注: 因為上面的數(shù)據(jù)不是從服務(wù)端同步過來的诀拭,所以anchor默認為0
Client發(fā)送本地更新
SELECT * FROM table WHERE status < 9
客戶端執(zhí)行上面的SQL語句迁筛,找出客戶端需要同步到服務(wù)端的記錄。通過網(wǎng)絡(luò)串行的發(fā)送給服務(wù)端耕挨。上一條請求沒有得到回應(yīng)的話细卧,就不能進行下一個請求尉桩。
下表中的數(shù)據(jù)是發(fā)送的同步消息
id | name | phone | status | anchor |
---|---|---|---|---|
2 | Jim | 010-12345678 | 1 | 3 |
3 | Tim | 12345678 | 0 | 0 |
Server處理同步消息
服務(wù)端串行的收到客戶端發(fā)送過來的數(shù)據(jù),首先處理第一條數(shù)據(jù)
id | name | phone | status | anchor |
---|---|---|---|---|
2 | Jim | 010-12345678 | 1 | 3 |
服務(wù)端收到請求后需要對比客戶端的anchor和服務(wù)端的modified贪庙,只有服務(wù)端modified=客戶端anchor才能繼續(xù)同步魄健,否則說明客戶端在上一次同步后服務(wù)端更新過數(shù)據(jù),需要解決沖突后才能繼續(xù)插勤,接著根據(jù)status的值為1沽瘦,那么服務(wù)端執(zhí)行UPDATE語句
UPDATE table SET (name, phone) VALUES (?, ?) WHERE id = ?
其次,處理第二條數(shù)據(jù)
id | name | phone | status | anchor |
---|---|---|---|---|
3 | Tim | 12345678 | 0 | 0 |
如果得知anchor = 0农尖,直接執(zhí)行INSERT 語句
INSERT INTO table (id, name, phone) VALUES(?, ?, ?)
服務(wù)端經(jīng)過這兩次操作后析恋,數(shù)據(jù)表如下
id | name | phone | modified |
---|---|---|---|
1 | Ken | 18612345678 | 2 |
2 | Jim | 010-12345678 | 6 |
3 | Tim | 12345678 | 8 |
Client根據(jù)響應(yīng)更新本地記錄
服務(wù)端處理完數(shù)據(jù)后,還要響應(yīng)客戶端的請求盛卡,如下
id | status | anchor |
---|---|---|
2 | 9 | 6 |
3 | 9 | 8 |
收到響應(yīng)后助隧,客戶端就開始執(zhí)行UPDATE了
UPDATE table SET status = ?, anchor = ? WHERE id = ?
客戶端現(xiàn)在的數(shù)據(jù)表如下:
id | name | phone | status | anchor |
---|---|---|---|---|
1 | Ken | 18612345678 | 9 | 2 |
2 | Jim | 010-12345678 | 9 | 3->6 |
3 | Tim | 12345678 | 9 | 0->8 |
Server增加一條數(shù)據(jù)并更新一條數(shù)據(jù)
id | name | phone | modified |
---|---|---|---|
1 | Ken | 00000000 | 11 |
2 | Jim | 010-12345678 | 6 |
3 | Tim | 12345678 | 8 |
4 | Bill | 88888888 | 10 |
Client向Server請求數(shù)據(jù)
因為服務(wù)端modified字段代表的是時間戳,所以Max(anchor)表示客戶端最近一次同步的時間滑沧,如果存在服務(wù)端modified > Max(anchor)并村,說明服務(wù)端需要向客戶端同步數(shù)據(jù)。
服務(wù)器端執(zhí)行下面的SQL語句:
SELECT * FROM table WHERE modified > Max(anchor)
返回下表中的數(shù)據(jù):
id | name | phone | modified |
---|---|---|---|
1 | Ken | 00000000 | 11 |
4 | Bill | 88888888 | 10 |
Client處理同步消息
客戶端根據(jù)增量數(shù)據(jù)更新本地表滓技,處理數(shù)據(jù)時哩牍,只能更新狀態(tài)為已同步或者不存在的數(shù)據(jù)
id | name | phone | status | anchor |
---|---|---|---|---|
1 | Ken | 00000000 | 9 | 2->11 |
2 | Jim | 010-12345678 | 9 | 6 |
3 | Tim | 12345678 | 9 | 8 |
4 | Bill | 88888888 | 9 | 10 |
客戶端刪除記錄
邏輯刪除記錄
id | name | phone | status | anchor |
---|---|---|---|---|
1 | Ken | 00000000 | -1 | 15 |
2 | Jim | 010-12345678 | 9 | 6 |
3 | Tim | 12345678 | 9 | 8 |
4 | Bill | 88888888 | 9 | 10 |
客戶端發(fā)送消息到服務(wù)端
根據(jù)status < 9,將邏輯刪除的記錄發(fā)送至服務(wù)端令漂,服務(wù)端收到消息后膝昆,將該記錄移至deleted_table(相當于時光機,以后可以進行數(shù)據(jù)的恢復(fù))表中
id | name | phone | modified |
---|---|---|---|
1 | Ken | 00000000 | 16 |
服務(wù)端響應(yīng)客戶端的請求
id | status | anchor |
---|---|---|
1 | -1 | 16 |
客戶端收到響應(yīng)
客戶端直接進行物理刪除
服務(wù)端刪除記錄
如果客戶端從服務(wù)端獲取的增量信息中包含刪除記錄的消息叠必,則客戶端直接進行物理刪除