栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

RabbitMQ

RabbitMQ

RabbitMQ

消息队列

生产者 消费者

生产者 : 负责投递消息到消息队列中

消费者 : 拉取消息队列中的消息

并发量削锋

消息队列原理

交换机:生产者把消息写入队列的交换机中

路由:交换机通过路由把消息写入到队列中

队列:先进先出

mq各种通信方式
  1. workQuere方式 设置每个消费者一次消费多少信息,手动进行ack更安全(手动进行消息确认)
  2. 发布订阅(广播)在生产者微服务里 声明交换机为 广播类型,同时将同样的数据写道多个队列中
  3. 路由发布:把消息存到符合规则的队列中
  4. 增强路由:支持通配符 (不常用)
  5. 普通:一个消费者 一个生产者
消息的可靠性

可靠性1:生产者把信息成功写入交换机 使用/confirm/i机制
判断消息是否成功写入交换机
如果一次性写入交换机多个消息 则批量确认
异步确认是否成功写入交换机
可靠性2:确保消息能够从交换机成功的写入到队列中 采用return机制

避免消息重复消费

为了解决消息重复消费问题 可以采用redis 在消费者消费消息之前 现将消息的id放在redis中
id=0(正在执行业务)
id=1(业务执行成功)
如果ack失败 在RabbitMq将消息交给其他的消费者时 先执行setnx 如果key已经存在 获取它的值 如果是0
当前消费者就什么都不做 如果是1 直接ack

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/651788.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号