[發明專利]多區塊鏈交互并發下的數據處理方法、裝置及存儲介質有效
| 申請號: | 201811086564.6 | 申請日: | 2018-09-18 |
| 公開(公告)號: | CN109376020B | 公開(公告)日: | 2021-02-12 |
| 發明(設計)人: | 祝赫 | 申請(專利權)人: | 中國銀行股份有限公司 |
| 主分類號: | G06F9/54 | 分類號: | G06F9/54;G06Q40/04 |
| 代理公司: | 北京三友知識產權代理有限公司 11127 | 代理人: | 陳剛;劉飛 |
| 地址: | 100818 *** | 國省代碼: | 北京;11 |
| 權利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關鍵詞: | 區塊 交互 并發 數據處理 方法 裝置 存儲 介質 | ||
本申請提供了一種多區塊鏈交互并發下的數據處理方法、裝置及存儲介質,該方法包括:在收到交易上鏈消息后從指定的線程池中取出一個空閑線程;在空閑線程內,解析交易上鏈消息獲得交易信息,從指定的雙向隊列的隊首中取出一條Channel,并確定該Channel是否為交易信息所屬區塊鏈對應的Channel;如果是,則使用該Channel發送交易信息,并在使用后將該Channel放回至雙向隊列的隊首;如果不是,則將該Channel放至雙向隊列的隊尾。本申請可以提高多區塊鏈交互并發場景下Channel的復用性。
技術領域
本申請涉及區塊鏈技術領域,尤其是涉及一種多區塊鏈交互并發下的數據處理方法、裝置及存儲介質。
背景技術
目前,在區塊鏈交易中,每次交易前都需要打開Channel中的節點地址端口進行socket連接進行交易;其中,Channel在每次使用時都要重新創建,并在使用完成后關閉。而在多區塊鏈交互并發場景下,Channel的反復切換、創建和關閉,這就意味著同樣的socket連接可能要多次打開/關閉,非常容易造成性能浪費(例如負載過大可能導致的內存溢出等),甚至可能造成程序崩潰而阻礙業務的流暢性。因此,多區塊鏈的不均勻高并發場景使得Channel的復用變得非常困難。當然,雖然也可以將不同區塊鏈區分開成不同的獨立程序,各自單獨處理一條區塊鏈上的信息;但是,在多條鏈的場景時需要開發多個java程序,開發與維護的成本巨大,因而并不實用。
因此,如何在多區塊鏈交互并發場景下提高Channel的復用是目前亟需解決的技術問題。
發明內容
本申請實施例的目的在于提供一種多區塊鏈交互并發下的數據處理方法、裝置及存儲介質,以提高多區塊鏈交互并發場景下Channel的復用性。
為達到上述目的,一方面,本申請實施例提供了一種多區塊鏈交互并發下的數據處理方法,包括:
在收到交易上鏈消息后從指定的線程池中取出一個空閑線程;
在所述空閑線程內,解析所述交易上鏈消息獲得交易信息,從指定的雙向隊列的隊首中取出一條Channel,并確定該Channel是否為所述交易信息所屬區塊鏈對應的Channel;
如果該Channel是所述交易信息所屬區塊鏈對應的Channel,則使用該Channel發送所述交易信息,并在使用后將該Channel放回至所述雙向隊列的隊首;
如果該Channel不是所述交易信息所屬區塊鏈對應的Channel,則將該Channel放至所述雙向隊列的隊尾。
較佳的,所述的多區塊鏈交互并發下的數據處理方法,還包括:
如果所述雙向隊列為空,則創建一條所述交易信息所屬區塊鏈對應的Channel,使用該Channel發送所述交易信息,并在使用后將該Channel放至所述雙向隊列的隊首。
較佳的,所述的多區塊鏈交互并發下的數據處理方法,還包括:
當從所述雙向隊列的隊首中取Channel的次數超過所述雙向隊列的隊列長度,且未匹配到所述交易信息所屬區塊鏈對應的Channel時,關掉取出的Channel,創建一條所述交易信息所屬區塊鏈對應的Channel,使用該Channel發送所述交易信息,并在使用后將該Channel放至所述雙向隊列的隊首。
較佳的,所述的多區塊鏈交互并發下的數據處理方法,所述雙向隊列的隊列長度等于所述線程池的線程池尺寸。
另一方面,本申請實施例還提供了一種多區塊鏈交互并發下的數據處理裝置,包括:
取線程模塊,用于在收到交易上鏈消息后從指定的線程池中取出一個空閑線程;
該專利技術資料僅供研究查看技術是否侵權等信息,商用須獲得專利權人授權。該專利全部權利屬于中國銀行股份有限公司,未經中國銀行股份有限公司許可,擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作,請聯系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/201811086564.6/2.html,轉載請聲明來源鉆瓜專利網。
- 上一篇:接口調用方法及終端設備
- 下一篇:接口調用的響應方法及服務器





