消息处理方法及装置、存储介质、电子装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114281568A(43)申请公布日2022.04.05(21)申请号202111567648.3(22)申请日2021.12.20(71)申请人汇承金融科技服务（南京）有限公司地址210000江苏省南京市浦口区滨江大道396号扬子江金融示范区3栋3层(72)发明人梁靖民(74)专利代理机构北京知果之信知识产权代理有限公司11541代理人高科(51)Int.Cl.G06F9/54(2006.01)权利要求书2页说明书7页附图3页(54)发明名称消息处理方法及装置、存储介质、电子装置(57)摘要本申请公开了一种消息处理方法及装置、存储介质、电子装置。该方法包括接收待处理消息，响应于所述待处理消息的下发指令，将所述待处消息存储至预设消息队列中，根据预设模拟器、预设第三方服务接口，将所述消息内容发送至所述目标用户所在的消息群。本申请解决了消息处理无通用接口、功能不完善的技术问题。通过本申请优化消息处理过程、丰富可用接口。CN114281568ACN114281568A权利要求书1/2页1.一种消息处理方法，其特征在于，包括：接收待处理消息，其中，所述待处理消息至少包括如下之一：消息内容、用户信息，所述消息内容用于作为与预设业务相关的投放内容，通过所述用户信息确定目标用户所在的消息群，所述目标用户包括多个；响应于所述待处理消息的下发指令，将所述待处消息存储至预设消息队列中，其中，所述预设消息队列采用发布订阅的模式；根据预设模拟器、预设第三方服务接口，将所述消息内容发送至所述目标用户所在的消息群，其中，所述预设第三方服务接口用于将当前的目标用户以及目标用户所在的消息群信息同步更新，所述预设模拟器用于作为所述预设消息队列的消费者，并通过唯一标识符对所述预设消息队列中的订阅内容进行消费。2.根据权利要求1所述的方法，其特征在于，所述根据预设模拟器、预设第三方服务接口，将所述消息内容发送至所述目标用户所在的消息群包括：当所述预设模拟器感知到所述消息队列中有订阅内容待消费时，根据预设模拟器通过所述唯一标识符作为Topic进行消费，其中所述订阅内容中携带有包消息群群号、消息内容；根据所述预设第三方服务接口，将所述消息内容粘贴至用户端的剪贴板中，并模拟用户的操作事件根据所述消息群群号搜索出所述目标用户所在的消息群进行所述消息内容的发送，并将发送结果进行回调。3.根据权利要求2所述的方法，其特征在于，所述将所述消息内容发送至所述目标用户所在的消息群时，所述消息内容的收发通过Selenium模拟器实现。4.根据权利要求2所述的方法，其特征在于，所述根据预设模拟器、预设第三方服务接口，将所述消息内容发送至所述目标用户所在的消息群，还包括：基于所述预设消息队列，对消息内容添加消息生产时间Timestamp，用以在所述模拟器端接收到消息内容之后且识别到消息内容超过时限的情况下，将消息丢弃，其中，所述预设消息队列包括kafka队列。5.根据权利要求1所述的方法，其特征在于，所述根据预设模拟器、预设第三方服务接口，将所述消息内容发送至所述目标用户所在的消息群，还包括：根据预设模拟器、所述预设第三方服务接口，用于对预设的SDK进行兼容接入以及功能切换，其中，所述预设模拟器用于作为对第三方服务接口的预设功能的补充。6.根据权利要求1所述的方法，其特征在于，所述接收待处理消息之前，还包括：客户端通过预设RestfulAPI接口推送所述待处理消息中的所述消息内容、所述用户信息。7.一种消息处理系统，其特征在于，包括：后台系统，用于在消息内容、用户信息通过Restful接口到达所述后台系统之后，通过所述后台系统用于根据所述用户信息在数据库中查找出目标用户所在的消息群；预设模拟器，用于作为所述预设消息队列的消费者，并通过唯一标识符对所述预设消息队列中的订阅内容进行消费；预设第三方接口，用于将当前的目标用户以及目标用户所在的消息群信息同步更新；其中，所述预设模拟器和所述后台系统以所述后台系统作为根节点的树形结构，所述2CN114281568A权利要求书2/2页后台系统将作为生产者将消息存储至预设消息队列中，所述消息队列采用发布订阅的模式。8.一种消息处理装置，其特征在于，包括：接收模块，用于接收待处理消息，其中，所述待处理消息至少包括如下之一：消息内容、用户信息，所述消息内容用于作为与预设业务相关的投放内容，通过所述用户信息确定目标用户所在的消息群；响应模块，用于响应于所述待处理消息的下发指令，将所述待处消息存储至预设消息队列中；模拟发送模块，用于根据预设模拟器、预设第三方服务接口，将所述消息内容发送至所述目标用户所在的消息群，其中，所述预设第三方服务接口用于将当前的目标用户以及目标用户所在的消息