[發(fā)明專(zhuān)利]基于分布式即時(shí)推送的Web頁(yè)面狀態(tài)更新方法及裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 202110243204.8
• 申請(qǐng)日: 2021-03-05
• 公開(kāi)（公告）號(hào): CN113037834A
• 公開(kāi)（公告）日: 2021-06-25
• 發(fā)明（設(shè)計(jì)）人: 張穎;郭建廷;尹學(xué)壯;余滿(mǎn)江
• 申請(qǐng)（專(zhuān)利權(quán)）人: 中國(guó)工商銀行股份有限公司
• 主分類(lèi)號(hào): H04L29/08
• 分類(lèi)號(hào): H04L29/08;H04L29/06
• 代理公司: 北京三友知識(shí)產(chǎn)權(quán)代理有限公司 11127
• 代理人: 任默聞;孫乳筍

1.一種基于分布式即時(shí)推送的Web頁(yè)面狀態(tài)更新方法，其特征在于，包括：

接收客戶(hù)端Web頁(yè)面所發(fā)送的長(zhǎng)連接請(qǐng)求；

響應(yīng)于所述長(zhǎng)連接請(qǐng)求，隨機(jī)發(fā)送所述長(zhǎng)連接請(qǐng)求至多個(gè)服務(wù)端上，以建立多個(gè)長(zhǎng)連接；

根據(jù)所述長(zhǎng)連接分別建立服務(wù)端地址與客戶(hù)端編號(hào)之間的第一映射以及所述客戶(hù)端編號(hào)與長(zhǎng)連接編號(hào)之間的第二映射；

根據(jù)所述第一映射以及所述第二映射推送所述服務(wù)端更新的數(shù)據(jù)至所述客戶(hù)端Web頁(yè)面。

2.根據(jù)權(quán)利要求1所述的Web頁(yè)面狀態(tài)更新方法，其特征在于，所述根據(jù)所述長(zhǎng)連接分別建立接建立服務(wù)端地址與客戶(hù)端編號(hào)之間的第一映射以及述客戶(hù)端編號(hào)與長(zhǎng)連接編號(hào)之間的第二映射，包括：

將所述第一映射存儲(chǔ)在Redis緩存中；

將所述第二映射存儲(chǔ)在所述服務(wù)端中。

3.根據(jù)權(quán)利要求2所述的Web頁(yè)面狀態(tài)更新方法，其特征在于，所述根據(jù)所述第一映射以及所述第二映射推送所述服務(wù)端更新的數(shù)據(jù)至所述客戶(hù)端Web頁(yè)面，包括：

若所述服務(wù)端進(jìn)行同步或異步數(shù)據(jù)更新，則根據(jù)所述第一映射從所述Redis緩存中讀取服務(wù)端地址；以及

根據(jù)所述第二映射從所述服務(wù)端中讀取客戶(hù)端地址；

根據(jù)所述服務(wù)端地址以及所述客戶(hù)端地址將所述服務(wù)端更新后的數(shù)據(jù)推送至所述客戶(hù)端Web頁(yè)面。

4.根據(jù)權(quán)利要求1所述的Web頁(yè)面狀態(tài)更新方法，其特征在于，還包括：

建立所述長(zhǎng)連接所對(duì)應(yīng)的客戶(hù)端Socket；

利用Netty框架監(jiān)聽(tīng)所述客戶(hù)端Socket中數(shù)據(jù)的讀取以及寫(xiě)入。

5.根據(jù)權(quán)利要求1所述的Web頁(yè)面狀態(tài)更新方法，其特征在于，還包括：

通過(guò)Dubbo對(duì)推送接口進(jìn)行注冊(cè)，以確定推送服務(wù)接口；

對(duì)所述服務(wù)端更新的數(shù)據(jù)進(jìn)行消息封裝；

將封裝后的消息推送至所述推送服務(wù)接口。

6.一種基于分布式即時(shí)推送的Web頁(yè)面狀態(tài)更新裝置，其特征在于，包括：

請(qǐng)求接收單元，用于接收客戶(hù)端Web頁(yè)面所發(fā)送的長(zhǎng)連接請(qǐng)求；

長(zhǎng)連接建立單元，用于響應(yīng)于所述長(zhǎng)連接請(qǐng)求，隨機(jī)發(fā)送所述長(zhǎng)連接請(qǐng)求至多個(gè)服務(wù)端上，以建立多個(gè)所述長(zhǎng)連接；

映射關(guān)系建立單元，用于根據(jù)所述長(zhǎng)連接分別建立接建立服務(wù)端地址與客戶(hù)端編號(hào)之間的第一映射以及述客戶(hù)端編號(hào)與長(zhǎng)連接編號(hào)之間的第二映射；

消息推送單元，用于根據(jù)所述第一映射以及所述第二映射推送所述服務(wù)端更新的數(shù)據(jù)至所述客戶(hù)端Web頁(yè)面。

7.根據(jù)權(quán)利要求6所述的Web頁(yè)面狀態(tài)更新裝置，其特征在于，所述映射關(guān)系建立單元包括：

第一映射緩存模塊，用于將所述第一映射存儲(chǔ)在Redis緩存中；

第二映射緩存模塊，用于將所述第二映射存儲(chǔ)在所述服務(wù)端中。

8.根據(jù)權(quán)利要求7所述的Web頁(yè)面狀態(tài)更新裝置，其特征在于，所述消息推送單元，包括：

服務(wù)端地址讀取模塊，用于根據(jù)所述第一映射從所述Redis緩存中讀取服務(wù)端地址；以及

客戶(hù)端地址讀取模塊，用于根據(jù)所述第二映射從所述服務(wù)端中讀取客戶(hù)端地址；

消息推送模塊，用于根據(jù)所述服務(wù)端地址以及所述客戶(hù)端地址將所述服務(wù)端更新后的數(shù)據(jù)推送至所述客戶(hù)端Web頁(yè)面。

9.根據(jù)權(quán)利要求6所述的Web頁(yè)面狀態(tài)更新裝置，其特征在于，還包括：

客戶(hù)端Socket建立單元，用于建立所述長(zhǎng)連接所對(duì)應(yīng)的客戶(hù)端Socket；

數(shù)據(jù)監(jiān)聽(tīng)單元，用于利用Netty框架監(jiān)聽(tīng)所述客戶(hù)端Socket中數(shù)據(jù)的讀取以及寫(xiě)入。

10.根據(jù)權(quán)利要求6所述的Web頁(yè)面狀態(tài)更新裝置，其特征在于，還包括：

服務(wù)接口確定單元，用于通過(guò)Dubbo對(duì)推送接口進(jìn)行注冊(cè)，以確定推送服務(wù)接口；

消息封裝單元，用于對(duì)所述服務(wù)端更新的數(shù)據(jù)進(jìn)行消息封裝；

封裝消息推送單元，用于將封裝后的消息推送至所述推送服務(wù)接口。