MQ怎么保证消息的稳定性和完整性?
2016-12-09 11:28
253 查看
业务说明:
某业务操作完成后,需要发送通知给其他人,比如,单据审批后,需要发送通知给下一审批人(张三),和单据提交人
情况分析:
1.业务操作完成后,调用mq发送消息失败,mq无法连接---发送问题
2.mq发送了,但消费者接收失败,没有接收,或者接收服务挂了 -----接收问题
3.消息的延迟性,如说明中的的审批情况,可能 张三 都已经处理了,但这条通知消息因为某种原因迟迟没有发出,导致最后收到过期的消息-----消息过期问题
方案:
根据如下图,解决1、2情况,情况3由消费者自己处理
某业务操作完成后,需要发送通知给其他人,比如,单据审批后,需要发送通知给下一审批人(张三),和单据提交人
情况分析:
1.业务操作完成后,调用mq发送消息失败,mq无法连接---发送问题
2.mq发送了,但消费者接收失败,没有接收,或者接收服务挂了 -----接收问题
3.消息的延迟性,如说明中的的审批情况,可能 张三 都已经处理了,但这条通知消息因为某种原因迟迟没有发出,导致最后收到过期的消息-----消息过期问题
方案:
根据如下图,解决1、2情况,情况3由消费者自己处理
相关文章推荐
- Java安全之保证消息的完整性
- 如何保证MQ消息必达
- Java安全之保证消息的完整性
- MQ是怎么存放消息的[windows平台]
- 保证MQ消息传递的一致性
- 消息中间件(MQ)能给我们带来什么
- linux进程通信:使用posix消息队列mq进行线程或进程间的通信
- 数据库设计指南(四)保证数据的完整性
- zookeeper+activemq配置消息中间件集群 服务器配置
- 架构设计:系统间通信(19)——MQ:消息协议(上)
- 消息 MQ、Kafka
- RocketMQ原理解析-broker 2.消息存储
- 阿里消息列队MQ无法在远程服务器上运行的问题
- RabbitMQ+PHP 消息队列环境配置
- 站内消息系统数据表怎么设计
- kafka 怎么保证的exactly once
- 【消息队列MQ】各类MQ比较
- 保证数据的完整性
- webim如何保证消息的可靠投递
- 分布式消息队列RocketMQ源码分析之1 -- Topic路由数据结构解析 -- topicRoute与topicPublishInfo与queueId