消息传输方法、装置、电子设备及存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113742110A(43)申请公布日2021.12.03(21)申请号202111065884.5(22)申请日2021.09.10(71)申请人北京沃东天骏信息技术有限公司地址100176北京市大兴区北京经济技术开发区科创十一街18号院2号楼4层A402室(72)发明人郝旭(74)专利代理机构中科专利商标代理有限责任公司11021代理人王文思(51)Int.Cl.G06F9/54(2006.01)权利要求书2页说明书10页附图5页(54)发明名称消息传输方法、装置、电子设备及存储介质(57)摘要本公开提供了一种消息传输方法、装置、电子设备及存储介质，该方法包括：响应于接收到预定主题下的当前消息，确定发送当前消息的当前生产者；确定订阅预定主题的至少一个订户，得到订户集合；取针对预定主题配置的消息传输通道；根据消息传输通道，确定目标生产者和目标订户；以及在确定当前生产者与目标生产者相同，且订户集合中包括目标订户的情况下，将当前消息发送至目标订户。CN113742110ACN113742110A权利要求书1/2页1.一种消息传输方法，包括：响应于接收到预定主题下的当前消息，确定发送所述当前消息的当前生产者；确定订阅所述预定主题的至少一个订户，得到订户集合；获取针对所述预定主题配置的消息传输通道；根据所述消息传输通道，确定目标生产者和目标订户；以及在确定所述当前生产者与所述目标生产者相同，且所述订户集合中包括所述目标订户的情况下，将所述当前消息发送至所述目标订户。2.根据权利要求1所述的方法，还包括：确定所述消息传输通道是否已配置；在确定所述消息传输通道尚未配置的情况下，将所述当前消息发送至所述订户集合中的每一个订户。3.根据权利要求1所述的方法，其中，所述在确定所述当前生产者与所述目标生产者相同，且所述订户集合中包括所述目标订户的情况下，将所述当前消息发送至所述目标订户包括：在确定所述当前生产者的标识信息与所述目标生产者的标识信息相同，且所述订户集合对应的标识信息集合中包括所述目标订户的标识信息的情况下，将所述当前消息发送至所述目标订户。4.根据权利要求1至3中任意一项所述的方法，还包括：在满足预设条件的情况下，将所述当前消息发送至所述订户集合中的每一个订户；其中，所述预设条件包括以下中的至少一个：所述当前生产者与所述目标生产者不同；所述订户集合中不包括所述目标订户。5.根据权利要求4所述的方法，还包括：展示所述当前生产者的标识信息和接收到所述当前消息的订户的标识信息。6.一种消息传输装置，包括：当前生产者确定模块，用于响应于接收到预定主题下的当前消息，确定发送所述当前消息的当前生产者；订户集合确定模块，用于确定订阅所述预定主题的至少一个订户，得到订户集合；消息传输通道获取模块，用于获取针对所述预定主题配置的消息传输通道；对象确定模块，用于根据所述消息传输通道，确定目标生产者和目标订户；以及第一发送模块，用于在确定所述当前生产者与所述目标生产者相同，且所述订户集合中包括所述目标订户的情况下，将所述当前消息发送至所述目标订户。7.根据权利要求6所述的装置，还包括：判断模块，用于确定所述消息传输通道是否已配置；第二发送模块，用于在确定所述消息传输通道尚未配置的情况下，将所述当前消息发送至所述订户集合中的每一个订户。8.一种电子设备，包括：一个或多个处理器；存储器，用于存储一个或多个程序，2CN113742110A权利要求书2/2页其中，当所述一个或多个程序被所述一个或多个处理器执行时，使得所述一个或多个处理器实现权利要求1至5中任一项所述的方法。9.一种计算机可读存储介质，其上存储有可执行指令，该指令被处理器执行时使处理器实现权利要求1至5中任一项所述的方法。10.一种计算机程序产品，包括计算机可执行指令，所述指令在被执行时用于实现权利要求1至5中任一项所述的方法。3CN113742110A说明书1/10页消息传输方法、装置、电子设备及存储介质技术领域[0001]本公开涉及计算机技术领域，更具体地，涉及一种消息传输方法、消息传输装置、电子设备、计算机可读存储介质以及计算机程序产品。背景技术[0002]MQ(MessageQueue，消息队列)是一种消息传输系统。根据消息传递方式的不同，MQ分为不同模式。一种为生产者/订户模式，生产者(消息的发送者)发送的消息会进入到队列，多个订户(消息的接收者)同时监听队列，并且队列中的每一条消息仅被一个订户获取，实现消息的点对点传输。另一种为发布/订阅模式，生产者将消息发布到预定主题下，多个订户(消息的接收者)共同订阅预定主题，并从预定主题下共同取得消息。发明内容[0003]本公开提供了一种消息传输方法、消息传输装置、电