[發(fā)明專利]企業(yè)服務(wù)總線系統(tǒng)、數(shù)據(jù)處理方法、終端及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 201810928828.1
• 申請(qǐng)日: 2018-08-15
• 公開(kāi)（公告）號(hào): CN109298950A
• 公開(kāi)（公告）日: 2019-02-01
• 發(fā)明（設(shè)計(jì)）人: 張學(xué)
• 申請(qǐng)（專利權(quán)）人: 深圳壹賬通智能科技有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F13/42
• 代理公司: 深圳市賽恩倍吉知識(shí)產(chǎn)權(quán)代理有限公司 44334
• 代理人: 楊毅玲

1.一種企業(yè)服務(wù)總線系統(tǒng)，所述企業(yè)服務(wù)總線系統(tǒng)通訊連接多個(gè)企業(yè)系統(tǒng)和多個(gè)第三方系統(tǒng)，其特征在于，所述企業(yè)服務(wù)總線系統(tǒng)包括：

ESB-ADAPTER子系統(tǒng)、ESB-PROXY-IN子系統(tǒng)、ESB-PROXY-OUT子系統(tǒng)、ESB-FILE-PROXY-OUT子系統(tǒng)，所述ESB-ADAPTER子系統(tǒng)分別與所述ESB-PROXY-IN子系統(tǒng)、所述ESB-PROXY-OUT子系統(tǒng)及所述ESB-FILE-PROXY-OUT子系統(tǒng)通訊連接，其中，

所述ESB-ADAPTER子系統(tǒng)用于發(fā)布dubbo服務(wù)協(xié)議，所述ESB-PROXY-IN子系統(tǒng)用于發(fā)布http協(xié)議和https服務(wù)協(xié)議；

所述ESB-ADAPTER子系統(tǒng)還用于將所述企業(yè)服務(wù)總線系統(tǒng)封裝后的消息暫存于內(nèi)存中；

所述ESB-ADAPTER子系統(tǒng)還用于偵測(cè)到所述內(nèi)存中存儲(chǔ)有待處理的消息時(shí)，獲取所述待處理的消息，根據(jù)所述待處理的消息配置相應(yīng)的消息隊(duì)列，并對(duì)所述待處理的消息進(jìn)行處理；

所述ESB-ADAPTER子系統(tǒng)還用于每隔預(yù)設(shè)時(shí)間段從消息隊(duì)列中拉取所述待處理的消息，根據(jù)所述待處理的消息創(chuàng)建相應(yīng)的線程；

所述ESB-ADAPTER子系統(tǒng)還用于對(duì)所述待處理的消息進(jìn)行解析，并將解析后的內(nèi)容發(fā)送至所述數(shù)據(jù)請(qǐng)求對(duì)應(yīng)的數(shù)據(jù)請(qǐng)求服務(wù)方；

所述ESB-ADAPTER子系統(tǒng)還用于獲取所述數(shù)據(jù)請(qǐng)求的服務(wù)方發(fā)送的請(qǐng)求結(jié)果并將所述請(qǐng)求結(jié)果暫存至所述內(nèi)存中的消息隊(duì)列中；

所述ESB-ADAPTER子系統(tǒng)還用于從所述內(nèi)存中的消息隊(duì)列中獲取所述請(qǐng)求結(jié)果，并將所述請(qǐng)求結(jié)果發(fā)送至所述數(shù)據(jù)請(qǐng)求的請(qǐng)求方。

2.一種利用如權(quán)利要求1所述的企業(yè)服務(wù)總線系統(tǒng)進(jìn)行企業(yè)服務(wù)總線數(shù)據(jù)處理方法，其特征在于，所述方法包括：

發(fā)布服務(wù)，供請(qǐng)求方調(diào)用，所述ESB-ADAPTER子系統(tǒng)發(fā)布服務(wù)協(xié)議為dubbo協(xié)議，所述ESB-PROXY-IN子系統(tǒng)發(fā)布服務(wù)協(xié)議為http協(xié)議和https協(xié)議；

偵測(cè)是否接收到請(qǐng)求方的數(shù)據(jù)請(qǐng)求；

當(dāng)偵測(cè)到接收到請(qǐng)求方的數(shù)據(jù)請(qǐng)求后，識(shí)別所述數(shù)據(jù)請(qǐng)求的請(qǐng)求方是否合法；

當(dāng)識(shí)別所述數(shù)據(jù)請(qǐng)求的請(qǐng)求方合法時(shí)，根據(jù)所述數(shù)據(jù)請(qǐng)求識(shí)別所述數(shù)據(jù)請(qǐng)求的服務(wù)方；

根據(jù)所述請(qǐng)求的服務(wù)方將所述數(shù)據(jù)請(qǐng)求封裝成相應(yīng)的消息，所述ESB-ADAPTER子系統(tǒng)將封裝后的消息暫存于內(nèi)存中；

所述ESB-ADAPTER子系統(tǒng)偵測(cè)到所述內(nèi)存中存儲(chǔ)有待處理的消息時(shí)，獲取所述待處理的消息，根據(jù)所述待處理的消息配置相應(yīng)的消息隊(duì)列，并對(duì)所述待處理的消息進(jìn)行處理；

每隔預(yù)設(shè)時(shí)間段所述ESB-ADAPTER子系統(tǒng)從消息隊(duì)列中拉取所述待處理的消息，根據(jù)所述待處理的消息創(chuàng)建相應(yīng)的線程；

所述ESB-ADAPTER子系統(tǒng)對(duì)所述待處理的消息進(jìn)行解析，并將解析后的內(nèi)容發(fā)送至所述數(shù)據(jù)請(qǐng)求對(duì)應(yīng)的數(shù)據(jù)請(qǐng)求服務(wù)方；

所述ESB-ADAPTER子系統(tǒng)獲取所述數(shù)據(jù)請(qǐng)求的服務(wù)方發(fā)送的請(qǐng)求結(jié)果并將所述請(qǐng)求結(jié)果暫存至所述內(nèi)存中的消息隊(duì)列中；

所述ESB-ADAPTER子系統(tǒng)從所述內(nèi)存中的消息隊(duì)列中獲取所述請(qǐng)求結(jié)果，并將所述請(qǐng)求結(jié)果發(fā)送至所述數(shù)據(jù)請(qǐng)求的請(qǐng)求方。

3.如權(quán)利要求2所述的方法，其特征在于，所述請(qǐng)求方的數(shù)據(jù)請(qǐng)求為所述請(qǐng)求方根據(jù)企業(yè)服務(wù)系統(tǒng)所發(fā)布的服務(wù)協(xié)議對(duì)數(shù)據(jù)請(qǐng)求進(jìn)行封裝后的數(shù)據(jù)請(qǐng)求，包括：

當(dāng)所述請(qǐng)求方為所述企業(yè)系統(tǒng)時(shí)，根據(jù)所述dubbo協(xié)議對(duì)所述數(shù)據(jù)請(qǐng)求進(jìn)行封裝；

當(dāng)所述請(qǐng)求方為第三方系統(tǒng)時(shí)，根據(jù)所述http協(xié)議或者h(yuǎn)ttps協(xié)議對(duì)所述數(shù)據(jù)請(qǐng)求進(jìn)行封裝。

4.如權(quán)利要求2所述的方法，其特征在于，所述根據(jù)所述數(shù)據(jù)請(qǐng)求識(shí)別所述數(shù)據(jù)請(qǐng)求的服務(wù)方包括：

根據(jù)所述數(shù)據(jù)請(qǐng)求中攜帶的數(shù)據(jù)請(qǐng)求服務(wù)方標(biāo)識(shí)識(shí)別所述數(shù)據(jù)請(qǐng)求的服務(wù)方；

當(dāng)識(shí)別所述數(shù)據(jù)請(qǐng)求服務(wù)方標(biāo)識(shí)為第一標(biāo)識(shí)時(shí)，確定所述數(shù)據(jù)請(qǐng)求服務(wù)方為企業(yè)系統(tǒng)；

當(dāng)識(shí)別所述數(shù)據(jù)請(qǐng)求服務(wù)方標(biāo)識(shí)為第二標(biāo)識(shí)時(shí)，確定所述數(shù)據(jù)請(qǐng)求服務(wù)方為第三方系統(tǒng)。