前言
RabbitMQ是一个开源的遵循 AMQP协议实现的基于 Erlang语言编写,即需要先安装部署Erlang环境再安装RabbitMQ环境。
一、Erlang下载安装
https://packagecloud.io/rabbitmq/erlang
上执行命令 此时,Erlang的rpm包下载完成,见下图。
wget --content-disposition "https://packagecloud.io/rabbitmq/erlang/packages/el/7/erlang-23.3.4.11-1.el7.x86_64.rpm/download.rpm?distro_version_id=140"
接着,安装已下载的rpm包(可根据刚才自己选择的版本修改下面的版本号),执行命令:
yum localinstall erlang-23.3.4.11-1.el7.x86_64.rpm
最后,Erlang包安装完成见图
二、RabbitMQ下载安装
https://packagecloud.io/rabbitmq/rabbitmq-server
RabbitMQ的rpm包下载
wget --content-disposition "https://packagecloud.io/rabbitmq/rabbitmq-server/packages/el/7/rabbitmq-server-3.10.0-1.el7.noarch.rpm/download.rpm?distro_version_id=140"
接着,当你下载完成后,你需要运行下面的命令来将 Key 导入,执行命令:
rpm --import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc
最后,使用 yum 进行本地安装(可根据自己选择的版本修改下面的版本号),执行命令:
yum localinstall rabbitmq-server-3.10.0-1.el7.noarch.rpm
RabbitMQ安装成功,见下图。
当安装完成后,需要启动 rabbitmq 服务器,执行命令:
systemctl start rabbitmq-server
设置开机自动启动,执行命令:
systemctl enable rabbitmq-server
三、RabbitMQ Web界面管理
默认情况下,是没有安装web端的客户端插件,
需要安装才可以生效。执行命令:
rabbitmq-plugins enable rabbitmq_management
安装完毕以后,重启服务即可,执行命令:
systemctl restart rabbitmq-server
注意,请在服务器上开放 15672 端口。
rabbitmq有一个默认账号和密码是: **guest 。**默认情况只能在 localhost本机下访问(见下图),所以需要新增一个远程登录的用户。
新增用户。此时,账号密码都设置为admin:
rabbitmqctl add_user admin admin
设置用户分配操作权限。
rabbitmqctl set_user_tags admin administrator
设置用户权限 名命令或者登录超级管理员进行认证设置
rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"
设置用户权限 登录超级管理员进行认证设置如下:
RabbitMQ服务 配置 进件简单测试
1、创建springboot-rabbitMq工程,pom依赖配置
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.1</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.liu.jxing</groupId>
<artifactId>springboot-rabbitMq</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>springboot-rabbitMq</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!-- 系统健康检测模块依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!-- rabbitmq模块依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
2、配置 application.properties
# 服务端口
server.port=8080
# 应用名称 Monitor
spring.application.name=SpringbootMonitor
# 开启所有的端点
management.endpoints.web.exposure.include=*
# RabbitMQ 配置
spring.rabbitmq.host=test-jxing.cn
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=admin
# RabbitMQ 服务创建的虚拟主机(非必须)
spring.rabbitmq.virtual-host=/
服务启动:
RabbitMQ连接报错:An unexpected connection driver error occured
设置mq服务端 Current permissions 链接权限名命令 或者 登录超级管理员进行认证设置
rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"
3、创建生产者
package com.liu.jxing.demo.mq;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
/**
* 创建生产者
* 生产者需要用到 RabbitTemplate 类来生产消息并进行消息发送
*/
@Component
public class Producer {
@Resource
private RabbitTemplate rabbitTemplate;
public void produce(String say) {
String message = say+":这是第一次测试";
System.out.println(message);
rabbitTemplate.convertAndSend("notice_queue", message);
}
}
4、创建消费者
package com.liu.jxing.demo.mq;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
/**
* 创建消费者
* Consumer 消费者通过 @RabbitListener 注解创建侦听器端点,绑定 notice_queue 队列。
*
* @RabbitListener 注解提供了@QueueBinding、@Queue、@Exchange 等对象,通过这个组合注解配置交换机、绑定路由并且配置监听功能等。
*
* @RabbitHandler 注解为具体接收的方法
*/
@Component
public class Consumer {
@RabbitHandler
@RabbitListener(queuesToDeclare = @Queue("notice_queue"))
public void process(String message) {
System.out.println("收到通知:" + message);
}
}
控制台输出:
至此,全部安装结束。