(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210179682.1 (22)申请日 2022.02.25 (71)申请人 京东科技控股 股份有限公司 地址 100176 北京市北京经济技 术开发区 科创十一 街18号C座2层2 21室 (72)发明人 马江　王顺达　刘尧　 (74)专利代理 机构 北京华夏泰和知识产权代理 有限公司 1 1662 专利代理师 邓菊香 (51)Int.Cl. G06F 9/54(2006.01) G06F 9/46(2006.01) G06F 16/22(2019.01) G06F 16/23(2019.01) (54)发明名称 消息发送方法、 装置、 系统、 设备及 介质 (57)摘要 本发明实施例涉及一种消息发送方法、 装 置、 系统、 设备及介质， 该消息发送方法包括将事 务触发的消息存储至数据库， 在所述消息存储至 数据库成功的情况下执行所述事务； 在所述事务 执行成功的情况下， 将所述消息发送给消息中间 件； 以及查询所述数据库中未被成功发送的消 息， 将所述未被成功发送的消息重新发送给所述 消息中间件。 权利要求书2页 说明书12页 附图6页 CN 114564319 A 2022.05.31 CN 114564319 A 1.一种消息发送方法， 其特 征在于， 包括： 将事务触发的消息存储至数据库， 在所述消息存储至数据库成功的情况下执行所述事 务； 在所述事务执 行成功的情况 下， 将所述消息发送给消息中间件； 查询所述数据库中未被成功发送的消息， 将所述未被成功发送的消息重新发送给所述 消息中间件。 2.根据权利要求1所述的方法， 其特征在于， 所述将事务触发的消息存储至数据库， 在 所述消息存 储至数据库成功的情况 下执行所述事务， 包括： 根据预设键值结构生成所述消息对应的键值对， 其中， 所述预设键值结构包含表征消 息的状态信息的字段； 将所述消息对应的键值对存储至所述数据库， 将所述消息的状态信 息设置为待执行并 执行所述事务。 3.根据权利要求2所述的方法， 其特征在于， 所述在所述事务执行成功 的情况下， 将所 述消息发送给消息中间件， 包括： 在所述事务执 行成功的情况 下， 将所述消息的状态信息更新 为待发送； 将状态信息为待发送的消息发送给消息中间件。 4.根据权利要求3所述的方法， 其特征在于， 所述消息对应的键值对包含所述消息的主 键， 还包括： 在所述数据库中创建主键数据集， 并将所述消息的主键存 储至所述主键数据集。 5.根据权利要求4所述的方法， 其特征在于， 在将状态信 息为待发送的消息发送给消息 中间件之后， 还 包括： 根据所述消息中间件返回的发送成功通知， 确定所述消息被成功发送给消息中间件； 将所述消息的状态信息更新 为已发送； 从所述主键数据集中删除状态信息为已发送的消息的主键 。 6.根据权利要求5所述的方法， 其特征在于， 所述查询所述数据库中未被成功发送的消 息， 将所述未被成功发送的消息 重新发送给 所述消息中间件， 包括： 查询所述主键数据集中存储的主键， 将所述主键对应的消息确定为未被成功发送的消 息； 将所述未被成功发送的消息 重新发送给 所述消息中间件。 7.根据权利要求6所述的方法， 其特征在于， 所述查询所述主键数据集中存储的主键包 括： 通过预设的定时机制定时查询所述主键数据集中存 储的主键 。 8.根据权利要求1至7中任一项所述的方法， 其特 征在于， 还 包括： 在所述消息存储至数据库失败的情况下或在所述事务执行失败的情况下， 执行回滚操 作。 9.一种消息发送装置， 其特 征在于， 所述装置包括： 存储模块， 用于将事务触发的消息存储至数据库， 在所述消息存储至数据库成功 的情 况下执行所述事务； 发送模块， 用于在所述事务执 行成功的情况 下， 将所述消息发送给消息中间件；权　利　要　求　书 1/2 页 2 CN 114564319 A 2重试模块， 用于查询所述数据库中未被成功发送的消息， 将所述未被成功发送的消息 重新发送给 所述消息中间件。 10.一种消息发送系统， 其特征在于， 所述系统包括消息的生产者、 消息中间件、 消息的 消费者， 所述生产者和所述消息中间件通过网络进行交互， 所述消息中间件和所述消费者 通过网络进行交 互， 所述系统包括： 所述生产者， 用于执行如权利要求1至8中任一项所述的消息发送方法， 将事务触发的 消息发送给 所述消息中间件， 并执 行所述事务； 所述消息中间件， 用于将接收到的消息发送给 所述消费者； 所述消费者， 用于消费由所述消息中间件发送的消息 。 11.一种电子设备， 其特征在于， 包括处理器、 通信接口、 存储器和通信总 线， 其中， 处理 器、 通信接口和存 储器通过通信总线完成相互间的通信； 存储器， 用于存放计算机程序； 处理器， 用于执 行存储器上所存放的程序时， 实现权利要求1至8中任一项所述的方法。 12.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时实现权利要求1至8中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 114564319 A 3