[發明專利]一種報文處理方法、裝置、電子設備及存儲介質

有效

• 申請號: 202110482383.0
• 申請日: 2021-04-30
• 公開（公告）號: CN113259265B
• 公開（公告）日: 2023-07-25
• 發明（設計）人: 吳翔;許偉棟;吳旭冬
• 申請（專利權）人: 阿里云計算有限公司
• 主分類號: H04L47/125
• 分類號: H04L47/125;H04L47/50;G06F16/28
• 代理公司: 北京博思佳知識產權代理有限公司 11415
• 代理人: 李威

本申請提供一種報文處理方法、裝置、電子設備及存儲介質，應用于中轉節點；所述方法包括：將目標報文序列中的首個Bind報文之前的若干報文，拆分為第一報文子序列，并將第一報文子序列轉發至對應的數據庫節點；確定目標報文序列中剩余的報文所構成的第二報文子序列中的Bind報文的數量是否大于1；如果否，則將第二報文子序列轉發至對應的數據庫節點；如果是，則將第二報文子序列中的首個Execute報文的之前的若干報文和Execute報文，拆分為第三報文子序列，并將第三報文子序列轉發至對應的數據庫節點；以及將第二報文子序列中剩余的報文所構成的報文子序列，重新確定為目標報文序列。

技術領域

本申請涉及網絡通信技術領域，尤其涉及一種報文處理方法、裝置、電子設備及機器可讀存儲介質。

背景技術

為了提升PostgreSQL數據庫處理報文的效率，客戶端通常可以基于ExtendedQuery協議，向PostgreSQL數據庫發送報文序列，所述報文序列中可以包括多個報文，以使客戶端通過一次網絡通信發送一個報文序列，就可以實現將多個報文發送給PostgreSQL數據庫。

在實際應用中，與PostgreSQL數據庫節點對應的中間件，通常可以先對客戶端發送的報文序列進行處理，再將處理后的報文序列中的報文轉發至對應的PostgreSQL數據庫節點。

例如，當客戶端發送基于Extended?Query協議的PBES序列(即包括Parse報文、Bind報文、Execute報文和Sync報文的報文序列)時，中間件Pgpool-Ⅱ可以先從所述PBES序列中拆分出Parse報文，并將其轉發至對應的數據庫節點；再拆分出Bind報文，并將其轉發至對應的數據庫節點；然后可以拆分出Execute報文，并根據與出Execute報文對應的Parse報文中包含的SQL語句的讀寫屬性，將其轉發至對應的數據庫節點；最后將Sync報文轉發至對應的數據庫節點。

由此可見，所述中間件在將客戶端發送的一個報文序列轉發至對應的數據庫節點時，需要逐個拆分出所述報文序列中的報文并逐個轉發，導致網絡處理性能不佳。

發明內容

本申請提供一種報文處理方法，應用于與PostgreSQL數據庫節點對應的中轉節點；所述中轉節點用于將接收到的基于Extended?Query協議的報文序列轉發給所述數據庫節點；所述方法包括：

將客戶端發送的基于Extended?Query協議的報文序列確定為目標報文序列，并迭代執行以下步驟A、B、C，直至客戶端發送的所述報文序列中的報文均被轉發至對應的數據庫節點；

步驟A：將所述目標報文序列中的首個Bind報文之前的若干報文，拆分為第一報文子序列，并將所述第一報文子序列轉發至對應的數據庫節點；

步驟B：確定所述目標報文序列中剩余的報文所構成的第二報文子序列中的Bind報文的數量是否大于1；

步驟C：如果否，則將所述第二報文子序列轉發至對應的數據庫節點；如果是，則將所述第二報文子序列中的與所述首個Bind報文對應的Execute報文的之前的若干報文和所述Execute報文，拆分為第三報文子序列，并將所述第三報文子序列轉發至對應的數據庫節點；以及將所述第二報文子序列中剩余的報文所構成的報文子序列，重新確定為所述目標報文序列。

可選的，所述數據庫節點包括多個數據庫子節點；

所述將所述第一報文子序列轉發至對應的數據庫節點，包括：

將所述第一報文子序列廣播發送至所述數據庫節點中的所有子節點；

所述將所述第二報文子序列或者所述第三報文子序列轉發至對應的數據庫節點，包括：

將所述第二報文子序列或者所述第三報文子序列轉發至所述數據庫節點中的任一子節點。