日韩在线一区二区三区,日本午夜一区二区三区,国产伦精品一区二区三区四区视频,欧美日韩在线观看视频一区二区三区 ,一区二区视频在线,国产精品18久久久久久首页狼,日本天堂在线观看视频,综合av一区

[發明專利]一種基于消息隊列系統的消息處理方法和裝置有效

專利信息
申請號: 201710366692.5 申請日: 2017-05-23
公開(公告)號: CN107197015B 公開(公告)日: 2020-09-08
發明(設計)人: 鄭光杰 申請(專利權)人: 阿里巴巴集團控股有限公司
主分類號: H04L29/08 分類號: H04L29/08;H04L12/803
代理公司: 北京博思佳知識產權代理有限公司 11415 代理人: 陳蕾;靳玫
地址: 英屬開曼群島大開*** 國省代碼: 暫無信息
權利要求書: 查看更多 說明書: 查看更多
摘要:
搜索關鍵詞: 一種 基于 消息 隊列 系統 處理 方法 裝置
【權利要求書】:

1.一種基于消息隊列系統的消息處理方法,所述消息隊列系統包括消息隊列服務端和消息隊列客戶端,所述消息隊列服務端包括屬于同一消息主題的多個隊列分組(partition);所述方法包括:

一個隊列分組接收作為生產者的消息隊列客戶端發送的消息;

所述隊列分組判斷當前的隊列長度是否達到閾值,若達到閾值,則向所述作為生產者的消息隊列客戶端返回隊列滿指令,并且返回推薦切換的目標隊列分組;

所述作為生產者的消息隊列客戶端根據所述隊列滿指令,將生產的消息轉發至所述目標隊列分組,以從源頭上減少消息的進入;

所述隊列分組接收作為消費者的消息隊列客戶端拉取消息的請求,所述作為消費者的消息隊列客戶端用于訂閱所述消息主題并處理所述消息主題下的隊列分組中發布的消息;

所述隊列分組判斷當前的隊列長度是否達到閾值,若達到閾值,則向所述消費者的消息隊列客戶端返回隊列滿指令,并且返回推薦切換的目標隊列分組;

所述作為消費者的消息隊列客戶端根據所述隊列滿指令,將由所述隊列分組拉取的消息轉發至所述目標隊列分組,以由所述目標隊列分組對應的消費者的消息隊列客戶端進行處理,從出口加快消息的離開;

所述返回推薦切換的目標隊列分組,包括:

所述隊列分組向所述消息隊列服務端的隊列管理器請求推薦切換的目標對列分組;

所述隊列管理器根據位于同一消息主題下的各個隊列分組的隊列負載狀態,選擇當前負載低于負載最大閾值的隊列分組作為所述目標隊列分組。

2.根據權利要求1所述的方法,所述方法還包括:若當前的所述隊列分組的隊列長度未達到閾值,則所述隊列分組接受并存儲所述作為生產者的消息隊列客戶端發送的消息;或者,若當前的所述隊列分組的隊列長度未達到閾值,則由所述隊列分組對應的消費者的消息隊列客戶端處理拉取到的消息。

3.一種消息隊列系統,所述系統包括:消息隊列服務端和消息隊列客戶端,所述消息隊列服務端包括屬于同一消息主題的多個隊列分組(partition),所述消息隊列客戶端包括作為生產者的消息隊列客戶端和作為消費者的消息隊列客戶端;

所述消息隊列服務端的其中一個隊列分組,用于在接收到所述作為生產者的消息隊列客戶端發送的消息時,或者在接收到作為消費者的消息隊列客戶端拉取消息的請求時,判斷當前的隊列長度是否達到閾值,若達到閾值,則向所述消息隊列客戶端返回隊列滿指令,并且返回推薦切換的目標隊列分組;

所述作為生產者的消息隊列客戶端,用于根據所述隊列滿指令,將向所述隊列分組發送的消息轉發至所述目標隊列分組,以從源頭上減少消息的進入;

所述作為消費者的消息隊列客戶端,用于根據所述隊列滿指令,將由所述隊列分組拉取的消息轉發至所述目標隊列分組,以從出口加快消息的離開;

所述消息隊列服務端的所述隊列分組,具體用于向所述消息隊列服務端的隊列管理器請求推薦切換的目標隊列分組;所述隊列管理器,用于根據位于同一消息主題下的各個隊列分組的隊列負載狀態,選擇當前負載低于負載最大閾值的隊列分組作為所述目標隊列分組。

4.根據權利要求3所述的系統,所述隊列分組,還用于若當前的所述隊列分組的隊列長度未達到閾值,則接受并存儲所述作為生產者的消息隊列客戶端發送的消息,或者,將消息發送至對應的作為消費者的消息隊列客戶端處理。

下載完整專利技術內容需要扣除積分,VIP會員可以免費下載。

該專利技術資料僅供研究查看技術是否侵權等信息,商用須獲得專利權人授權。該專利全部權利屬于阿里巴巴集團控股有限公司,未經阿里巴巴集團控股有限公司許可,擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作,請聯系【客服

本文鏈接:http://www.szxzyx.cn/pat/books/201710366692.5/1.html,轉載請聲明來源鉆瓜專利網。

×

專利文獻下載

說明:

1、專利原文基于中國國家知識產權局專利說明書;

2、支持發明專利 、實用新型專利、外觀設計專利(升級中);

3、專利數據每周兩次同步更新,支持Adobe PDF格式;

4、內容包括專利技術的結構示意圖流程工藝圖技術構造圖

5、已全新升級為極速版,下載速度顯著提升!歡迎使用!

請您登陸后,進行下載,點擊【登陸】 【注冊】

關于我們 尋求報道 投稿須知 廣告合作 版權聲明 網站地圖 友情鏈接 企業標識 聯系我們

鉆瓜專利網在線咨詢

周一至周五 9:00-18:00

咨詢在線客服咨詢在線客服
tel code back_top
主站蜘蛛池模板: 96国产精品视频| 国产资源一区二区| 欧美极品少妇xx高潮| 国产综合亚洲精品| 91看片片| 国产69精品福利视频| 欧美精品在线视频观看| 日韩一区免费| 日韩欧美多p乱免费视频| 国产精品日韩一区二区三区| 久久久久久久亚洲视频| 欧美黄色片一区二区| 九九热国产精品视频 | 夜色av网站| 国产精品视频免费看人鲁| 国产日韩一区二区三免费| 午夜a电影| 精品久久久久99| 狠狠色狠狠色综合久久第一次| 少妇自拍一区| 国产精品国产三级国产专播精品人 | 亚洲欧洲一二三区| 国产在线精品一区| 久久一级精品| 高清国产一区二区三区| 福利片91| 91精品福利观看| 久久免费视频一区二区| 国产日韩一区二区在线| 草逼视频网站| 国内自拍偷拍一区| 欧美精品日韩一区| 一区二区三区欧美精品| 欧美精品久| 精品久久久久一区二区| 国产亚洲精品久久777777| 99久国产| 国产一级片网站| 国产91视频一区二区| 香蕉av一区| 国产精品视频久久久久| 国产精品久久91| 狠狠操很很干| 偷拍区另类欧美激情日韩91| 一区二区欧美在线| 午夜一区二区三区在线观看| 欧美精品一区二区性色| 国产一区二区三区精品在线| 国产二区三区视频| 国产第一区二区三区| 处破大全欧美破苞二十三| 欧美久久精品一级c片| 日韩精品久久久久久久酒店| 久久久999精品视频| 亚洲四区在线| 国产精品视频久久久久久| 91亚洲欧美日韩精品久久奇米色| 欧美日韩激情一区二区| 日本一区二区在线观看视频| 久久久久国产精品视频| 欧美乱战大交xxxxx| 亚洲va国产2019| 久久免费视频一区二区| 日韩有码一区二区三区| 国产精品自拍在线| 国产日韩欧美精品一区二区 | 国产乱子一区二区| 中文字幕一区三区| 亚洲精品国产suv| 黄毛片在线观看| 思思久久96热在精品国产| 国产精品女同一区二区免费站| 久久精品爱爱视频| 一级午夜影院| 欧美精品免费视频| 激情久久久久久| 欧美乱大交xxxxx古装| 国产精品中文字幕一区| 中文字幕日韩有码| 免费视频拗女稀缺一区二区| 久久精品一二三| 99精品区|