[發(fā)明專利]一種基于Kubernetes集群的數(shù)據(jù)訂閱服務(wù)方法和設(shè)備

有效

• 申請?zhí)枺?/td>: 201911324959.X
• 申請日: 2019-12-16
• 公開（公告）號: CN112995267B
• 公開（公告）日: 2023-04-18
• 發(fā)明（設(shè)計）人: 張建學(xué);何輝彪;臧遠(yuǎn)慧
• 申請（專利權(quán)）人: 中科星圖股份有限公司
• 主分類號: H04L67/1095
• 分類號: H04L67/1095;H04L67/1097;H04L67/06
• 代理公司: 北京華專卓海知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11664
• 代理人: 張繼鑫

本發(fā)明的實(shí)施例提供了一種基于Kubernetes集群的數(shù)據(jù)訂閱服務(wù)方法和設(shè)備。所述方法包括將數(shù)據(jù)訂閱服務(wù)進(jìn)行解耦，得到解耦后的多個服務(wù)組件；將解耦后的多個服務(wù)組件鏡像打包，將鏡像文件上傳至私有鏡像倉庫；從私有鏡像倉庫中提取打包后的服務(wù)組件，以容器的形式部署在Kubernetes中，根據(jù)服務(wù)劃分為有狀態(tài)服務(wù)和無狀態(tài)服務(wù)，并為有狀態(tài)服務(wù)和無狀態(tài)服務(wù)配置資源。以此方式，降低服務(wù)的耦合度，提升代碼復(fù)用性；具有彈性伸縮，平行遷移，負(fù)載均衡等特性；將服務(wù)上云，一次部署多次使用，且實(shí)現(xiàn)服務(wù)的自動化部署和啟動；監(jiān)控服務(wù)運(yùn)行狀態(tài)，及時遷移和恢復(fù)問題服務(wù)；監(jiān)控資源使用狀況，對服務(wù)進(jìn)行擴(kuò)容和縮容。

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

本發(fā)明的實(shí)施例一般涉及互聯(lián)網(wǎng)通信技術(shù)領(lǐng)域，并且更具體地，涉及一種基于Kubernetes集群的數(shù)據(jù)訂閱服務(wù)方法和設(shè)備。

背景技術(shù)

傳統(tǒng)數(shù)據(jù)訂閱服務(wù)在部署過程中，開發(fā)者通常需要通過各種方式配置服務(wù)中的各個組件以及組件依賴的資源，這就要求運(yùn)維開發(fā)人員熟悉服務(wù)使用的各個組件和組件之間的關(guān)系，導(dǎo)致部署過程困難。同時，傳統(tǒng)的部署方式很難實(shí)現(xiàn)一次部署多次使用的目標(biāo)，服務(wù)遷移對人員和環(huán)境要求非常高，整體過程不僅復(fù)雜繁瑣，而且耗時耗力，不利于服務(wù)運(yùn)營。

傳統(tǒng)的數(shù)據(jù)訂閱服務(wù)在開發(fā)過程中有高耦合的問題。高耦合架構(gòu)本質(zhì)上是一個Client/Server模型，隨著集群規(guī)模的擴(kuò)大，缺點(diǎn)也隨之暴露出來：

1)無法支持高并發(fā)大規(guī)模的任務(wù)；

2)服務(wù)器超載嚴(yán)重，管控風(fēng)險增大；

3)程序代碼關(guān)聯(lián)度過大，不利于模塊化處理；

4)維護(hù)成本增大，隨著功能的增多，服務(wù)會越來越臃腫，龐大；

5)無法實(shí)現(xiàn)組件的有效、快捷的復(fù)用。

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

根據(jù)本發(fā)明的實(shí)施例，提供了一種基于Kubernetes集群的數(shù)據(jù)訂閱服務(wù)方案。

在本發(fā)明的第一方面，提供了一種基于Kubernetes集群的數(shù)據(jù)訂閱服務(wù)方法，該方法包括：

將數(shù)據(jù)訂閱服務(wù)進(jìn)行解耦，得到解耦后的多個服務(wù)組件；

將解耦后的多個服務(wù)組件鏡像打包，將鏡像文件上傳至私有鏡像倉庫；

從私有鏡像倉庫中提取打包后的服務(wù)組件，以容器的形式部署在Kubernetes中，根據(jù)服務(wù)劃分為有狀態(tài)服務(wù)和無狀態(tài)服務(wù)，并為有狀態(tài)服務(wù)和無狀態(tài)服務(wù)配置資源。

進(jìn)一步地，所述解耦后的多個服務(wù)組件包括生產(chǎn)者組件Producer、中間件服務(wù)組件Kafka和消費(fèi)者服務(wù)組件Consumer。

進(jìn)一步地，將所述生產(chǎn)者組件Producer和消費(fèi)者服務(wù)組件Consumer劃分為無狀態(tài)服務(wù)，將所述中間件服務(wù)組件Kafka劃分為有狀態(tài)服務(wù)。

進(jìn)一步地，當(dāng)客戶端Client與服務(wù)器端Server進(jìn)行通信時，所述生產(chǎn)者組件Producer生產(chǎn)訂閱數(shù)據(jù)，將訂閱數(shù)據(jù)插入到所述中間件服務(wù)組件Kafka中，所述消費(fèi)者服務(wù)組件Consumer監(jiān)聽中間件服務(wù)組件Kafka，從所述中間件服務(wù)組件Kafka中取出訂閱數(shù)據(jù)并進(jìn)行處理。

進(jìn)一步地，所述消費(fèi)者服務(wù)組件Consumer根據(jù)FIFO方式，當(dāng)所述中間件服務(wù)組件Kafka中有新的訂閱數(shù)據(jù)插入時，取出該訂閱數(shù)據(jù)進(jìn)行處理。

進(jìn)一步地，所述消費(fèi)者服務(wù)組件Consumer從中間件服務(wù)組件Kafka中提取并處理訂閱數(shù)據(jù)的速度小于所述生產(chǎn)者組件Producer生產(chǎn)訂閱數(shù)據(jù)插入中間件服務(wù)組件Kafka的速度。

進(jìn)一步地，所述將解耦后的多個服務(wù)組件鏡像打包，包括：

選擇基礎(chǔ)鏡像，并安裝程序依賴包；