消息 :

消息接收方

同步消息 : 收到响应消息之后才能继续发送

异步消息 : 不需要响应消息就可以继续发送

---

企业级应用中广泛使用的三种异步消息传递技术

AMQP: 一个协议 , 规范了数据的传输格式

MQTT:

---

SpringBoot整合各种消息技术 :

---

ActiveMQ:

下载安装:

下载地址 : https://activemq.apache.org/components/classic/download/

直接双击第一个 , 启动之后 , 访问 http://127.0.0.1:8161/ ,会显示一个管理后台页面 , 默认用户名密码是admin

---

使用:

---

设置发布订阅模型 ,

默认的处理模型是点对点的模型 , 一个消息只能有一个消费者消费 , 或超时

切换模型 . 要在配置文件中设置 , 即可

pub-sub-domain: true ;
 

---

RabbitMQ:

下载安装:

RabbitMQ是基于Erlang语言编写的 , 需要安装Erlang

下载地址: https://www.erlang.org/downloads

安装一键式安装 , 安装完毕需要重启 , 需要依赖windows组件

环境变量 :

安装RabbitMQ

https://rabbitmq.com/install-windows.html

---

启动:

在安装目录下 , 有一个sbin目录 , 这个目录下就是RabbitMQ的可执行文件

启动命令 :

注意需要要使用管理员权限启动

rabbitmq-service.bat start
 

关闭使用 :

rabbitmq-service.bat stop
 

开启管理后台页面 :

在控制台 输入 :可以查看携带的所有插件的状态

rabbitmq-plugins.bat list
 

使用的是这个插件 :

启动这个插件 :

rabbitmq-plugins.bat enable rabbitmq_management 
 

启动之后 , 前边的括号中会有一个E , 如果是这个插件携带的插件 , 前边的括号中是一个 e

RabbitMQ的后台管理端口

用户名和密码是guest

---

使用direct(直连交换机模式) :

---

使用 Topic (主题交换机模式) :

定义消息队列 : 可以指定绑定键的名称 , 在使用这个队列的时候进行匹配 , 也就是一个消息可以指定多个队列进行消费 ,

---

RocketMQ:

下载安装 :

下载地址 : https://rocketmq.apache.org/

安装 :解压缩即可

环境变量 :

启动命名服务器 :

双击bin目录下的mqnamesrv.cmd文件 , 启动命名服务器

启动broker服务器

双击bin目录下的mqbroker.cmd , 启动broker服务器

---

配置这个命名服务器之后

---

配置yml文件 :

编写实现类 :

编写监听类 :