rocketMQ之十二 消息存储

消息存储 分布式列队有高可用的需求,所以需要持久化,避免消息丢失 生产者发送消息 mq收到消息,持久化之后,在存储中新增一条记录 返回ack给生产者 mq push消息给对应的消费者,然后等消费者返回ack 如果消息者在指定时间内返回ack,mq认为消费成功,进行第六步,如果mq指定时间内没收到, 则认为消息推送失败,会重试上一步的操作 mq删除消息 存储介质 关系型数据库DB ActiveMQ就
相关文章
相关标签/搜索