[發(fā)明專(zhuān)利]一種服務(wù)器集群處理系統(tǒng)及方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201710485835.4
• 申請(qǐng)日: 2017-06-23
• 公開(kāi)（公告）號(hào): CN107222550B
• 公開(kāi)（公告）日: 2020-07-03
• 發(fā)明（設(shè)計(jì)）人: 方敏
• 申請(qǐng)（專(zhuān)利權(quán)）人: 武漢聚風(fēng)天下科技有限公司
• 主分類(lèi)號(hào): H04L29/08
• 分類(lèi)號(hào): H04L29/08;H04L12/26
• 代理公司: 北京輕創(chuàng)知識(shí)產(chǎn)權(quán)代理有限公司 11212
• 代理人: 楊立;陳璐

1.一種服務(wù)器集群處理系統(tǒng)，其特征在于，包括：連接服務(wù)器、消息服務(wù)器和至少一個(gè)前端服務(wù)器，所述前端服務(wù)器包括前端服務(wù)器緩存引擎和前端服務(wù)器會(huì)話控制模型；

所述連接服務(wù)器，用于接收客戶(hù)端發(fā)送的客戶(hù)端事件，若所述客戶(hù)端事件為視圖注冊(cè)類(lèi)事件，則判斷所述連接服務(wù)器是否有所述客戶(hù)端事件對(duì)應(yīng)的視圖注冊(cè)類(lèi)事件處理器，若無(wú)，則發(fā)送所述客戶(hù)端事件至所述消息服務(wù)器；

所述前端服務(wù)器緩存引擎，用于監(jiān)聽(tīng)所述消息服務(wù)器，獲取所述客戶(hù)端事件，如果所述客戶(hù)端事件為直接類(lèi)事件，發(fā)送所述客戶(hù)端事件至前端服務(wù)器會(huì)話控制模型，如果所述客戶(hù)端事件為緩存類(lèi)事件，首先處理所述客戶(hù)端事件得到客戶(hù)端事件處理結(jié)果列表，再發(fā)送所述客戶(hù)端事件處理結(jié)果列表至所述前端服務(wù)器會(huì)話控制模型；

所述前端服務(wù)器會(huì)話控制模型，用于分別處理所述客戶(hù)端事件和所述客戶(hù)端事件處理結(jié)果列表，得到客戶(hù)端事件處理結(jié)果，并發(fā)送所述客戶(hù)端事件處理結(jié)果至所述消息服務(wù)器；

所述連接服務(wù)器，還用于監(jiān)聽(tīng)所述消息服務(wù)器，并獲取所述客戶(hù)端事件處理結(jié)果，發(fā)送所述客戶(hù)端事件處理結(jié)果至所述客戶(hù)端；

所述前端服務(wù)器緩存引擎包括緩存引擎單元和前端服務(wù)器緩存類(lèi)事件處理器；

所述緩存引擎單元，用于監(jiān)聽(tīng)所述消息服務(wù)器，獲取所述客戶(hù)端事件，并取得所述客戶(hù)端事件對(duì)應(yīng)的前端服務(wù)器緩存類(lèi)事件處理器；

所述前端服務(wù)器緩存類(lèi)事件處理器，用于分別處理所述客戶(hù)端事件，得到所述客戶(hù)端事件處理結(jié)果列表；

所述緩存引擎單元，還用于發(fā)送所述客戶(hù)端事件處理結(jié)果列表至所述前端服務(wù)器會(huì)話控制模型；

所述前端服務(wù)器會(huì)話控制模型包括會(huì)話控制單元和前端服務(wù)器視圖數(shù)據(jù)模型；

所述會(huì)話控制單元，用于分配所述客戶(hù)端事件和所述客戶(hù)端事件處理結(jié)果列表至所述前端服務(wù)器視圖數(shù)據(jù)模型；

所述前端服務(wù)器視圖數(shù)據(jù)模型，用于處理所述客戶(hù)端事件，得到第一處理結(jié)果；處理所述客戶(hù)端事件處理結(jié)果列表，得到第二處理結(jié)果；

所述會(huì)話控制單元，還用于分別將所述第一處理結(jié)果和所述第二處理結(jié)果發(fā)送至所述消息服務(wù)器，其中，所述第一處理結(jié)果為視圖初始內(nèi)容，所述第二處理結(jié)果為所述視圖初始內(nèi)容的變更部分。

2.根據(jù)權(quán)利要求1所述的服務(wù)器集群處理系統(tǒng)，其特征在于，所述連接服務(wù)器包括連接服務(wù)器緩存引擎、連接服務(wù)器會(huì)話控制模型和前端服務(wù)器心跳監(jiān)視器；

所述連接服務(wù)器緩存引擎，用于監(jiān)聽(tīng)并獲取所述客戶(hù)端事件處理結(jié)果，發(fā)送所述客戶(hù)端事件處理結(jié)果至所述連接服務(wù)器會(huì)話控制模型；

所述連接服務(wù)器會(huì)話控制模型，用于發(fā)送所述客戶(hù)端事件處理結(jié)果至與所述連接服務(wù)器會(huì)話控制模型對(duì)應(yīng)的所述客戶(hù)端；

所述前端服務(wù)器心跳監(jiān)視器，用于監(jiān)視所述連接服務(wù)器和所述前端服務(wù)器的通信時(shí)間，如果當(dāng)前通信時(shí)間與最近一次通信時(shí)間的間隔大于預(yù)設(shè)時(shí)間間隔，則生成前端服務(wù)器連接失敗服務(wù)器事件，并發(fā)送所述前端服務(wù)器連接失敗服務(wù)器事件至所述連接服務(wù)器會(huì)話控制模型；

所述連接服務(wù)器會(huì)話控制模型，還用于根據(jù)所述前端服務(wù)器連接失敗服務(wù)器事件生成前端服務(wù)器連接失敗通知事件，并發(fā)送所述前端服務(wù)器連接失敗通知事件至與所述連接服務(wù)器會(huì)話控制模型對(duì)應(yīng)的所述客戶(hù)端。

3.根據(jù)權(quán)利要求2所述的服務(wù)器集群處理系統(tǒng)，其特征在于，

所述連接服務(wù)器，還用于接收所述客戶(hù)端發(fā)送的所述客戶(hù)端事件和與所述客戶(hù)端事件對(duì)應(yīng)的所述客戶(hù)端事件處理結(jié)果，并發(fā)送所述客戶(hù)端事件和所述客戶(hù)端事件處理結(jié)果至所述消息服務(wù)器；

所述前端服務(wù)器，還用于監(jiān)聽(tīng)所述消息服務(wù)器，并獲取所述客戶(hù)端事件和所述客戶(hù)端事件處理結(jié)果，處理得到更新的客戶(hù)端事件處理結(jié)果，并發(fā)送所述更新的客戶(hù)端事件處理結(jié)果至所述消息服務(wù)器；

所述連接服務(wù)器，還用于監(jiān)聽(tīng)所述消息服務(wù)器，并獲取所述更新的客戶(hù)端事件處理結(jié)果，發(fā)送所述更新的客戶(hù)端事件處理結(jié)果至所述客戶(hù)端。