[發(fā)明專利]消息轉(zhuǎn)發(fā)方法及服務(wù)端

有效

• 申請(qǐng)?zhí)枺?/td>: 202010016686.9
• 申請(qǐng)日: 2020-01-08
• 公開（公告）號(hào): CN111241355B
• 公開（公告）日: 2023-06-16
• 發(fā)明（設(shè)計(jì)）人: 馬小波;李科
• 申請(qǐng)（專利權(quán)）人: 浪潮通信信息系統(tǒng)有限公司
• 主分類號(hào): G06F16/903
• 分類號(hào): G06F16/903
• 代理公司: 濟(jì)南信達(dá)專利事務(wù)所有限公司 37100
• 代理人: 姜鵬

1.消息轉(zhuǎn)發(fā)方法，其特征在于，應(yīng)用于服務(wù)端，預(yù)先設(shè)置至少一個(gè)用戶權(quán)限字段名，其中，所述用戶權(quán)限字段名對(duì)應(yīng)字段為客戶端能夠訪問的信息，包括：

A0：獲取至少一條實(shí)時(shí)消息；

A1：獲取至少一個(gè)客戶端發(fā)送的至少一個(gè)用戶操作字段名，其中，所述用戶操作字段名對(duì)應(yīng)的字段為客戶端需要訪問的信息；

A2：根據(jù)所述至少一個(gè)用戶權(quán)限字段名和所述至少一個(gè)客戶端發(fā)送的所述至少一個(gè)用戶操作字段名，生成每一個(gè)所述客戶端對(duì)應(yīng)的用戶消息匹配條件；

A3：確定所述至少一條實(shí)時(shí)消息中，是否存在與各個(gè)所述用戶消息匹配條件中的至少一個(gè)目標(biāo)用戶消息匹配條件相對(duì)應(yīng)的至少一條用戶篩選消息；

A4：當(dāng)存在與至少一個(gè)目標(biāo)用戶消息匹配條件相對(duì)應(yīng)的至少一條用戶篩選消息時(shí)，將每一個(gè)所述目標(biāo)用戶消息匹配條件對(duì)應(yīng)的至少一條用戶篩選消息，發(fā)送給發(fā)來所述目標(biāo)用戶消息匹配條件的目標(biāo)客戶端，以使所述目標(biāo)客戶端輸出接收到的所述至少一條用戶篩選消息；

在所述預(yù)先設(shè)置至少一個(gè)用戶權(quán)限字段名之后，在所述A1之前，進(jìn)一步包括：

將所述至少一個(gè)用戶權(quán)限字段名發(fā)送給至少一個(gè)客戶端，以使用戶從所述客戶端接收到的所述至少一個(gè)用戶權(quán)限字段名中確定至少一個(gè)用戶操作字段名；

所述A2，包括：

針對(duì)每一個(gè)所述客戶端，當(dāng)所述至少一個(gè)用戶權(quán)限字段名中包含所述客戶端發(fā)送的所述至少一個(gè)用戶操作字段名時(shí)，將所述客戶端發(fā)送的所述至少一個(gè)用戶操作字段名作為所述客戶端對(duì)應(yīng)的用戶消息匹配條件；

在所述A2之前，進(jìn)一步包括：

獲取每一個(gè)所述客戶端發(fā)送的用于指示客戶端身份的窗口ID；

創(chuàng)建每一個(gè)所述窗口ID對(duì)應(yīng)的消息轉(zhuǎn)發(fā)隊(duì)列；

當(dāng)存在與至少一個(gè)目標(biāo)用戶消息匹配條件相對(duì)應(yīng)的至少一條用戶篩選消息時(shí)，在所述將每一個(gè)所述目標(biāo)用戶消息匹配條件對(duì)應(yīng)的至少一條用戶篩選消息，發(fā)送給發(fā)來所述目標(biāo)用戶消息匹配條件的目標(biāo)客戶端之前，進(jìn)一步包括：

針對(duì)每一個(gè)所述目標(biāo)用戶消息匹配條件執(zhí)行：

確定與所述目標(biāo)用戶消息匹配條件相對(duì)應(yīng)的目標(biāo)客戶端，其中，所述目標(biāo)客戶端為發(fā)來生成所述目標(biāo)用戶消息匹配條件時(shí)的所述用戶操作字段名的客戶端；

從創(chuàng)建的各個(gè)所述消息轉(zhuǎn)發(fā)隊(duì)列中，確定與所述目標(biāo)客戶端的窗口ID相對(duì)應(yīng)的目標(biāo)消息轉(zhuǎn)發(fā)隊(duì)列；

按照時(shí)間順序，將所述目標(biāo)用戶消息匹配條件相對(duì)應(yīng)的至少一條用戶篩選消息推送到所述目標(biāo)消息轉(zhuǎn)發(fā)隊(duì)列中；

所述將每一個(gè)所述目標(biāo)用戶消息匹配條件對(duì)應(yīng)的至少一條用戶篩選消息，發(fā)送給發(fā)來所述目標(biāo)用戶消息匹配條件的目標(biāo)客戶端，包括：

通過所述目標(biāo)消息轉(zhuǎn)發(fā)隊(duì)列向所述目標(biāo)客戶端發(fā)送每一條所述用戶篩選消息。

2.根據(jù)權(quán)利要求1所述的消息轉(zhuǎn)發(fā)方法，其特征在于，

在所述A0之后，在所述A3之前，進(jìn)一步包括：

S1:創(chuàng)建kafka消息隊(duì)列；

S2:按照時(shí)間順序，將所述至少一條實(shí)時(shí)消息推送至所述kafka消息隊(duì)列中；

所述A4，包括：

S3:讀取所述kafka消息隊(duì)列中的第一條實(shí)時(shí)消息；

S4:確定各個(gè)所述用戶消息匹配條件中是否存在與所述第一條實(shí)時(shí)消息相對(duì)應(yīng)的至少一個(gè)目標(biāo)用戶消息匹配條件，其中，所述目標(biāo)用戶消息匹配條件包括第一條實(shí)時(shí)消息中的字段對(duì)應(yīng)的字段名，如果是，執(zhí)行S5，否則，執(zhí)行S6；

S5:將所述第一條實(shí)時(shí)消息作為用戶篩選消息，將每一個(gè)所述目標(biāo)用戶消息匹配條件對(duì)應(yīng)的用戶篩選消息，發(fā)送給發(fā)來所述目標(biāo)用戶消息匹配條件的目標(biāo)客戶端，并執(zhí)行S6；

S6:將所述kafka消息隊(duì)列中所述第一條實(shí)時(shí)消息的下一條實(shí)時(shí)消息作為第一條實(shí)時(shí)消息，返回S4。