[發明專利]信息處理方法及系統在審
| 申請號: | 201810190114.5 | 申請日: | 2018-03-08 |
| 公開(公告)號: | CN110245026A | 公開(公告)日: | 2019-09-17 |
| 發明(設計)人: | 楊來昌 | 申請(專利權)人: | 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司 |
| 主分類號: | G06F9/54 | 分類號: | G06F9/54 |
| 代理公司: | 中科專利商標代理有限責任公司 11021 | 代理人: | 呂雁葭 |
| 地址: | 100195 北京市海淀區杏石口路6*** | 國省代碼: | 北京;11 |
| 權利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關鍵詞: | 消息序列 目標消息 排序邏輯 位點信息 信息處理 序列片段 預設 計算機可讀存儲介質 信息處理系統 連續性要求 連續排列 線程處理 計算機系統 對位點 在位 排序 | ||
1.一種信息處理方法,包括:
獲取按照預設排序邏輯對位點信息進行排序而構成的消息序列,其中,與所述消息序列中的位點信息對應的消息包括通過不同線程處理的消息,且所述消息序列包含至少一個消息序列片段,每個所述消息序列片段中的位點信息都是按照所述預設排序邏輯連續排列的;
從所述消息序列包含的所述至少一個消息序列片段中選出與之前已提交的消息序列片段在位點上滿足連續性要求的目標消息序列片段;以及
提交所述目標消息序列片段。
2.根據權利要求1所述的方法,其中,從所述消息序列包含的所述至少一個消息序列片段中選出與之前已提交的消息序列片段在位點上滿足連續性要求的目標消息序列片段包括:
針對所述至少一個消息序列片段,確定其中每個消息序列片段中處于首位的位點信息;
基于確定出的位點信息,確定所述每個消息序列片段中處于首位的位點信息所表示的首位位點;
從確定出的所有首位位點中選出排位最靠前的首位位點;以及
將與所述排位最靠前的首位位點對應的位點信息所在的消息序列片段作為所述目標消息序列片段。
3.根據權利要求2所述的方法,其中,所述方法還包括:
在將與所述排位最靠前的首位位點對應的位點信息所在的消息序列片段作為所述目標消息序列片段之前,確定所述之前已提交的消息序列片段中處于末位的位點信息;
確定所述處于末位的位點信息所表示的末位位點;
判斷所述末位位點與所述排位最靠前的首位位點是否是連續的位點;以及
若是,則將與所述排位最靠前的首位位點對應的位點信息所在的消息序列片段作為所述目標消息序列片段。
4.根據權利要求1所述的方法,其中,所述方法還包括:
按照預設時鐘周期或者在所述消息序列中位點信息的數量達到預設值時,從所述消息序列包含的所述至少一個消息序列片段中選出與之前已提交的消息序列片段在位點上滿足連續性要求的目標消息序列片段,并提交所述目標消息序列片段。
5.根據權利要求1所述的方法,其中,每個位點信息對應一個消息,所述方法還包括:
接收各位點信息對應的消息;
對所述各位點信息對應的消息進行分類處理;以及
根據分類處理結果,將不同類別的消息分配到不同的線程中進行消息處理。
6.根據權利要求5所述的方法,其中,所述方法還包括:
在各線程對對應類別的消息進行消息處理的過程中,如果消息處理成功,則將其對應的位點信息按照所述預設排序邏輯存入所述消息序列。
7.根據權利要求5所述的方法,其中,所述方法還包括:
在各線程對對應類別的消息進行消息處理的過程中,如果消息處理失敗,則發送消息重新獲取請求,以請求消息提供方重新提供位于所述之前已提交的消息序列片段中處于末位的位點信息所表示的末位位點之后的各位點所對應的各消息,并清除所述消息序列中存入的所有位點信息。
8.一種信息處理系統,包括:
獲取模塊,用于獲取按照預設排序邏輯對位點信息進行排序而構成的消息序列,其中,與所述消息序列中的位點信息對應的消息包括通過不同線程處理的消息,且所述消息序列包含至少一個消息序列片段,每個所述消息序列片段中的位點信息都是按照所述預設排序邏輯連續排列的;
選擇模塊,用于從所述消息序列包含的所述至少一個消息序列片段中選出與之前已提交的消息序列片段在位點上滿足連續性要求的目標消息序列片段;以及
提交模塊,用于提交所述目標消息序列片段。
該專利技術資料僅供研究查看技術是否侵權等信息,商用須獲得專利權人授權。該專利全部權利屬于北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司,未經北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司許可,擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作,請聯系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/201810190114.5/1.html,轉載請聲明來源鉆瓜專利網。





