[發明專利]TCP請求的處理方法及裝置

有效

• 申請號: 201210460494.2
• 申請日: 2012-11-15
• 公開（公告）號: CN102916977A
• 公開（公告）日: 2013-02-06
• 發明（設計）人: 邵曉風;余昊;劉宗福;耿宜超;祝清華;胡玉溪;劉君杰
• 申請（專利權）人: 易程科技股份有限公司
• 主分類號: H04L29/06
• 分類號: H04L29/06
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 劉芳

技術領域

本發明涉及通信技術，尤其涉及一種TCP請求的處理方法及裝置

背景技術

對于與互聯網設備或程序進行通信的終端來說，需要對并發涌入的大量的傳輸控制協議（Transmission?Control?Protocol，以下簡稱TCP）請求做出實時準確的處理和快速響應。隨著復雜事件處理技術的興起，該技術在數據處理方面支持高吞吐、低延遲的特性為傳統TCP請求處理問題帶來新的解決途徑。目前，應用復雜事件處理技術的終端對大量涌入的TCP請求進行處理的過程主要為：在接收到多個TCP請求后，需要依次對接收到的TCP請求進行事件處理。其中，以一個TCP請求進行事件處理為例：對TCP請求進行解析，獲取該TCP請求中的事件類型名稱以及數據內容，然后根據該事件類型名稱，構建該TCP請求對應的事件封裝器，再根據事件封裝器，對該數據內容進行封裝處理，最后，將封裝處理后獲取的事件發送給終端中的事件處理引擎進行相應的處理。

但是，當至少有兩個TCP請求中的事件類型名稱相同時，終端還會對每個TCP請求分別進行上述的處理，從而導致了終端從接收TCP請求到進行事件封裝這一過程中效率相對較低的問題。另外，由于受到時延的影響，接收到的TCP請求的時間順序可能與發送該些TCP請求的時間順序不一致，因此，導致了事件處理引擎對該些TCP請求對應的事件的處理時序也與發送該些TCP請求的時間順序不一致。

發明內容

本發明提供一種TCP請求的處理方法及裝置，通過緩存內存中的事件封裝器以及按照事件發送時間對事件進行排列，確保了事件處理的高時效性和嚴格時序性。

本發明提供一種TCP請求的處理方法，包括：

接收TCP請求，并對所述TCP請求進行解析，獲取所述TCP請求中的事件處理頭和數據內容，所述事件處理頭包括發送時間和事件類型名稱；

查詢事件類型名稱和事件封裝器的映射關系，若判斷存在與所述事件類型名稱對應的事件封裝器，則根據獲取的所述事件類型名稱對應的事件封裝器，對所述數據內容進行封裝處理，生成所述TCP請求對應的事件，并保存所述事件和所述事件對應的發送時間；

獲取預定發送周期內保存的事件和所述事件對應的發送時間，按照所述事件對應的發送時間的從小到大的順序，對所述事件進行排列，并在所述發送周期到達時，依次發送排列后的事件給事件處理引擎，以供所述事件處理引擎依次對接收到的事件分別進行處理。

本發明提供一種TCP請求的處理裝置，包括：

接收模塊，用于接收所述TCP請求；

解析模塊，用于對所述TCP請求進行解析，獲取所述TCP請求中的事件處理頭和數據內容，所述事件處理頭包括發送時間和事件類型名稱；

判斷模塊，用于查詢查詢事件類型名稱和事件封裝器的映射關系，判斷是否存在與所述事件類型名稱對應的事件封裝器；

封裝處理模塊，用于若所述判斷模塊判斷出存在與所述事件類型名稱對應的事件封裝器，則根據獲取的所述事件類型名稱對應的事件封裝器，對所述數據內容進行封裝處理，生成所述TCP請求對應的事件；

保存模塊，用于保存所述事件和所述事件對應的發送時間；

發送模塊，用于獲取預定發送周期內保存的事件和所述事件對應的發送時間，按照所述事件對應的發送時間的從小到大的順序，對所述事件進行排列，并在所述發送周期到達時，依次發送排列后的事件給事件處理引擎，以供所述事件處理引擎依次對接收到的事件分別進行處理。

本發明提供一種TCP請求的處理方法及裝置，通過對接收到的TCP請求進行解析，獲取該TCP請求中的事件處理頭和數據內容，其中，該事件處理頭包括發送時間和事件類型名稱，并在查詢事件類型名稱和事件封裝器的映射關系后，判斷出存在與該事件類型名稱對應的事件封裝器時，則根據獲取的該事件類型名稱對應的事件封裝器，對該數據內容進行封裝處理，生成該TCP請求對應的事件，并保存該事件和所述事件對應的發送時間，最后，獲取預定發送周期內保存的事件和該事件對應的發送時間，按照該事件對應的發送時間的從小到大的順序，對該事件進行排列，并在該發送周期到達時，依次發送排列后的事件給事件處理引擎，以供該事件處理引擎依次對接收到的事件分別進行處理，相對于現有技術，從而解決了現有技術中即使多個TCP請求中的事件類型名稱相同時，也需要分別構建每個TCP請求中的事件類型名稱對應的事件封裝器而造成的事件處理效率低的問題；同時由于根據生成的事件對應的發送時間從小到大的順序，依次發送所生成的事件，因此有效地保證了事件處理的時序性。