一种消息中间件MQ的消息传输方法和装置

摘要

本发明提供一种消息中间件MQ的传输方法和装置，其方法包括：获取所需要传输的目标消息，并确定与所述目标消息相邻的消息在日志数据库中的标记信息是否为传输失败，如果是，则将所述目标消息转存入日志数据库中，否则，对所述目标消息进行传输，并判断传输结果；在传输结果为传输失败时，将所述目标消息转存入日志数据库中，并标记所述目标消息传输失败，在传输结果为传输成功时，将所述目标消息存入消息队列，并同步到日志数据库中，并标记所述目标消息传输成功；根据预先设置的重试机制，对所述日志数据库中标记信息为传输失败的消息进行重新传输，以提高消息的可靠性。

主权项

一种消息中间件MQ的传输方法，其特征在于，包括：获取所需要传输的目标消息，并确定与所述目标消息相邻的消息在日志数据库中的标记信息；在确定所述标记信息为传输失败时，将所述目标消息转存入日志数据库中，并标记所述目标消息传输失败；否则，对所述目标消息进行传输，并判断传输结果；在传输结果为传输失败时，将所述目标消息转存入日志数据库中，并标记所述目标消息传输失败，在传输结果为传输成功时，将所述目标消息存入消息队列，并同步到日志数据库中，并标记所述目标消息传输成功；根据预先设置的重试机制，对所述日志数据库中标记信息为传输失败的消息进行重新传输。