概述

明天给大家分享以下三局部内容：

  • Docker 装置 RabbitMQ
  • Spring Boot and RabbitMQ demo
  • RabbitMQ 提早队列

Docker 装置 RabbitMQ

第一步：拉取镜像

docker pull rabbitmq:management

第二步：启动

docker run -d \--name rabbitmq \-p 5672:5672 \-p 15672:15672 \-v /data/rabbitmq:/var/lib/rabbitmq \--hostname myRabbit \-e RABBITMQ_DEFAULT_VHOST=my_vhost \-e RABBITMQ_DEFAULT_USER=admin \-e RABBITMQ_DEFAULT_PASS=admin \rabbitmq:management

阐明：

-d 后盾运行容器；

--name 指定容器名；

-p 指定服务运行的端口（5672：利用拜访端口；15672：控制台Web端口号）；

-v 映射目录或文件；

--hostname 主机名（RabbitMQ的一个重要注意事项是它依据所谓的 “节点名称” 存储数据，默认为主机名）；

-e 指定环境变量；（RABBITMQ_DEFAULT_VHOST：默认虚拟机名；RABBITMQ_DEFAULT_USER：默认的用户名；RABBITMQ_DEFAULT_PASS：默认用户名的明码）

Spring Boot and RabbitMQ demo

依赖

<dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-amqp</artifactId></dependency>

配置

spring:  rabbitmq:    host: localhost    port: 5672    username: admin    password: admin    virtual-host: my_vhost

配置

发送

接管

测试

GET http://localhost:8080/sendMsg...

RabbitMQ 提早队列

首先来看一个错：

channel error； protocol method: #method＜channel.close＞(reply-code=404, reply-text=NOT_FOUND - no

起因是，提早队列是 RabbitMQ 的一个插件，默认没有装置，须要装置。

相干链接：

  • RabbitMQ 插件：https://www.rabbitmq.com/comm...
  • 提早插件：https://github.com/rabbitmq/r...

装置插件：

  • 1.下载提早队列插件
  • 2.将插件复制到 RabbitMQ 的 /plugins 目录下。拷贝办法：docker cp rabbitmq_delayed_message_exchange-3.10.2.ez containerId:/plugins
  • 3.执行，在 /plugins 目录下执行：rabbitmq-plugins enable rabbitmq_delayed_message_exchange
  • 4.重启 RabbitMQ

配置：

发送

接管音讯：

测试：

GET http://localhost:8080/sendDel...