RabbitMQ 安装&体验

àì夳堔傛蜴生んèń 2023-09-26 20:34 92阅读 0赞

**前言**  
RabbitMQ是一个开源的遵循 AMQP协议实现的基于 Erlang语言编写，即需要先安装部署Erlang环境再安装RabbitMQ环境。

**一、Erlang下载安装**  
https://packagecloud.io/rabbitmq/erlang

上执行命令 此时，Erlang的rpm包下载完成，见下图。  
![在这里插入图片描述][6f87e111a6dd45fdb40b2f815deaca45.png]

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

![在这里插入图片描述][3a73322fc83f49669fd0a9190326e382.png]  
最后，Erlang包安装完成见图  
![在这里插入图片描述][e1fd3952053840cbb3771d2df1e7063e.png]

二、RabbitMQ下载安装  
https://packagecloud.io/rabbitmq/rabbitmq-server

![在这里插入图片描述][c77db7505a7d4aecba0db5d11a902b02.png]  
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"

![在这里插入图片描述][8b0ec766b00344b597853f52c0479389.png]

接着，当你下载完成后，你需要运行下面的命令来将 Key 导入，执行命令：

rpm --import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc

最后，使用 yum 进行本地安装（可根据自己选择的版本修改下面的版本号），执行命令：

yum localinstall rabbitmq-server-3.10.0-1.el7.noarch.rpm

![在这里插入图片描述][102f71889bc54998aece0d3c1be61764.png]

RabbitMQ安装成功，见下图。  
![在这里插入图片描述][cd6760a9f11b4383b2b4adde5034bfcc.png]

当安装完成后，需要启动 rabbitmq 服务器，执行命令：

systemctl start rabbitmq-server

![在这里插入图片描述][ad7dc43fb5a84c9e8cb16cab0a318636.png]

设置开机自动启动，执行命令：

systemctl enable rabbitmq-server

**三、RabbitMQ Web界面管理**  
默认情况下，是没有安装web端的客户端插件，

需要安装才可以生效。执行命令：

rabbitmq-plugins enable rabbitmq_management

安装完毕以后，重启服务即可，执行命令：

systemctl restart rabbitmq-server

注意，请在服务器上开放 15672 端口。  
rabbitmq有一个默认账号和密码是： \*\*guest 。\*\*默认情况只能在 localhost本机下访问（见下图），所以需要新增一个远程登录的用户。  
![在这里插入图片描述][adc089c641984aeeb84afeda0bc7acff.png]

新增用户。此时，账号密码都设置为admin：

rabbitmqctl add_user admin admin

设置用户分配操作权限。

rabbitmqctl set_user_tags admin administrator

设置用户权限 名命令或者登录超级管理员进行认证设置

rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"

设置用户权限 登录超级管理员进行认证设置如下：  
![在这里插入图片描述][4a5b71760ebd445faae42ff175b6f1df.png]

**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/> 
        </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>
            
            <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);
        }
    
    }

控制台输出：  
![在这里插入图片描述][ade20973792449579c7c0132ad1b393d.png]  
至此，全部安装结束。

[6f87e111a6dd45fdb40b2f815deaca45.png]: https://img-blog.csdnimg.cn/6f87e111a6dd45fdb40b2f815deaca45.png
[3a73322fc83f49669fd0a9190326e382.png]: https://img-blog.csdnimg.cn/3a73322fc83f49669fd0a9190326e382.png
[e1fd3952053840cbb3771d2df1e7063e.png]: https://img-blog.csdnimg.cn/e1fd3952053840cbb3771d2df1e7063e.png
[c77db7505a7d4aecba0db5d11a902b02.png]: https://img-blog.csdnimg.cn/c77db7505a7d4aecba0db5d11a902b02.png
[8b0ec766b00344b597853f52c0479389.png]: https://img-blog.csdnimg.cn/8b0ec766b00344b597853f52c0479389.png
[102f71889bc54998aece0d3c1be61764.png]: https://img-blog.csdnimg.cn/102f71889bc54998aece0d3c1be61764.png
[cd6760a9f11b4383b2b4adde5034bfcc.png]: https://img-blog.csdnimg.cn/cd6760a9f11b4383b2b4adde5034bfcc.png
[ad7dc43fb5a84c9e8cb16cab0a318636.png]: https://img-blog.csdnimg.cn/ad7dc43fb5a84c9e8cb16cab0a318636.png
[adc089c641984aeeb84afeda0bc7acff.png]: https://img-blog.csdnimg.cn/adc089c641984aeeb84afeda0bc7acff.png
[4a5b71760ebd445faae42ff175b6f1df.png]: https://img-blog.csdnimg.cn/4a5b71760ebd445faae42ff175b6f1df.png
[ade20973792449579c7c0132ad1b393d.png]: https://img-blog.csdnimg.cn/ade20973792449579c7c0132ad1b393d.png