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

有效

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

1.一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器，其特征在于，包括接收器、處理器以及事件處理器；

所述接收器包括：

連接建立模塊，用于調(diào)用接收器線程實(shí)時(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)由處理器線程返回給終端。

2.根據(jù)權(quán)利要求1所述的一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器，其特征在于：所述接收器線程只有一個(gè)，用于監(jiān)聽所述終端經(jīng)過的指定端口發(fā)送的連接請求。

3.根據(jù)權(quán)利要求1所述的一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器，其特征在于：所述事件包括數(shù)據(jù)到達(dá)事件、數(shù)據(jù)發(fā)送事件、數(shù)據(jù)意外事件、連接空閑事件、連接關(guān)閉事件等。

4.根據(jù)權(quán)利要求1所述的一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器，其特征在于：所述線程池配置參數(shù)包括核心線程數(shù)、最大線程數(shù)、線程最大空閑等待時(shí)間、隊(duì)列長度、連接事件提交線程池的失敗策略。

5.根據(jù)權(quán)利要求4所述的一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器，其特征在于，所述線程分配模塊,包括第一判斷子模塊、空閑線程分配子模塊、第二判斷子模塊、線程創(chuàng)建子模塊、第三判斷子模塊、線程銷毀子模塊以及隊(duì)列子模塊；

所述第一判斷子模塊用于判斷線程池中是否有空閑線程；

所述空閑線程分配子模塊用于當(dāng)?shù)谝慌袛嘧幽K判定有空閑線程時(shí)，分配空閑線程給事件；

所述第二判斷子模塊用于當(dāng)?shù)谝慌袛嘧幽K判定線程池中沒有空閑線程時(shí)，判斷當(dāng)前線程池線程數(shù)是否小于最大線程數(shù)；

所述線程創(chuàng)建子模塊用于當(dāng)所述第二判斷子模塊判定當(dāng)前線程池線程數(shù)小于最大線程數(shù)時(shí)，調(diào)用事件處理線程池動態(tài)創(chuàng)建新線程，并通知所述第三判斷子模塊判斷動態(tài)創(chuàng)建的新線程是否超過最大空閑等待時(shí)間；

所述線程銷毀子模塊用于當(dāng)所述第三判斷子模塊判定線程池動態(tài)創(chuàng)建的新線程超過最大空閑等待時(shí)間時(shí)，銷毀所述動態(tài)創(chuàng)建的新線程；

所述隊(duì)列子模塊用于當(dāng)所述第二判斷子模塊判定當(dāng)前線程池線程數(shù)不小于最大線程數(shù)時(shí)，將事件存入隊(duì)列中并通知第一判斷子模塊判斷線程池中是否有空閑線程。

6.一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理系統(tǒng)，其特征在于，包括聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器以及與所述聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器通信連接的至少一個(gè)終端，所述聯(lián)機(jī)業(yè)務(wù)并發(fā)處理服務(wù)器如權(quán)利要求1-5任意一項(xiàng)所述。

7.一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理方法，其特征在于，包括以下步驟：

調(diào)用接收器線程實(shí)時(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)閉；

處理器線程根據(jù)IO操作觸發(fā)相應(yīng)的連接事件，并將事件及其相關(guān)信息轉(zhuǎn)發(fā)至可配置的事件處理線程池；

調(diào)用事件處理線程池分配可用事件處理線程給事件；

調(diào)用分配給事件的可用事件處理線程依據(jù)事件類型及相關(guān)信息調(diào)用事件處理器中相應(yīng)的事件方法對事件進(jìn)行業(yè)務(wù)處理，以及將處理結(jié)果交由處理器經(jīng)由處理器線程返回給終端。

8.根據(jù)權(quán)利要求7所述的一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理方法，其特征在于：所述事件包括數(shù)據(jù)到達(dá)事件、數(shù)據(jù)發(fā)送事件、數(shù)據(jù)意外事件、連接空閑事件、連接關(guān)閉事件等。

9.根據(jù)權(quán)利要求7所述的一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理方法，其特征在于：所述線程池配置參數(shù)包括核心線程數(shù)、最大線程數(shù)、線程最大空閑等待時(shí)間、隊(duì)列長度、連接事件提交線程池的失敗策略。

10.根據(jù)權(quán)利要求9所述的一種聯(lián)機(jī)業(yè)務(wù)并發(fā)處理方法，其特征在于：所述“調(diào)用事件處理線程池根據(jù)線程池配置參數(shù)配置分配可用事件處理線程”具體包括步驟：

判斷線程池中是否有空閑線程；

當(dāng)判定有空閑線程時(shí)，分配空閑線程給事件；

當(dāng)判定線程池中沒有空閑線程時(shí)，判斷當(dāng)前線程池線程數(shù)小于最大線程數(shù)；

當(dāng)判定當(dāng)前線程池線程數(shù)是否小于最大線程數(shù)時(shí)，調(diào)用事件處理線程池動態(tài)創(chuàng)建新線程，并判斷動態(tài)創(chuàng)建的新線程是否超過最大空閑等待時(shí)間；

當(dāng)判定線程池動態(tài)創(chuàng)建的線程超過最大空閑等待時(shí)間時(shí)，銷毀所述動態(tài)創(chuàng)建的新線程；

當(dāng)判定當(dāng)前線程池線程數(shù)不小于最大線程數(shù)時(shí)，將事件存入隊(duì)列中，并返回步驟判斷線程池中是否有空閑線程。