消息一致性保证方法、装置、设备、存储介质及产品

本申请涉及计算机技术领域，提供一种消息一致性保证方法、装置、设备、存储介质及产品。方法包括：获取各阶段的消息状态信息和分布式消息队列系统的实时性能信息；根据各阶段的消息状态信息和实时性能信息，基于自适应动态学习系统的学习和决策引擎，生成各阶段的消息配置策略，并基于各阶段的消息配置策略，进行消息传递；其中，消息配置策略以最小化消息丢失风险和消息重复消费风险为目标。通过上述方式，可有效避免由于消息丢失和消息重复消费导致数据生产者和数据消费者之间的消息不一致，提高消息一致性保证方法的有效性，减少人工介入，优化通信流程，提高消息一致性保证方法的效率。