買專利賣專利找龍圖騰，真高效！ 查專利查商標(biāo)用IPTOP,全免費(fèi)！專利年費(fèi)監(jiān)控用IP管家,真方便！

龍圖騰網(wǎng)恭喜正數(shù)網(wǎng)絡(luò)技術(shù)有限公司申請(qǐng)的專利一種基于事件驅(qū)動(dòng)和Reactor模式的實(shí)現(xiàn)動(dòng)態(tài)業(yè)務(wù)管線的方法獲國家發(fā)明授權(quán)專利權(quán)，本發(fā)明授權(quán)專利權(quán)由國家知識(shí)產(chǎn)權(quán)局授予，授權(quán)公告號(hào)為：CN114936074B 。

龍圖騰網(wǎng)通過國家知識(shí)產(chǎn)權(quán)局官網(wǎng)在2025-06-10發(fā)布的發(fā)明授權(quán)授權(quán)公告中獲悉：該發(fā)明授權(quán)的專利申請(qǐng)?zhí)?專利號(hào)為：202210330920.4，技術(shù)領(lǐng)域涉及：G06F9/48；該發(fā)明授權(quán)一種基于事件驅(qū)動(dòng)和Reactor模式的實(shí)現(xiàn)動(dòng)態(tài)業(yè)務(wù)管線的方法是由王海龍;王京晶;鄭亞凱;高艷濤;吳澤荃設(shè)計(jì)研發(fā)完成，并于2022-03-30向國家知識(shí)產(chǎn)權(quán)局提交的專利申請(qǐng)。

本一種基于事件驅(qū)動(dòng)和Reactor模式的實(shí)現(xiàn)動(dòng)態(tài)業(yè)務(wù)管線的方法在說明書摘要公布了：本發(fā)明公開了一種基于事件驅(qū)動(dòng)和Reactor模式的實(shí)現(xiàn)動(dòng)態(tài)業(yè)務(wù)管線的方法，包括以下步驟:a、架構(gòu)設(shè)計(jì)，消息中間件上的消息經(jīng)過調(diào)度中心的組合處理后，執(zhí)行相應(yīng)的任務(wù)鏈；b、動(dòng)態(tài)配置業(yè)務(wù)管線，根據(jù)Topic上的數(shù)據(jù)組成對(duì)任務(wù)鏈進(jìn)行劃分，從而形成業(yè)務(wù)管線，不同的劃分方式形成不同的業(yè)務(wù)管線；c、任務(wù)鏈的執(zhí)行，任務(wù)鏈的輸入要求對(duì)消息中間件上多個(gè)Topic上的多類數(shù)據(jù)進(jìn)行匹配，組合成一個(gè)完整輸入后，進(jìn)而觸發(fā)任務(wù)鏈的執(zhí)行。一個(gè)任務(wù)鏈關(guān)聯(lián)一個(gè)輸入，一個(gè)輸入由調(diào)度中心對(duì)消息中間件上的數(shù)據(jù)進(jìn)行組合，不同的組合或劃分方式，提供了動(dòng)態(tài)配置業(yè)務(wù)管線的方法。

本發(fā)明授權(quán)一種基于事件驅(qū)動(dòng)和Reactor模式的實(shí)現(xiàn)動(dòng)態(tài)業(yè)務(wù)管線的方法在權(quán)利要求書中公布了：1.一種基于事件驅(qū)動(dòng)和Reactor模式的實(shí)現(xiàn)動(dòng)態(tài)業(yè)務(wù)管線的方法，其特征在于，包括以下步驟：a、架構(gòu)設(shè)計(jì)，消息中間件上的消息經(jīng)過調(diào)度中心的組合處理后，執(zhí)行相應(yīng)的任務(wù)鏈；b、動(dòng)態(tài)配置業(yè)務(wù)管線，根據(jù)Topic上的數(shù)據(jù)組成對(duì)任務(wù)鏈進(jìn)行劃分，從而形成業(yè)務(wù)管線，不同的劃分方式形成不同的業(yè)務(wù)管線；c、任務(wù)鏈的執(zhí)行，任務(wù)鏈的輸入要求對(duì)消息中間件上多個(gè)Topic上的多類數(shù)據(jù)進(jìn)行匹配，組合成一個(gè)完整輸入后，進(jìn)而觸發(fā)任務(wù)鏈的執(zhí)行；在對(duì)消息中間件上多個(gè)Topic上的多類數(shù)據(jù)進(jìn)行匹配時(shí)采用最近匹配點(diǎn)算法，用于匹配完整輸入，同時(shí)提供容錯(cuò)機(jī)制，消息中間件上的數(shù)據(jù)來源于多個(gè)系統(tǒng)，各個(gè)系統(tǒng)處理數(shù)據(jù)的速度具有差異性，消息中間件上的消息保證數(shù)據(jù)的最終一致性，但無法保證消息的實(shí)時(shí)一致性，調(diào)度中心在組裝任務(wù)鏈的輸入時(shí)需要負(fù)責(zé)容錯(cuò)處理，將一段時(shí)間內(nèi)無法匹配的數(shù)據(jù)進(jìn)行保存，以便二次處理，實(shí)現(xiàn)ExactlyOnce語義模型對(duì)系統(tǒng)的復(fù)雜性和性能影響較大，調(diào)度中心需要能夠保證在出現(xiàn)重復(fù)信息和丟失信息的情況下能夠正確處理，即尋找到最近的匹配點(diǎn)，并保存不匹配數(shù)據(jù)便于二次處理，尋找到最近的匹配點(diǎn)通過匹配算法實(shí)現(xiàn)，匹配算法如下：a、指定超時(shí)時(shí)間；b、中間件事件驅(qū)動(dòng)，將收到的數(shù)據(jù)傳給調(diào)度中心，這條數(shù)據(jù)加入到對(duì)應(yīng)的隊(duì)列中，調(diào)度中心記錄該數(shù)據(jù)到達(dá)時(shí)間；c1、如果任務(wù)鏈輸入所關(guān)聯(lián)的隊(duì)列有空隊(duì)列，那么該任務(wù)鏈不觸發(fā)；c2、如果任務(wù)鏈輸入所關(guān)聯(lián)的隊(duì)列都至少有一個(gè)值，以最新的數(shù)據(jù)為基準(zhǔn)，掃描其他隊(duì)列，如果找到匹配點(diǎn)，將中間的數(shù)據(jù)標(biāo)記為不匹配并記錄到數(shù)據(jù)庫，如果沒有找到匹配點(diǎn)，重復(fù)步驟a；c3、如果數(shù)據(jù)在隊(duì)列中的時(shí)間超出閾值，將對(duì)應(yīng)的數(shù)據(jù)標(biāo)記為不匹配，移出隊(duì)列并記錄到數(shù)據(jù)庫，重復(fù)步驟a。

如需購買、轉(zhuǎn)讓、實(shí)施、許可或投資類似專利技術(shù)，可聯(lián)系本專利的申請(qǐng)人或?qū)＠麢?quán)人正數(shù)網(wǎng)絡(luò)技術(shù)有限公司，其通訊地址為：450000 河南省鄭州市鄭東新區(qū)金水東路39號(hào)中國河南出版產(chǎn)業(yè)園D座6-7樓；或者聯(lián)系龍圖騰網(wǎng)官方客服，聯(lián)系龍圖騰網(wǎng)可撥打電話0551-65771310或微信搜索“龍圖騰網(wǎng)”。