1.安装
Erlang 官网下载地址:http://www.erlang.org/downloads
RabbitMQ 官网下载地址:https://www.rabbitmq.com/download.html
注意Erlang 版本和RabbitMQ 版本的兼容性,并且Erlang 要比RabbitMQ 先安装好
下载好了先安装Erlang 按照默认的一直next就行了 ,当然你也可以改安装目录地址
安装好了之后配置坏境变量,变量名我们取成ERLANG_HOME,变量值为你的Erlang的安装目录,再在系统变量的Path里添加上%ERLANG_HOME%\bin
打开cmd输入erl如果显示出现如下图则说明成功
再安装RabbitMQ,也按照默认的配置一直next就行,安装好了也要配置坏境变量,在系统变量那新建一个变量名为RABBITMQ_SERVER,变量值为你的RabbitMQ安装的地址,再在系统变量的Path中添加%RABBITMQ_SERVER%\sbin
然后**RabbitMQ,我们打开RabbitMQ Command Prompt
然后输入 rabbitmq-plugins.bat enable rabbitmq_management,出现下图说明**成功
然后在输入rabbitmq-service start启动RabbitMQ,启动好了在浏览器中输入http://localhost:15672/#/。
输入账号密码进行登录,RabbitMQ的默认账号密码是guest,
2.使用
打开IDEA,创建两个SpringBoot项目,一个生产者(rabbitmq-producer),一个消费者(rabbitmq-consumer)
消费者也按照上面的步骤进行创建项目
打开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类
在消费者创建 DirectConfig配置类和MessageNotifyReceive消息接收类
启动消费者,然后再在生产者进行测试
在生产方和消费发日志中我们可以看到如下内容
可看出成功了, 以上就是一个简单的例子
3.会出现的问题
如果你是一个新建的用户配置在SpringBoot中的配置文件中,可能为出现Scoket close这个问题,因为新建的用户没有权限,跟着下图走
这样就OK了