RabbitMQ 安装体验

前言
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 {@Resourceprivate 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);}}

控制台输出：

至此，全部安装结束。