RabbitMQ

RabbitMQ知识分享，包括maven整合MQ、SpringBoot整合MQ、消息可靠性、消息延迟等等。

RabbitMQ

• 流量消峰 应用解耦 异步处理 
• 安装
  • 安装前准备： 如果之前安装erlang，先删除 安装C++环境  1. 上传文件到/usr/local/software  或者采用在线下载的方式：（两个安装包） 2. 安装文件 安装erlang  由于要将安装目录放到erlang中，所以提前在local目录下创建好erlang文件夹   安装RabbitMQ   3.依次执行   RabbitMQ默认提供了一个guests账号，但此账号只能用作远程登录，也就是不能再管理系统的登录，所以创建一个新的账号并授予响应的管理权限实现远程登录 创建新用户    登录之后可以继续创建新用户，第一次只能采用命令模式创建用户   放行端口    阿里云 
  • 官网下载：https://www.rabbitmq.com/download.html
• 逻辑结构
  • 创建虚拟主机
    • 创建虚拟主机  进入虚拟主机，可以进行用户授权和清除，也可以直接删除虚拟机。 
  • 在虚拟机下创建队列
    •  
  • 在虚拟机下创建交换机
    •    
• 工作方式
  • 简单模式
    • 一个生产者，一个消费者
  • 工作模式
  • 订阅方式
  • 路由方式
• 消息可靠性
  • RabbitMQ事务： 
  • 生产者如何保证消息可靠性
    • 生产者（消息确认机制{同步+异步}+return机制）  普通maven项目的消息确认+return机制： 同步方式：waitForConfirms()会起到阻塞作用，若迟迟不返回结果则后面的代码无法执行  异步方式：addConfirmListener()方法，即使消息确认结果为返回也不影响后面代码的执行。  return机制  ========================================= SpringBoot项目的消息确认+return机制：  创建自定义消息确认监听器  创建自定义消息return机制 
  • 消费者如何保证消息可靠性
    • 消费者  普通maven项目的手动ACK： 确保消息是被消费者成功处理   =========================================
• 消息延迟
  •  依赖，配置文件    死信队列，没有消费者 
• SpringBoot整合MQ
  • 消息生产者 依赖：web+lombok+spring for RabbitMQ application.yml  controller+service+serviceImpl   进行访问 消息消费者 依赖+配置文件yml 其中@RabbitListener(queues = {"queue1","queue5"}) 可以接收多个队列  ====================================================== SpringBoot中通过代码创建队列 通过配置类创建队列、交换机    当请求访问路径调用，若虚拟主机中没有该队列，则会创建 
• maven工程整合MQ
  • 消息生产者：     消息消费者  ================= 
• 概要
  • 使用RabbitMQ传递对象： 第一种  第二种  第三种：不需要实现序列化