[發(fā)明專利]一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理方法、系統(tǒng)及服務(wù)器

有效

• 申請?zhí)枺?/td>: 201310259154.8
• 申請日: 2013-06-26
• 公開（公告）號: CN103366471A
• 公開（公告）日: 2013-10-23
• 發(fā)明（設(shè)計）人: 張志超
• 申請（專利權(quán)）人: 福建聯(lián)迪商用設(shè)備有限公司
• 主分類號: G07G1/00
• 分類號: G07G1/00;G07G1/14
• 代理公司: 福州市鼓樓區(qū)博深專利代理事務(wù)所(普通合伙) 35214
• 代理人: 林志崢

技術(shù)領(lǐng)域

本發(fā)明涉及到通訊技術(shù)領(lǐng)域，尤其涉及一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理方法、系統(tǒng)及服務(wù)器。

背景技術(shù)

POS機(jī)刷卡消費(fèi)已經(jīng)成為一種時尚，客戶出門可以不用攜帶巨額現(xiàn)金，支付方便。隨著大量POS機(jī)投放市場，銀行對POS機(jī)的業(yè)務(wù)需求也越來越廣，由此產(chǎn)生的聯(lián)機(jī)交易系統(tǒng)也日漸增多，但是隨著POS機(jī)數(shù)量的增長，大并發(fā)數(shù)據(jù)的處理成為了聯(lián)機(jī)交易系統(tǒng)的一項(xiàng)重要環(huán)節(jié)。

由于聯(lián)機(jī)業(yè)務(wù)處理系統(tǒng)中，需要對終端的每一筆交易進(jìn)行監(jiān)控，隨著終端布放量的增加，以及交易數(shù)量的增加，系統(tǒng)將承受巨大的并發(fā)壓力，需要較高的數(shù)據(jù)并發(fā)處理能力，以免影響正常交易的進(jìn)行。因此有必要設(shè)計一種可以進(jìn)行大量數(shù)據(jù)并發(fā)處理的方法與系統(tǒng)。

發(fā)明內(nèi)容

為解決上述技術(shù)問題，本發(fā)明采用的一個技術(shù)方案是：

提供一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器，包括接收器、處理器以及事件處理器；所述接收器包括：連接建立模塊，用于調(diào)用接收器線程實(shí)時監(jiān)聽來自終端的連接請求，接受連接請求并建立聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器與所述終端的連接；以及連接導(dǎo)入模塊，用于調(diào)用接收器線程將聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器與終端已經(jīng)建立的連接導(dǎo)入到處理器線程；所述處理器包括：IO操作模塊，用于調(diào)用處理器線程進(jìn)行數(shù)據(jù)IO操作，直至該連接關(guān)閉；以及事件轉(zhuǎn)發(fā)模塊，用于調(diào)用處理器線程根據(jù)IO操作觸發(fā)相應(yīng)的連接事件，并將事件及其相關(guān)信息轉(zhuǎn)發(fā)至可配置的事件處理線程池；所述事件處理器包括：線程分配模塊，用于調(diào)用事件處理線程池根據(jù)線程池配置參數(shù)分配可用事件處理線程給事件；以及事件處理模，用于調(diào)用分配給事件的可用事件處理線程依據(jù)事件類型及相關(guān)信息調(diào)用事件處理器中相應(yīng)的事件方法對事件進(jìn)行業(yè)務(wù)處理并將處理結(jié)果交由處理器經(jīng)由處理器線程返回給終端。

其中，所述接收器線程只有一個，用于監(jiān)聽所述終端經(jīng)過的指定端口發(fā)送的連接請求。

其中，所述事件包括數(shù)據(jù)到達(dá)事件、數(shù)據(jù)發(fā)送事件、數(shù)據(jù)意外事件、連接空閑事件、連接關(guān)閉事件等。

其中，所述線程池配置參數(shù)包括核心線程數(shù)、最大線程數(shù)、線程最大空閑等待時間、隊(duì)列長度、連接事件提交線程池的失敗策略。

其中，所述線程分配模塊包括第一判斷子模塊、空閑線程分配子模塊、第二判斷子模塊、線程創(chuàng)建子模塊、第三判斷子模塊、線程銷毀子模塊以及隊(duì)列子模塊；所述第一判斷子模塊用于判斷線程池中是否有空閑線程；所述空閑線程分配子模塊用于當(dāng)?shù)谝慌袛嘧幽K判定有空閑線程時，分配空閑線程給事件；所述第二判斷子模塊用于當(dāng)?shù)谝慌袛嘧幽K判定線程池中沒有空閑線程時，判斷當(dāng)前線程池線程數(shù)是否小于最大線程數(shù)；所述線程創(chuàng)建子模塊用于當(dāng)所述第二判斷子模塊判定當(dāng)前線程池線程數(shù)小于最大線程數(shù)時，調(diào)用事件處理線程池動態(tài)創(chuàng)建新線程，并通知所述第三判斷子模塊判斷動態(tài)創(chuàng)建的新線程是否超過最大空閑等待時間；所述線程銷毀子模塊用于當(dāng)所述第三判斷子模塊判定線程池動態(tài)創(chuàng)建的新線程超過最大空閑等待時間時，銷毀所述動態(tài)創(chuàng)建的新線程；所述隊(duì)列子模塊用于當(dāng)所述第二判斷子模塊判定當(dāng)前線程池線程數(shù)不小于最大線程數(shù)時，將事件存入隊(duì)列中并通知第一判斷子模塊判斷線程池中是否有空閑線程。

本發(fā)明采用的另一個技術(shù)方案是：

提供一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理系統(tǒng)，包括聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器以及與所述聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器通信連接的至少一個終端，所述聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器是上述的聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器。

本發(fā)明采用的另一個技術(shù)方案是：

提供一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理方法，包括以下步驟：調(diào)用接收器線程實(shí)時監(jiān)聽來自終端的連接請求，接受連接請求并建立聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器與所述終端的連接；調(diào)用接收器線程將聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器與終端已經(jīng)建立的連接導(dǎo)入到處理器線程，然后調(diào)用處理器線程進(jìn)行數(shù)據(jù)IO操作，直至該連接關(guān)閉；調(diào)用處理器線程根據(jù)IO操作觸發(fā)相應(yīng)的連接事件，并將事件及其相關(guān)信息轉(zhuǎn)發(fā)至可配置的事件處理線程池；調(diào)用事件處理線程池根據(jù)線程池配置參數(shù)分配可用事件處理線程給事件；調(diào)用分配給事件的可用事件處理線程依據(jù)事件類型及相關(guān)信息調(diào)用事件處理器中相應(yīng)的事件方法對事件進(jìn)行業(yè)務(wù)處理，以及將處理結(jié)果交由處理器經(jīng)由處理器線程返回給終端。

其中，所述事件包括數(shù)據(jù)到達(dá)事件、數(shù)據(jù)發(fā)送事件、數(shù)據(jù)意外事件、連接空閑事件、連接關(guān)閉事件等。

其中，所述線程池配置參數(shù)包括核心線程數(shù)、最大線程數(shù)、線程最大空閑等待時間、隊(duì)列長度、連接事件提交線程池的失敗策略。