网站开发导向图,合肥软件开发公司,启东网站建设公司,中企动力是骗子公司吗保证可靠性
生产者
本地事务完成和消息发送同时完成 通过事务消息完成
重写confirm在里面做逻辑处理 确保发送成功#xff08;不成功就放入到重试队列#xff09;
MQ
打开持久化确保消息不会丢失
消费者
改成手动回应
不重复消费
生产者
保证不重复发送消息
消费者…保证可靠性
生产者
本地事务完成和消息发送同时完成 通过事务消息完成
重写confirm在里面做逻辑处理 确保发送成功不成功就放入到重试队列
MQ
打开持久化确保消息不会丢失
消费者
改成手动回应
不重复消费
生产者
保证不重复发送消息
消费者
确保它不重复消费 把消费过的消息存入redis
把消息中的多个字段进行组合加密得到字符串如果能在缓存中取到值表示已消费
顺序消费
传统做法用单一的消费者就能确保消息按照顺序消费
缺点并发度较高的时候效率会很低
顺序消费和多线程本身就是矛盾的关系并发多线程的意义就是因为不在乎顺序所以才变成多线程
解决方法将需要保证顺序的消息放在一块进行分组然后由单一的消费者消费
将需要保证顺序的放在一组然后用同一个work进行处理
延迟消息
死信
缺点需要过期时间一致
如果时间不一致 (例如: 消息A 5分钟过期 消息B 10分钟过期)
另一种方式 本地库存然后通过轮询重新发送一次信息
缺点性能上有损耗 但是更加灵活
消息堆积
原因
消费者消费的慢
消费出现问题导致nack队列太多
解决
增加消费者
消费过程改用异步或者多线程
‘将当前业务的topic改成新的topic然后新增多几个消费者在这新的topic上保证后续业务的正常执行前面堆积的这些单独开一些消费者在这里消费
