RabbitMQ（安装配置以及与SpringBoot整合）

文章目录

    • 1.基本介绍
    • 2.Linux下安装配置RabbitMQ
        • 1.安装erlang环境
          • 1.将文件上传到/opt目录下
          • 2.进入/opt目录下，然后安装
        • 2.安装RabbitMQ
          • 1.进入/opt目录，安装所需依赖
          • 2.安装MQ
        • 3.基本配置
          • 1.启动MQ
          • 2.查看MQ状态
          • 3.安装web管理插件
          • 4.安装web管理插件超时的解决方案
            • 1.修改etc/hosts文件，修改主机名
            • 2.重启MQ如果还报错就修改ip与本机ip相同
          • 5.设置开机自启
          • 6.关闭MQ
          • 7.组合指令
            • 1.启动MQ并查看状态
            • 2.关闭MQ并查看状态
            • 3.重启MQ并查看状态
        • 4.RabbitMQ管控台配置
          • 1.开放15672端口
            • 1.宝塔开启
            • 2.腾讯云开启，仅限本机登录
          • 2.访问 http://ip:15672 进行登录
            • 1.使用guest用户登录，出现权限问题
            • 2.进入/etc/rabbitmq 编辑 rabbitmq.config
            • 3.将下面这句话粘贴进去
            • 4.重启MQ，使配置生效
            • 5.再次登录，成功！
          • 3.控制台参数解析
            • 1.端口
            • 2.交换机，默认七个
          • 4.用户管理
            • 1.进入Admin
            • 2.添加用户test，默认不能访问虚拟主机
            • 3.给test用户分配可以访问的虚拟主机
            • 4.为了安全，修改guest用户的密码
          • 5.增加虚拟主机
            • 1.添加/test的虚拟主机
            • 2.配置test用户可以访问虚拟主机/test
            • 3.删除test用户
    • 5.SpringBoot集成MQ
        • 1.需求分析
        • 2.环境配置
          • 1.引入依赖
          • 2.MQ的端口配置
            • 1.编辑MQ的配置文件
            • 2.修改端口5672为6783（防止被攻击）
            • 3.重启MQ使其生效
            • 4.测试是否成功
            • 5.宝塔开启6783端口
            • 6.腾讯云开启
          • 3.配置application.yml
          • 4.RabbitMQ配置类创建队列 RabbitMQConfig.java
        • 3.基本使用
          • 1.编写消息发送者 MQSender.java
          • 2.编写消息接受者 MQReceiver.java
          • 3.控制层调用发送消息的方法
          • 4.启动测试
            • 1.访问 http://localhost:9092/seckill/mq 成功发送和接受消息
            • 2.http://ip:15672 在控制台可以进行监控

1.基本介绍

image-20240511093548128

2.Linux下安装配置RabbitMQ

1.安装erlang环境
1.将文件上传到/opt目录下

image-20240511094141520

2.进入/opt目录下，然后安装
cd /opt && rpm -ivh erlang-21.3-1.el7.x86_64.rpm

image-20240511094607525

2.安装RabbitMQ
1.进入/opt目录，安装所需依赖
cd /opt && yum install socat -y

image-20240511094818005

2.安装MQ
rpm -ivh rabbitmq-server-3.8.8-1.el7.noarch.rpm

image-20240511094907481

3.基本配置
1.启动MQ
/sbin/service rabbitmq-server start

image-20240511095035550

2.查看MQ状态
/sbin/service rabbitmq-server status

image-20240511095131428

3.安装web管理插件
rabbitmq-plugins enable rabbitmq_management

image-20240511095242435

4.安装web管理插件超时的解决方案
1.修改etc/hosts文件，修改主机名

image-20240511095330229

image-20240511095429376

2.重启MQ如果还报错就修改ip与本机ip相同

image-20240511095825597

5.设置开机自启
chkconfig rabbitmq-server on

image-20240511100028069

6.关闭MQ
/sbin/service rabbitmq-server stop

image-20240511100119207

7.组合指令
1.启动MQ并查看状态
/sbin/service rabbitmq-server start && /sbin/service rabbitmq-server status

image-20240511100244007

2.关闭MQ并查看状态
/sbin/service rabbitmq-server stop && /sbin/service rabbitmq-server status

image-20240511100349257

3.重启MQ并查看状态
/sbin/service rabbitmq-server stop && /sbin/service rabbitmq-server start && /sbin/service rabbitmq-server status

image-20240511100501531

4.RabbitMQ管控台配置
1.开放15672端口
1.宝塔开启
systemctl start firewalld && firewall-cmd --permanent --add-port=15672/tcp && firewall-cmd --reload && firewall-cmd --query-port=15672/tcp

image-20240511101456789

2.腾讯云开启，仅限本机登录

image-20240511101924825

2.访问 http://ip:15672 进行登录
1.使用guest用户登录，出现权限问题

image-20240511102159480

2.进入/etc/rabbitmq 编辑 rabbitmq.config
cd /etc/rabbitmq && vim rabbitmq.config

image-20240511102448107

3.将下面这句话粘贴进去
[
{
	rabbit,
		[{
			loopback_users,[]
		}]
}
].

image-20240511102612261

4.重启MQ，使配置生效
/sbin/service rabbitmq-server stop && /sbin/service rabbitmq-server start && /sbin/service rabbitmq-server status
5.再次登录，成功！

image-20240511102721570

3.控制台参数解析
1.端口

image-20240511102910962

2.交换机，默认七个

image-20240511102958591

4.用户管理
1.进入Admin

image-20240511103240680

2.添加用户test，默认不能访问虚拟主机

image-20240511103411192

image-20240511103438155

3.给test用户分配可以访问的虚拟主机

image-20240511103552470

image-20240511103630246

image-20240511103642661

4.为了安全，修改guest用户的密码

image-20240511104138104

5.增加虚拟主机
1.添加/test的虚拟主机

image-20240511103749131

2.配置test用户可以访问虚拟主机/test

image-20240511103850074

image-20240511103857649

3.删除test用户

image-20240511104414406

5.SpringBoot集成MQ

1.需求分析

image-20240511104725661

2.环境配置
1.引入依赖
        <!--rabbitmq-需要的 AMQP 依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
2.MQ的端口配置
1.编辑MQ的配置文件
cd /etc/rabbitmq && vim rabbitmq.config
2.修改端口5672为6783（防止被攻击）
[
    {rabbit, [
        {tcp_listeners, [{"0.0.0.0", 6783}]},
        {loopback_users, []}
    ]}
].
3.重启MQ使其生效
/sbin/service rabbitmq-server stop && /sbin/service rabbitmq-server start && /sbin/service rabbitmq-server status
4.测试是否成功
netstat -plnt | grep 6783

image-20240511142336772

5.宝塔开启6783端口
systemctl start firewalld && firewall-cmd --permanent --add-port=6783/tcp && firewall-cmd --reload && firewall-cmd --query-port=6783/tcp

image-20240511135713648

6.腾讯云开启

image-20240511135640831

3.配置application.yml
  # RabbitMQ 配置
  rabbitmq:
    # 服务器地址
    host: 
    # 用户名
    username: 
    # 密码
    password: ******
    # 虚拟主机
    virtual-host: /
    # 端口
    port: 6783
    # 消息监听器配置
    listener:
      simple:
        #消费者最小数量
        concurrency: 10
        #消费者最大数量
        max-concurrency: 10
        #限制消费者，每次只能处理一条消息，处理完才能继续下一条消息
        prefetch: 1
        #启动时是否默认启动容器，默认为 true
        auto-startup: true
        #被拒绝时重新进入队列的
        default-requeue-rejected: true
    # 消息重试配置
    template:
      retry:
        #启用消息重试机制，默认为 false
        enabled: true
        #初始重试间隔时间
        initial-interval: 1000ms
        #重试最大次数，默认为 3 次
        max-attempts: 3
        #重试最大时间间隔，默认 10000ms
        max-interval: 10000ms
        #重试的间隔乘数
        #配置 2 的话，第一次等 1s，第二次等 2s，第三次等 4s
        multiplier: 1
4.RabbitMQ配置类创建队列 RabbitMQConfig.java
package com.sxs.seckill.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * Description:
 *
 * @Author sun
 * @Create 2024/5/11 13:58
 * @Version 1.0
 */
@Configuration
public class RabbitMQConfig {
    private static final String QUEUE = "queue";
    /**
     * 1. 配置队列
     * 2. 队列名为 queue
     * 3. true 表示: 持久化
     * durable： 队列是否持久化。 队列默认是存放到内存中的，rabbitmq 重启则丢失，
     * 若想重启之后还存在则队列要持久化，
     * 保存到 Erlang 自带的 Mnesia 数据库中，当 rabbitmq 重启之后会读取该数据库
     */
    @Bean
    public Queue queue() {
        return new Queue(QUEUE, true);
    }
}
3.基本使用
1.编写消息发送者 MQSender.java
package com.sxs.seckill.rabbitmq;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * Description: 消息发送者
 *
 * @Author sun
 * @Create 2024/5/11 14:04
 * @Version 1.0
 */
@Service
@Slf4j
public class MQSender {
    @Resource
    private RabbitTemplate rabbitTemplate;

    public void send(Object message) {
        log.info("发送消息: " + message);
        // 发送消息到队列，需要指定在配置类中配置的队列名
        rabbitTemplate.convertAndSend("queue", message);
    }
}
2.编写消息接受者 MQReceiver.java
package com.sxs.seckill.rabbitmq;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;


/**
 * Description: 消息接收者
 *
 * @Author sun
 * @Create 2024/5/11 14:08
 * @Version 1.0
 */
@Service
@Slf4j
public class MQReceiver {

    // 方法，接收消息
    @RabbitListener(queues = "queue")
    public void receive(Object message) {
        log.info("接收消息: " + message);
    }
}
3.控制层调用发送消息的方法
package com.sxs.seckill.controller;

import com.sxs.seckill.rabbitmq.MQSender;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.annotation.Resource;

/**
 * Description:
 *
 * @Author sun
 * @Create 2024/5/11 14:13
 * @Version 1.0
 */
@Controller
public class RabbitMQHandler {
    @Resource
    private MQSender mqSender;
    
    // 调用发送消息的方法
    @RequestMapping("/mq")
    @ResponseBody
    public void mq() {
        mqSender.send("hello rabbitmq");
    }
}
4.启动测试
1.访问 http://localhost:9092/seckill/mq 成功发送和接受消息

image-20240511142633815

2.http://ip:15672 在控制台可以进行监控

image-20240511143128879

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/614620.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

操作系统基础之磁盘

操作系统基础之磁盘

概述 基本概念 磁盘有正反两个盘面&#xff0c;每个盘面有多个同心圆&#xff0c;每个同心圆是一个磁道&#xff0c;每个同心圆又被划分为多个扇区&#xff0c;数据就被存在扇区中。 磁头首先寻找到对应磁道&#xff0c;然后等到磁盘进行周期旋转到指定的扇区&#xff0c;才…
阅读更多...
【SpringBoot篇】基于Redis分布式锁的 误删问题 和 原子性问题

【SpringBoot篇】基于Redis分布式锁的 误删问题 和 原子性问题

文章目录 &#x1f354;Redis的分布式锁&#x1f6f8;误删问题&#x1f388;解决方法&#x1f50e;代码实现 &#x1f6f8;原子性问题&#x1f339;Lua脚本 ⭐利用Java代码调用Lua脚本改造分布式锁&#x1f50e;代码实现 &#x1f354;Redis的分布式锁 Redis的分布式锁是通过利…
阅读更多...
工业中常见大数据技术组件

工业中常见大数据技术组件

随着大数据技术在各行各业的广泛应用&#xff0c;数据产品经理的角色也变得越来越重要。了解常见的大数据技术组件对于数据产品经理来说至关重要&#xff0c;因为这有助于他们更好地设计产品架构和功能模块&#xff0c;满足数据处理和分析的需求。在处理海量数据的产品中&#…
阅读更多...
【Linux】-网络请求和下载、端口[6]

【Linux】-网络请求和下载、端口[6]

目录 一、网络请求和下载 1、ping命令 2、wget命令 3、curl命令 二、端口 1、虚拟端口 2、查看端口占用 一、网络请求和下载 1、ping命令 可以通过ping命令&#xff0c;检查指定的网络服务器是否可联通状态 语法&#xff1a;ping [ -c num ] ip或主机名 选项&…
阅读更多...
window.location.href的介绍及使用

window.location.href的介绍及使用

目录 介绍&#xff1a; 获取当前 URL 设置新的 URL URL 的组成部分 解析 URL 参数 什么是片段标识符的URL&#xff1f; 使用new URL&#xff1a; 输出的部分解释&#xff1a; 假如我们需要获取路径上的最后一级的路径名&#xff1a; 介绍&#xff1a; window.location.h…
阅读更多...
2023版brupsuite专业破解安装

2023版brupsuite专业破解安装

安装教程&#xff0c;分两部分&#xff1a; 1、安装java环境、参考链接JAVA安装配置----最详细的教程&#xff08;测试木头人&#xff09;_java安装教程详细-CSDN博客 2、安装2023.4版本brupsuite&#xff1a;参考链接 2023最新版—Brup_Suite安装配置----最详细的教程&…
阅读更多...
【数据分析】 JupyterNotebook安装及使用简介

【数据分析】 JupyterNotebook安装及使用简介

各位大佬好 &#xff0c;这里是阿川的博客 &#xff0c; 祝您变得更强 个人主页&#xff1a;在线OJ的阿川 大佬的支持和鼓励&#xff0c;将是我成长路上最大的动力 阿川水平有限&#xff0c;如有错误&#xff0c;欢迎大佬指正 在数据分析中&#xff0c;一般用Pycharm编辑代…
阅读更多...
大模型面试常考知识点1

大模型面试常考知识点1

文章目录 1. 写出Multi-Head Attention2. Pre-Norm vs Post-Norm3. Layer NormRMS NormBatch Norm 4. SwiGLU从ReLU到SwishSwiGLU 5. AdamW6. 位置编码Transformer位置编码RoPEALibi 7. LoRA初始化 参考文献 1. 写出Multi-Head Attention import torch import torch.nn as nn …
阅读更多...
按键配合LDO实现开关功能

按键配合LDO实现开关功能

今天给大家分享一个学到的按键开关电路&#xff0c;适合没有足够空间给自锁开关的场景&#xff0c;既可以用于USB供电控制也可以用于电池供电控制。话不多说上电路图先。 核心任务就是通过按键控制LDO芯片的使能管脚的电平状态&#xff0c;这枚NCP芯片高电平使能&#xff0c;VB…
阅读更多...
ETLCloud中如何执行Java Bean脚本

ETLCloud中如何执行Java Bean脚本

ETLCloud中如何执行Java Bean脚本 在ETLCloud这一强大的数据集成和转换平台中&#xff0c;执行Java Bean脚本的能力为其增添了更多的灵活性和扩展性。Java Bean脚本不仅仅是一段简单的代码&#xff0c;而是一种强大的工具&#xff0c;可以帮助用户定制和优化数据处理的每一个环…
阅读更多...
AI 绘画神器 Fooocus 2.3.1 汉化教程（中文界面/汉化包下载/持续更新最新版本...）

AI 绘画神器 Fooocus 2.3.1 汉化教程（中文界面/汉化包下载/持续更新最新版本...）

本文收录于《AI绘画从入门到精通》专栏&#xff0c;专栏总目录&#xff1a;点这里&#xff0c;订阅后可阅读专栏内所有文章。 大家好&#xff0c;我是水滴~~ Fooocus 是一款功能强大的 AI 绘画神器&#xff0c;它能够帮助我们以更高效、更创意的方式进行绘画创作。本教程将详细…
阅读更多...
C++入门系列-构造函数

C++入门系列-构造函数

&#x1f308;个人主页&#xff1a;羽晨同学 &#x1f4ab;个人格言:“成为自己未来的主人~” 类的6个默认成员函数 如果一个类中什么成员都没有&#xff0c;简称为空类。 空类中真的什么都没有吗&#xff1f;并不是&#xff0c;任何类在什么都不写时&#xff0c;编译器会…
阅读更多...
社交媒体数据恢复：飞书

社交媒体数据恢复：飞书

飞书数据恢复过程包括以下几个步骤&#xff1a; 确认数据丢失&#xff1a;首先要确认数据是否真的丢失&#xff0c;有时候可能只是被隐藏或者误操作删除了。 检查回收站&#xff1a;飞书中删除的文件会默认保存在回收站中&#xff0c;用户可以通过进入回收站找到被删除的文件&…
阅读更多...
推荐全网最全的AI小白进阶指南

推荐全网最全的AI小白进阶指南

1. 引言 您想学习人工智能&#xff1f;但不知道如何开始&#xff0c;也不知道从哪里开始&#xff1f;互联网上的资源总是丰富多彩&#xff0c;质量参差不齐&#xff0c;往往容易看花眼而无从下手。 鉴于此&#xff0c;本文重点推荐一些个人收集的还不错的一些资源供大家学习参…
阅读更多...
ApiHug Official Website

ApiHug Official Website

&#x1f917; ApiHug {Postman|Swagger|Api...} 快↑ 准√ 省↓ GitHub - apihug/apihug.com: All abou the Apihug apihug.com: 有爱&#xff0c;有温度&#xff0c;有质量&#xff0c;有信任ApiHug - API design Copilot - IntelliJ IDEs Plugin | MarketplaceApiHug-H…
阅读更多...
DSSAT作物模建模方法

DSSAT作物模建模方法

原文链接&#xff1a;DSSAT作物模建模方法https://mp.weixin.qq.com/s?__bizMzUzNTczMDMxMg&mid2247604079&idx5&sn0151d083d35c9ea259cf155d082b0145&chksmfa821688cdf59f9eddae14a99fce4f56c6ad9d73db38e0b9b165dcb9b315b6ed845d83cd085f&token94156244…
阅读更多...
c++多态机制

c++多态机制

多态 在 C 中&#xff0c;多态&#xff08;Polymorphism&#xff09;是一种面向对象编程的重要概念&#xff0c;它允许不同类的对象对同一消息做出不同的响应。具体来说&#xff0c;多态性允许基类的指针或引用在运行时指向派生类的对象&#xff0c;并且根据对象的实际类型来调…
阅读更多...
日报表定时任务优化历程

日报表定时任务优化历程

报表需求背景 报表是一个很常见的需求&#xff0c;在项目中后期往往会需要加多种维度的一些统计信息&#xff0c;今天就来谈谈上线近10个月后的一次报表优化优化之路&#xff08;从一天报表跑需要五分钟&#xff0c;优化至秒级&#xff09; 需求&#xff1a;对代理商进行日统计…
阅读更多...
BUUCTF[PWN]

BUUCTF[PWN]

BUUCTF[PWN] 题目&#xff1a;warmup_csaw_2016 地址&#xff1a;warmup_csaw_2016ida打开&#xff0c;进main函数&#xff1a;gets函数的栈溢出&#xff1a;给出了sub_40060D函数的地址直接&#xff0c;溢出到sub_40060D的地址即可&#xff1a; from pwn import *p remote…
阅读更多...
vue 孙组件调用父组件的方法

vue 孙组件调用父组件的方法

通过组件内的 传递方法名称&#xff0c;可以实现孙组件调用父组件。 代码如下&#xff1a; index.html <!DOCTYPE html> <html> <head><meta charset"utf-8"><script src"/framework/vue-2.7.16.min.js"></script>…
阅读更多...
最新文章

Copyright @ 2022~2023