[發(fā)明專利]一種基于Dubbo服務(wù)的會(huì)話消息的傳遞方法和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 202011206768.6
• 申請(qǐng)日: 2020-11-03
• 公開（公告）號(hào): CN112256456B
• 公開（公告）日: 2021-10-01
• 發(fā)明（設(shè)計(jì)）人: 樂思文
• 申請(qǐng)（專利權(quán)）人: 武漢物易云通網(wǎng)絡(luò)科技有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F9/48;G06F8/41
• 代理公司: 深圳市六加知識(shí)產(chǎn)權(quán)代理有限公司 44372
• 代理人: 崔肖肖;向彬

1.一種基于Dubbo服務(wù)的會(huì)話消息的傳遞方法，其特征在于，所述傳遞方法應(yīng)用于Dubbo服務(wù)系統(tǒng)，所述Dubbo服務(wù)系統(tǒng)包括至少一個(gè)節(jié)點(diǎn)，在所述節(jié)點(diǎn)上部署Dubbo服務(wù)，其中，所述Dubbo服務(wù)包括多個(gè)執(zhí)行線程；

所述傳遞方法包括：

第一Dubbo服務(wù)接收到來自于消費(fèi)方的第一請(qǐng)求后，選取目標(biāo)執(zhí)行線程對(duì)所述第一請(qǐng)求進(jìn)行處理，其中，所述目標(biāo)執(zhí)行線程配套設(shè)置有第一線程局部變量、第二線程局部變量、第一過濾器和第二過濾器；

所述第一過濾器從所述第一請(qǐng)求中獲取第一上下文消息，并將所述第一上下文消息存儲(chǔ)在所述第一線程局部變量中；

在所述第一過濾器完成上下文消息的存儲(chǔ)后，所述第二過濾器將所述第一上下文消息存儲(chǔ)在所述第二線程局部變量；

在所述第一Dubbo服務(wù)發(fā)生級(jí)聯(lián)調(diào)用時(shí)，可以從所述第二線程局部變量中獲取所述第一上下文消息，以進(jìn)行所述第一請(qǐng)求的后續(xù)邏輯處理；

所述目標(biāo)執(zhí)行線程還配套設(shè)置有第三過濾器和第三線程局部變量，其中，所述第一線程局部變量和所述第二線程局部變量均用于存儲(chǔ)所述第一Dubbo服務(wù)作為提供方的上下文消息，所述第三線程局部變量用于存儲(chǔ)所述第一Dubbo服務(wù)作為消費(fèi)方的上下文消息；

所述在所述第一Dubbo服務(wù)發(fā)生級(jí)聯(lián)調(diào)用時(shí)，可以從所述第二線程局部變量中獲取所述第一上下文消息，以進(jìn)行所述第一請(qǐng)求的后續(xù)邏輯處理包括：

在所述第二過濾器完成上下文消息的存儲(chǔ)后，所述目標(biāo)執(zhí)行線程繼續(xù)處理所述第一請(qǐng)求的后續(xù)邏輯；

所述目標(biāo)執(zhí)行線程對(duì)所述第一請(qǐng)求的后續(xù)邏輯進(jìn)行解析，判斷所述第一請(qǐng)求的后續(xù)邏輯是否包括第一子邏輯和第二子邏輯，其中，所述第一子邏輯需要調(diào)用第二Dubbo服務(wù)，所述第二子邏輯需要基于所述第一子邏輯返回的數(shù)據(jù)進(jìn)行處理；

若所述第一請(qǐng)求的后續(xù)邏輯包括第一子邏輯和第二子邏輯，則所述第一Dubbo服務(wù)基于所述第一子邏輯向所述第二Dubbo服務(wù)生成第二請(qǐng)求；

所述第二子邏輯獲取所述第二Dubbo服務(wù)基于所述第二請(qǐng)求的響應(yīng)結(jié)果，并從所述第二線程局部變量中獲取所述第一上下文消息，從而根據(jù)所述第一上下文消息和所述響應(yīng)結(jié)果完成后續(xù)處理。

2.根據(jù)權(quán)利要求1所述的傳遞方法，其特征在于，若所述第一請(qǐng)求的后續(xù)邏輯包括第一子邏輯和第二子邏輯，則所述第一Dubbo服務(wù)基于所述第一子邏輯向所述第二Dubbo服務(wù)生成第二請(qǐng)求之后，所述第二子邏輯獲取所述第二Dubbo服務(wù)基于所述第二請(qǐng)求的響應(yīng)結(jié)果，并從所述第二線程局部變量中獲取所述第一上下文消息，從而根據(jù)所述第一上下文消息和所述響應(yīng)結(jié)果完成后續(xù)處理之前還包括：

所述第三過濾器從所述第二請(qǐng)求中獲取第二上下文消息，并將所述第二上下文消息存儲(chǔ)在第三線程局部變量中；

所述第三過濾器清除所述第一線程局部變量中的上下文消息；

所述目標(biāo)執(zhí)行線程將經(jīng)過所述第三過濾器的第二請(qǐng)求發(fā)送至所述第二Dubbo服務(wù)；

所述目標(biāo)執(zhí)行線程在接收到所述第二Dubbo服務(wù)基于所述第二請(qǐng)求的響應(yīng)結(jié)果后，所述第三過濾器清除所述第三線程局部變量中的上下文消息。

3.根據(jù)權(quán)利要求1所述的傳遞方法，其特征在于，所述在所述第一Dubbo服務(wù)發(fā)生級(jí)聯(lián)調(diào)用時(shí)，可以從所述第二線程局部變量中獲取所述第一上下文消息，以進(jìn)行所述第一請(qǐng)求的后續(xù)邏輯處理還包括：

在所述目標(biāo)執(zhí)行線程完成對(duì)所述第一請(qǐng)求的處理后，所述第二過濾器清除所述第二線程局部變量中的上下文消息；

所述第一過濾器清除所述第一線程局部變量；

所述第一Dubbo服務(wù)將所述目標(biāo)執(zhí)行線程回收至線程池。

4.根據(jù)權(quán)利要求1所述的傳遞方法，其特征在于，所述第一過濾器為Dubbo服務(wù)原生的作為提供方的過濾器，所述第三過濾器為Dubbo服務(wù)原生的作為消費(fèi)方的過濾器；

所述傳遞方法包括：

基于Dubbo服務(wù)的原生接口org.apache.dubbo.rpc.Filter擴(kuò)展過濾器，以為執(zhí)行線程設(shè)置所述第二過濾器。

5.根據(jù)權(quán)利要求1所述的傳遞方法，其特征在于，所述第一Dubbo服務(wù)和所述第二Dubbo服務(wù)設(shè)置在同一個(gè)節(jié)點(diǎn)上；或，所述第一Dubbo服務(wù)和所述第二Dubbo服務(wù)設(shè)置在不同節(jié)點(diǎn)上。