锐客网

  1. 首页 > 睿知 > it技术 > >

mq消息存入redis可靠性，redis消息队列可靠性

IT技术摘录自

redis与rabbitmq做消息队列的区别1、我们介绍了RabbitMQ，Kafka和Redis的一些特征 。这三种动物都是它们的类别，但是如上所述，它们的运行方式大不相同 。这是我们建议正确的消息代理根据不同用例使用的建议 。
2、首先说RabbitMQ，RabbitMQ是使用Erlang编写的一个开源的消息队列，本身支持很多的协议：AMQP，XMPP，SMTP， STOMP，也正因如此 ， 它非常重量级 ， 更适合于企业级的开发 。
3、redis 消息推送（基于分布式 pub/sub）多用于实时性较高的消息推送 ， 并不保证可靠 。其他的mq和kafka保证可靠但有一些延迟（非实时系统没有保证延迟） 。
4、当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka ， 阿里巴巴自主开发RocketMQ等 。
5、redis只是提供一个高性能的、原子操作内存键值对，具有高速访问能力，可用做消息队列的存储 ， 但是不具备消息队列的任何功能和逻辑，要作为消息队列来实现的话，功能和逻辑要通过上层应用自己实现 。我们以RabbitMQ为例介绍 。
redis如何与mysql保持一致性1、SAGA或者TCC - 这两种需要业务代码的大量配合 。通过业务代码来补偿一致性 。现实当中有XA协议 。比如Ehcache是支持XA协议的 。但是性能表现不佳 ， 运维也麻烦 。
2、redis没有像mysql那样复制位置的概念，所以Slave和Master断开连接再重新连接时，会全量取Master的快照，Slave的所有数据都会清除，重新建立整个内存表，这样导致Salve恢复数据特别慢，同时也给Master带来的压力 。
3、比如基于数据库的唯一键来保证重复数据不会重复插入多条 。因为有唯一键约束了，重复数据插入只会报错，不会导致数据库中出现脏数据 。
4、总的来说有两种方案 本文把两种方式都实现下 。如果公司有统一的平台接入binlog的话，canal+mq应该是比较好的解耦的方式 。
【mq消息存入redis可靠性，redis消息队列可靠性】5、如果要“保证”数据的安全性，那么会带来开销的进一步提升，以至于使用redis带来的性能优势都会丧失 。正确的做法是区分不同的业务 ， 使得并不需要“保证”数据一致性的场合，可以使用redis优化 。而敏感的场合依然使用mysql 。
Redis、Kafka或RabbitMQ:哪个作为微服务消息代理最合适?Kafka是一个高吞吐量的分布式队列，用于长时间存储大量数据 。对于需要持久性的一对多用例，Kafka是理想的选择 。复杂路由：RabbitMQ RabbitMQ是一个较老但很成熟的代理 ， 具有许多支持复杂路由的功能 。
综上所述： 一般公司会利用kafka收集一些日志之类的消息，因为日志一般量特别大，即使丢几条数据也没事，并且要求吞吐量也高 ， 一般就是收发消息，不需要太多的功能，所以kafka非常适合这个场景 。
我们介绍了RabbitMQ，Kafka和Redis的一些特征 。这三种动物都是它们的类别，但是如上所述 ， 它们的运行方式大不相同 。这是我们建议正确的消息代理根据不同用例使用的建议 。
面试官:如何保证RocketMQ/RabbitMQ消息数据100%不丢失1、生产端可靠性投递，即生产端要确保将消息正确投递到RabbitMQ中 。
2、首先要确保写入 RabbitMQ 的消息别丢，消息队列通过 请求确认机制 ，保证消息的可靠传输 。生产开启 comfirm 模式 ， 在生产者开启 comfirm 模式之后 ， 每次发送消息都会分配一个唯一的id 。
3、所以如果对一批消息处理完毕了，同时提交消息的offset给broker ， 即使消费者系统宕机了，此时是不会丢失消息的 。

推荐阅读


上一篇：湖南如何找专业的营销机构，湖南营销策划

下一篇：c语言好用的函数分装 c语言拆分函数