[發(fā)明專利]信息傳輸方法及裝置

在審

• 申請?zhí)枺?/td>: 201810611200.9
• 申請日: 2018-06-14
• 公開（公告）號: CN108848031A
• 公開（公告）日: 2018-11-20
• 發(fā)明（設(shè)計）人: 杜恒;曾德熹;韓朋成;曾宇基;馬玲
• 申請（專利權(quán)）人: 深圳金證引擎科技有限公司
• 主分類號: H04L12/725
• 分類號: H04L12/725;H04L12/741;H04L12/751
• 代理公司: 北京超凡志成知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11371
• 代理人: 逯恒

1.一種信息傳輸方法，應(yīng)用于服務(wù)器，其特征在于，所述服務(wù)器存儲有一消息組件和多個消息中間件，所述方法包括：

建立所述消息組件與各所述消息中間件之間的路由鏈路，指定各所述路由鏈路的路由信息，其中，所述路由信息包括路由鏈路的通信地址、隊列名稱以及端口號，所述隊列名稱對應(yīng)有隊列管理器，所述隊列管理器存儲于所述消息中間件且與所述消息中間件一一對應(yīng)，所述隊列管理器關(guān)聯(lián)有消息接收端；

向所述消息組件中配置路由規(guī)則，其中，所述路由規(guī)則包括規(guī)則名稱和規(guī)則表達(dá)式；

接收消息發(fā)送端輸入的待傳輸消息并發(fā)送至所述消息組件，將所述待傳輸消息與所述路由規(guī)則中的規(guī)則名稱和規(guī)則表達(dá)式分別進(jìn)行匹配以得到待傳輸消息的發(fā)送方式和目標(biāo)鏈路；

查找所述目標(biāo)鏈路對應(yīng)的路由鏈路，并根據(jù)該路由鏈路對應(yīng)的通信地址和端口號按照所述發(fā)送方式將所述待傳輸消息路由至與該路由鏈路對應(yīng)的隊列管理器中；

接收消息接收端發(fā)送的消息接收請求，基于所述消息接收請求查找與所述消息接收端關(guān)聯(lián)的隊列管理器中是否存在待傳輸消息，并在存在待傳輸消息時將該隊列管理器中的待傳輸消息發(fā)送至所述消息接收端。

2.根據(jù)權(quán)利要求1所述的信息傳輸方法，其特征在于，所述路由信息還包括與該路由信息中的規(guī)則名稱和規(guī)則表達(dá)式對應(yīng)的預(yù)設(shè)標(biāo)識，所述待傳輸消息包括標(biāo)識信息，將所述待傳輸消息與所述路由規(guī)則中的規(guī)則名稱和規(guī)則表達(dá)式分別進(jìn)行匹配以得到待傳輸消息的發(fā)送方式和目標(biāo)鏈路的步驟包括：

獲取所述待傳輸消息中的標(biāo)識信息并查找與該標(biāo)識信息匹配的預(yù)設(shè)標(biāo)識；

將所述待傳輸消息與該預(yù)設(shè)標(biāo)識對應(yīng)的路由規(guī)則中的規(guī)則名稱和規(guī)則表達(dá)式分別進(jìn)行匹配以得到待傳輸消息的發(fā)送方式和目標(biāo)鏈路。

3.根據(jù)權(quán)利要求1所述的信息傳輸方法，其特征在于，在執(zhí)行接收消息接收端發(fā)送的消息接收請求，基于所述消息接收請求查找與所述消息接收端關(guān)聯(lián)的隊列管理器中是否存在待傳輸消息，并在存在待傳輸消息時將該隊列管理器中的消息發(fā)送至所述消息接收端的步驟之后，所述方法還包括：

接收所述消息接收端發(fā)送的應(yīng)答反饋信息，并發(fā)送至該消息接收端對應(yīng)的消息管理器；

將該消息管理器中的應(yīng)答反饋信息采用對應(yīng)的路由鏈路路由至所述消息組件，以將該消息組件中的應(yīng)答反饋信息反饋至所述消息發(fā)送端。

4.根據(jù)權(quán)利要求1所述的信息傳輸方法，其特征在于，在執(zhí)行建立所述消息組件與各所述消息中間件之間的路由鏈路，指定各所述路由鏈路的路由信息的步驟之后，所述方法還包括：

將所述路由信息保存至路由信息表中；

查找所述目標(biāo)鏈路對應(yīng)的路由鏈路的步驟包括：

從所述路由信息表中的各所述路由信息的路由鏈路中查找與所述目標(biāo)鏈路對應(yīng)的路由鏈路。

5.根據(jù)權(quán)利要求1所述的信息傳輸方法，其特征在于，所述待傳輸消息包括：消息是否支持事務(wù)性，消息是否支持順序性，消息是否需要重新添加到隊列，消息是否需要設(shè)置過期時間、消息是否需要死信隊列，消息是否需要用戶域管理以及消息是否有數(shù)據(jù)的流量需求的任意一項或多項，所述發(fā)送方式包括轉(zhuǎn)發(fā)或復(fù)制轉(zhuǎn)發(fā)，所述消息中間件包括kafka、rabbitmq和/或Rocketmq。