国外网站托管,桥的设计网站建设,开福区网站建设中,企业网站开发 文献综述一、用list实现【这是数据类型所以支持持久化】 消息基于redis存储不会因为受jvm内存上限的限制#xff0c;支持消息的有序性#xff0c;基于redis的持久化机制#xff0c;只支持单一消费者订阅#xff0c;无法避免消息丢失。
二、用PubSub【这不是数据类型#xff0c;是…一、用list实现【这是数据类型所以支持持久化】 消息基于redis存储不会因为受jvm内存上限的限制支持消息的有序性基于redis的持久化机制只支持单一消费者订阅无法避免消息丢失。
二、用PubSub【这不是数据类型是一种通讯机制所以不支持持久化】 支持多消费者订阅但是不支持消息持久化无法避免消息丢失。
三、基于stream的消息队列 单消费模式 【】是可选参数 消息可以回溯也可以被多个消费者读取读取后不会消失可以阻塞读取数据但是可能会漏读因为循环后读取$意思是读取最新消息如果一次性插入多个数据可以读取只读取到最后一条消息其他消息可能会漏读。 消费者组消费模式 它可以保证消费者从最后次一次消费的时候开始消费避免消息丢失。然后它可以避免消费者对于同一个消息重复消费会有消息确认机制发送消息后会是pending状态它会进入一个pendding队列防止消息进入队列后没有持久化就挂掉它会先存起来对redis恢复后进行ack消息确认如果确认了说明消息被使用了那就移除这个pendding队列。
