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 {

    @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);
    }

}

控制台输出：

至此，全部安装结束。