[發(fā)明專利]一種分布式服務(wù)的實(shí)現(xiàn)方法、服務(wù)代理裝置及分布式系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201310542799.2
• 申請日: 2013-11-05
• 公開（公告）號: CN104618414B
• 公開（公告）日: 2018-05-04
• 發(fā)明（設(shè)計(jì)）人: 陸小亮;胡凌云;謝東凱
• 申請（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京國昊天誠知識產(chǎn)權(quán)代理有限公司11315
• 代理人: 許志勇

技術(shù)領(lǐng)域

本申請涉及計(jì)算機(jī)技術(shù)領(lǐng)域，具體涉及一種分布式服務(wù)的實(shí)現(xiàn)方法、服務(wù)代理裝置及分布式系統(tǒng)。

背景技術(shù)

隨著計(jì)算機(jī)技術(shù)的發(fā)展，可以將很多計(jì)算機(jī)組合成為一個分布式系統(tǒng)，通過分布式系統(tǒng)為用戶提供更好的服務(wù)。目前，分布式系統(tǒng)對外提供的服務(wù)有二類，一類是服務(wù)節(jié)點(diǎn)物理上有狀態(tài)的，即某類服務(wù)請求會被分配到固定的物理計(jì)算機(jī)進(jìn)行處理，另一類是服務(wù)節(jié)點(diǎn)物理上無狀態(tài)，即某類服務(wù)請求會被隨機(jī)分配到不同的物理機(jī)器進(jìn)行處理。

然而，服務(wù)節(jié)點(diǎn)物理上有狀態(tài)這類服務(wù)，一旦為某類服務(wù)請求服務(wù)的固定的物理計(jì)算機(jī)出現(xiàn)故障，進(jìn)行物理上的更換或修復(fù)耗時較長，會影響某類服務(wù)請求的實(shí)現(xiàn)。服務(wù)節(jié)點(diǎn)物理上無狀態(tài)這類服務(wù)，會因系統(tǒng)抖動等原因?qū)е履愁惙?wù)請求被多臺計(jì)算機(jī)重復(fù)處理，當(dāng)該某類服務(wù)請求有寫數(shù)據(jù)操作時，可能會造成數(shù)據(jù)不一致或?qū)憠臄?shù)據(jù)。

發(fā)明內(nèi)容

本申請所要解決的技術(shù)問題在于提供一種分布式服務(wù)的實(shí)現(xiàn)方法、服務(wù)代理裝置及分布式系統(tǒng)，通過根據(jù)服務(wù)請求信息中攜帶的用戶端標(biāo)識碼，獲取與該服務(wù)請求信息對應(yīng)的邏輯服務(wù)節(jié)點(diǎn)的信息，根據(jù)與邏輯服務(wù)節(jié)點(diǎn)對應(yīng)的物理服務(wù)節(jié)點(diǎn)的物理地址，查詢得到物理服務(wù)節(jié)點(diǎn)，通過邏輯服務(wù)節(jié)點(diǎn)實(shí)現(xiàn)了物理服務(wù)節(jié)點(diǎn)與服務(wù)請求的解耦，使服務(wù)請求與邏輯服務(wù)節(jié)點(diǎn)之間是有狀態(tài)的，服務(wù)請求會被分發(fā)到固定的邏輯服務(wù)節(jié)點(diǎn)，邏輯服務(wù)節(jié)點(diǎn)與物理服務(wù)節(jié)點(diǎn)之間是無狀態(tài)的，物理服務(wù)節(jié)點(diǎn)可以靈活快速變更，當(dāng)某服務(wù)請求的物理服務(wù)節(jié)點(diǎn)出現(xiàn)故障時，可以靈活快速地變更為其他物理服務(wù)節(jié)點(diǎn)，不會影響某服務(wù)請求的實(shí)現(xiàn)；同時查詢得到的物理服務(wù)節(jié)點(diǎn)在確定其自身的通用唯一識別碼，以及與邏輯服務(wù)節(jié)點(diǎn)對應(yīng)的物理服務(wù)節(jié)點(diǎn)的通用唯一識別碼二者一致后，才執(zhí)行與該服務(wù)請求對應(yīng)的服務(wù)，通過通用唯一識別碼有效性的驗(yàn)證，避免某服務(wù)請求被多個物理服務(wù)節(jié)點(diǎn)重復(fù)處理，保證寫的串行化。

為了解決上述問題，本申請公開了一種分布式服務(wù)的實(shí)現(xiàn)方法，包括：接收用戶端的服務(wù)請求信息，其中，所述服務(wù)請求信息中攜帶有用戶端標(biāo)識碼；根據(jù)所述用戶端標(biāo)識碼獲取與所述服務(wù)請求信息對應(yīng)的邏輯服務(wù)節(jié)點(diǎn)，并進(jìn)一步獲取所述邏輯服務(wù)節(jié)點(diǎn)的信息；其中，所述邏輯服務(wù)節(jié)點(diǎn)的信息包括與所述邏輯服務(wù)節(jié)點(diǎn)對應(yīng)的物理服務(wù)節(jié)點(diǎn)的物理地址以及與所述邏輯服務(wù)節(jié)點(diǎn)對應(yīng)的物理服務(wù)節(jié)點(diǎn)的通用唯一識別碼；根據(jù)所述物理地址查詢得到一物理服務(wù)節(jié)點(diǎn)，將所述服務(wù)請求信息以及所述通用唯一識別碼發(fā)送至查詢得到的物理服務(wù)節(jié)點(diǎn)；在確定所述查詢得到的物理服務(wù)節(jié)點(diǎn)自身的通用唯一識別碼與所述邏輯服務(wù)節(jié)點(diǎn)對應(yīng)的物理服務(wù)節(jié)點(diǎn)的通用唯一識別碼二者一致后，執(zhí)行與所述服務(wù)請求信息對應(yīng)的服務(wù)。

進(jìn)一步地，接收用戶端的服務(wù)請求信息之前，所述方法還包括：根據(jù)預(yù)設(shè)的總的邏輯服務(wù)節(jié)點(diǎn)的個數(shù)和預(yù)設(shè)的每個邏輯服務(wù)節(jié)點(diǎn)的名稱，從總的物理服務(wù)節(jié)點(diǎn)中獲取與每個邏輯服務(wù)節(jié)點(diǎn)對應(yīng)的物理服務(wù)節(jié)點(diǎn)；其中，總的物理服務(wù)節(jié)點(diǎn)的個數(shù)大于總的邏輯服務(wù)節(jié)點(diǎn)的個數(shù)；根據(jù)每個邏輯服務(wù)節(jié)點(diǎn)及其對應(yīng)的物理服務(wù)節(jié)點(diǎn)，建立節(jié)點(diǎn)信息列表，其中，所述節(jié)點(diǎn)信息列表中包括每個邏輯服務(wù)節(jié)點(diǎn)的信息；將所述節(jié)點(diǎn)信息列表中每個邏輯服務(wù)節(jié)點(diǎn)的信息，分別發(fā)送至與每個邏輯服務(wù)節(jié)點(diǎn)對應(yīng)的物理服務(wù)節(jié)點(diǎn)。

進(jìn)一步地，建立節(jié)點(diǎn)信息列表之后，所述方法還包括：獲取所述節(jié)點(diǎn)信息列表；根據(jù)所述節(jié)點(diǎn)信息列表中包括的每個邏輯服務(wù)節(jié)點(diǎn)的信息，建立與每個邏輯服務(wù)節(jié)點(diǎn)對應(yīng)的槽；其中，每個槽的名稱與其對應(yīng)的邏輯服務(wù)節(jié)點(diǎn)的名稱相同，總的槽的個數(shù)與總的邏輯服務(wù)節(jié)點(diǎn)的個數(shù)相同；將每個邏輯服務(wù)節(jié)點(diǎn)的信息分別存儲到與每個邏輯服務(wù)節(jié)點(diǎn)對應(yīng)的槽中。

進(jìn)一步地，將每個邏輯服務(wù)節(jié)點(diǎn)的信息分別存儲到與每個邏輯服務(wù)節(jié)點(diǎn)對應(yīng)的槽中之后，所述方法還包括：當(dāng)所述節(jié)點(diǎn)信息列表變更后，更新槽和/或槽中存儲的邏輯服務(wù)節(jié)點(diǎn)的信息。

進(jìn)一步地，當(dāng)邏輯服務(wù)節(jié)點(diǎn)的名稱為順序號，槽的名稱為順序號時，根據(jù)所述用戶端標(biāo)識碼獲取與所述服務(wù)請求信息對應(yīng)的邏輯服務(wù)節(jié)點(diǎn)，并進(jìn)一步獲取所述邏輯服務(wù)節(jié)點(diǎn)的信息，包括：利用預(yù)設(shè)的哈希函數(shù)對所述用戶端標(biāo)識碼進(jìn)行哈希運(yùn)算，得到哈希值；將所述哈希值對總的槽的個數(shù)的取模運(yùn)算結(jié)果，作為槽的順序號，所述槽的順序號對應(yīng)的槽中存儲的邏輯服務(wù)節(jié)點(diǎn)的信息為與所述服務(wù)請求信息對應(yīng)的邏輯服務(wù)節(jié)點(diǎn)的信息；從所述槽的順序號對應(yīng)的槽中，讀取得到與所述服務(wù)請求信息對應(yīng)的邏輯服務(wù)節(jié)點(diǎn)的信息。