
项目 项目二总结:(五)RabbitMQ是怎么处理消息丢失的及同步机构
说明为了将MQ的使用相关的代码进行统一所以将发送消息的代码消费者的配置抽取到slexpressmq工程中主要功能为RabbitTemplate设置了ReturnsCallback如果消息发送到交换机但是没有到达队列会进行日志的记录统一了配置了消息的消费消费者如果处理消息失败会进行重试如果依然是失败的话会将错误消息发送到errorqueue队列后续需要人工进行处理统一了发送消息代码如果网络等异常情况导致发送消息失败会进行重试如果依然失败的话将消息内容持久化到mysql数据库后续通过xxljob任务进行重新发送如果其他情况导致失败不会进行重试直接存储消息到mysql数据库中错误消息记录表结构upl