rabbitmq 入门到熟悉|不敢说精通

rabbitmq 可以使用的场景

• 异步接口调用

有这样的一种场景，公司项目原本是经过 http 接口来调用第三方接口，可是这样带来了不少问题；我在实际项目中有碰到这样一种状况，因为对方服务不稳定，接口虽然调过去了，对方操做成功，可是因为网络缘由或其它缘由，未能返回成功的反馈，致使我方业务出错，这在量少的时候还能够经过人工处理解决，当量上来的时候，就是一场灾难。

• 流量削锋
• 日志处理

与 kafka 的优缺点

kafka 来讲的话是高吞吐量，kafka 在每秒百万级别(通常用在设备上点等高频数据操做)，彻底分布式； 而 rabbitmq 比较简单，遵循 amqp 协议，通常应用可使用；不适合物联网数据上报

各组件说明

• ConnectionFactory 链接工厂，用于设置链接相关信息，建立链接
• Channel 信道，全部的发送消息，建立队列，建立交换机，接收消息都是经过它
• Exchange 消息交换机，至关于 DispatchServlet
• Queue 队列，存放消息的地方，只有这里能够存放消息
• RoutingKey 路由键，设置消息路由，派发给哪一个队列
• BindingKey 绑定键，用于把队列绑定到交换机上，只有队列绑定到交换机上，消息才能够路由给队列

注意事项

• 队列一经建立就不能够更改参数
• 消息能够直接发到队列上，也能够由交换机转发

rabbitmq 的几种模式

这里我是学的这个视频 ，正好又找到对应的代码博客 视频地址

简单队列

解读：

• 一个生产者
• 一个消费者
• 一个队列

代码： 简单队列

Work模式

解读：

• 一个队列
• 两个消费者同时消费

代码(轮询分发)： 轮询分发
代码(公平分发)： 也叫能者多劳 公平分发

订阅模式

解读：

• 一个队列对应一个消费者
• 多个队列，多个消费者
• 消息是发到交换机上的
• 消息是每一个队列都转发所有消息

代码： 订阅模式

路由模式

解读：

• 消息再也不是所有转发，而是根据路由键来转发，作的全名称匹配
• 队列能够和交换机绑定多个路由键

代码： 路由模式

主题模式

解读：

• 这个可能和你本来理解的 kafka 的主题模式有区别 ，kafka 的主题模式应该是对应发布订阅模式

• 这个相比较于路由模式来讲是把全名称匹配换成了模式匹配，有了通配符

  • # 匹配全部
  • * 匹配一个 ~感受有点反人类~

代码： 主题模式

如何保证消息的可靠性

生产端有两种方式来确保消息到达队列

1. 事务机制(不建议，性能过低)

代码：事务机制

1. confirm 机制

代码：confirm同步模式，confirm异步处理模式

消费者端有 ack 确认来确保可靠

//将自动 ack 确认设置为 false ，而后手动来确认已经收到消息并正确处理业务 
boolean autoAck=false;
channel.basicConsume("test",autoAck,defaultConsumer);

//回应 rabbitmq 已经收到消息并处理
channel.basicAck(envelope.getDeliveryTag(),false);

上面的代码虽然能解决消息丢失的问题，但有一个弊端，就是当业务处理时间特别长的时候，rabbitmq 得不到回应，形成消息堆积。解决办法以下。

1. 仍是使用手动 ack
2. 收到消息后，先把消息存入 rabbitmq 的一个未处理队列中
3. 而后回执 ack
4. 执行业务，业务处理完成后，发送二次确认到 rabbit 未处理队列,消费掉未处理的消息

rabbitmq 自己能够作持久化来保证可靠性

// 设置方法在声明队列的第二个参数，是否持久化，设置为 true 便可
boolean durable = true;
channel.queueDeclare(QUEUE_NAME,durable,false,false,null);

死信队列和使用场景

什么是死信队列

1. 一个消息被Consumer拒收了，而且reject方法的参数里requeue是false。也就是说不会被再次放在队列里，被其余消费者使用。
2. 上面的消息的TTL到了，消息过时了。
3. 队列的长度限制满了。排在前面的消息会被丢弃或者扔到死信路由上。

使用场景

• 12306 的那种订单 30 分钟后超时，数据库中会一个订单状态，在 30 分钟后须要更新为已超时，使用传统方法时要么使用定时任务扫描订单，要么是保存一个 map 到内存，操做都很繁琐，这时候可使用死信队列，设置队列消息的超时时间为 30 分钟，而后把消息经过死信交换机发送到特定队列中去，再有专门的程序更新单条记录为订单超时到数据库中。
• 物联网系统常常会遇到向终端下发命令，若是命令一段时间没有应答，就须要设置成超时，而后监听到命令超时再反馈给物联网系统。

使用 springboot 来调用 rabbitmq

• 发送消息
• 接收消息

一些小推广

Excel 通用导入导出，支持 Excel 公式
https://blog.csdn.net/sanri1993/article/details/100601578

使用模板代码 ，从数据库生成代码 ，及一些项目中常常能够用到的小工具
https://blog.csdn.net/sanri1993/article/details/98664034

感谢原做者,文章引用

原做者的文章恰好能和视频对上，太感谢了，我只是帮原做者作了个文章排序而已；
引用你的文章但愿不介意

https://blog.csdn.net/qq78442761/article/category/9040352
https://www.cnblogs.com/ssh-html/p/10542841.html