1.安装

Erlang 官网下载地址:http://www.erlang.org/downloads

RabbitMQ 官网下载地址:https://www.rabbitmq.com/download.html

注意Erlang 版本和RabbitMQ 版本的兼容性,并且Erlang 要比RabbitMQ 先安装好

RabbitMQ安装与使用

下载好了先安装Erlang 按照默认的一直next就行了 ,当然你也可以改安装目录地址

安装好了之后配置坏境变量,变量名我们取成ERLANG_HOME,变量值为你的Erlang的安装目录,再在系统变量的Path里添加上%ERLANG_HOME%\bin

RabbitMQ安装与使用

RabbitMQ安装与使用

打开cmd输入erl如果显示出现如下图则说明成功

RabbitMQ安装与使用

再安装RabbitMQ,也按照默认的配置一直next就行,安装好了也要配置坏境变量,在系统变量那新建一个变量名为RABBITMQ_SERVER,变量值为你的RabbitMQ安装的地址,再在系统变量的Path中添加%RABBITMQ_SERVER%\sbin

RabbitMQ安装与使用

RabbitMQ安装与使用

然后**RabbitMQ,我们打开RabbitMQ Command Prompt

RabbitMQ安装与使用

然后输入 rabbitmq-plugins.bat enable rabbitmq_management,出现下图说明**成功

RabbitMQ安装与使用

 

然后在输入rabbitmq-service start启动RabbitMQ,启动好了在浏览器中输入http://localhost:15672/#/。 

输入账号密码进行登录,RabbitMQ的默认账号密码是guest,

RabbitMQ安装与使用

 2.使用

打开IDEA,创建两个SpringBoot项目,一个生产者(rabbitmq-producer),一个消费者(rabbitmq-consumer)

RabbitMQ安装与使用RabbitMQ安装与使用

RabbitMQ安装与使用 RabbitMQ安装与使用

消费者也按照上面的步骤进行创建项目 

打开rabbitmq-producer和rabbitmq-consumer添加RabbitMQ的jar包

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

并在application配置文件中配置一下内容,我用的yml文件格式

spring:
  application:
    name: spirng-boot-rabbitmq-porducer
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: 你的rabbitmq账号
    password: 密码

在生产者创建MessageNotifySender类

RabbitMQ安装与使用

在消费者创建 DirectConfig配置类和MessageNotifyReceive消息接收类

RabbitMQ安装与使用RabbitMQ安装与使用

启动消费者,然后再在生产者进行测试

RabbitMQ安装与使用

在生产方和消费发日志中我们可以看到如下内容

 RabbitMQ安装与使用 RabbitMQ安装与使用

可看出成功了, 以上就是一个简单的例子

3.会出现的问题

如果你是一个新建的用户配置在SpringBoot中的配置文件中,可能为出现Scoket close这个问题,因为新建的用户没有权限,跟着下图走

RabbitMQ安装与使用

RabbitMQ安装与使用

RabbitMQ安装与使用

RabbitMQ安装与使用

这样就OK了

相关文章: