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#启动时是否默认启动容器,默认为 trueauto-startup: true#被拒绝时重新进入队列的default-requeue-rejected: true# 消息重试配置template:retry:#启用消息重试机制,默认为 falseenabled: true#初始重试间隔时间initial-interval: 1000ms#重试最大次数,默认为 3 次max-attempts: 3#重试最大时间间隔,默认 10000msmax-interval: 10000ms#重试的间隔乘数#配置 2 的话,第一次等 1s,第二次等 2s,第三次等 4smultiplier: 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 重启之后会读取该数据库*/@Beanpublic 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 {@Resourceprivate 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 {@Resourceprivate MQSender mqSender;// 调用发送消息的方法@RequestMapping("/mq")@ResponseBodypublic void mq() {mqSender.send("hello rabbitmq");}
}
4.启动测试
1.访问 http://localhost:9092/seckill/mq 成功发送和接受消息

image-20240511142633815

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

image-20240511143128879

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

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

使用xtuner微调InternLM-Chat-7B

1. 安装xtuner #激活环境 source activate test_llm # 安装xtuner pip install xtuner#还有一些依赖项需要安装 future>0.6.0 cython lxml>3.1.0 cssselect mmengine 2. 创建一个ft-oasst1 数据集的工作路径&#xff0c;进入 mkdir ft-oasst1 cd ft-oasst1 3.XTune…

MySQL系列之索引

&#x1f339;作者主页&#xff1a;青花锁 &#x1f339;简介&#xff1a;Java领域优质创作者&#x1f3c6;、Java微服务架构公号作者&#x1f604; &#x1f339;简历模板、学习资料、面试题库、技术互助 &#x1f339;文末获取联系方式 &#x1f4dd; 往期热门专栏回顾 专栏…

【Linux】环境变量是什么?如何配置?详解

&#x1f490; &#x1f338; &#x1f337; &#x1f340; &#x1f339; &#x1f33b; &#x1f33a; &#x1f341; &#x1f343; &#x1f342; &#x1f33f; &#x1f344;&#x1f35d; &#x1f35b; &#x1f364; &#x1f4c3;个人主页 &#xff1a;阿然成长日记 …

C++11:并发新纪元 —— 深入理解异步编程的力量(1)

hello &#xff01;大家好呀&#xff01; 欢迎大家来到我的Linux高性能服务器编程系列之《C11&#xff1a;并发新纪元 —— 深入理解异步编程的力量》&#xff0c;在这篇文章中&#xff0c;你将会学习到C新特性以及异步编程的好处&#xff0c;以及其如何带来的高性能的魅力&…

【算法】动态规划之背包DP问题(2024.5.11)

前言&#xff1a; 本系列是学习了董晓老师所讲的知识点做的笔记 董晓算法的个人空间-董晓算法个人主页-哔哩哔哩视频 (bilibili.com) 动态规划系列 【算法】动态规划之线性DP问题-CSDN博客 01背包 步骤&#xff1a; 分析容量j与w[i]的关系&#xff0c;然后分析是否要放…

OGG几何内核开发-BRepAlgoAPI_Fuse与BRep_Builder.MakeCompound比较

最近在与同事讨论BRepAlgoAPI_Fuse与BRep_Builder.MakeCompound有什么区别。 一、从直觉上来说&#xff0c;BRepAlgoAPI_Fuse会对两个实体相交处理&#xff0c;相交的部分会重新的生成相关的曲面。而BRep_Builder.MakeCompound仅仅是把两个实体组合成一个新的实体&#xff0c;…

JUC下的BlockingQueue详解

BlockingQueue是Java并发包(java.util.concurrent)中提供的一个接口&#xff0c;它扩展了Queue接口&#xff0c;增加了阻塞功能。这意味着当队列满时尝试入队操作&#xff0c;或者队列空时尝试出队操作&#xff0c;线程会进入等待状态&#xff0c;直到队列状态允许操作继续。这…

https://是怎么实现的?

默认的网站建设好后都是http访问模式&#xff0c;这种模式对于纯内容类型的网站来说&#xff0c;没有什么问题&#xff0c;但如果受到中间网络劫持会让网站轻易的跳转钓鱼网站&#xff0c;为避免这种情况下发生&#xff0c;所以传统的网站改为https协议&#xff0c;这种协议自己…

信息检索(35):LEXMAE: LEXICON-BOTTLENECKED PRETRAINING FOR LARGE-SCALE RETRIEVAL

LEXMAE: LEXICON-BOTTLENECKED PRETRAINING FOR LARGE-SCALE RETRIEVAL 标题摘要1 引言2 相关工作3 LEXMAE&#xff1a;词典瓶颈屏蔽自动编码器3.1 语言建模编码器3.2 词典瓶颈模块3.3 弱化掩蔽式解码器3.4 词汇加权检索器的预训练目标和微调 4 实验4.1 主要评估4.2 效率分析与…

利用OpenShift的ImageStream部署临时版本

公司是港企&#xff0c;项目都部署在OpenShift上统一管理&#xff0c;因为运行环境为香港网络(外网)&#xff0c;配置、中间件等大陆无法直接访问联通。因此在大陆开发时&#xff0c;测试是个很大的问题。为了避免往Git上频繁提交未确定可用的版本&#xff0c;选择用利用OpenSh…

机器人系统仿真

0、何为仿真 通过计算机对实体机器人系统进行模拟的技术。 1、为何仿真 低成本&#xff1a; 机器人实体一般价格昂贵&#xff0c;为降低机器人学习、调试的成本&#xff1b;高效&#xff1a; 搭建的环境更为多样且灵活&#xff0c;可以提高测试效率以及测试覆盖率&#xff1b…

【python】python中的argparse模块,教你如何自定义命令行参数

✨✨ 欢迎大家来到景天科技苑✨✨ &#x1f388;&#x1f388; 养成好习惯&#xff0c;先赞后看哦~&#x1f388;&#x1f388; &#x1f3c6; 作者简介&#xff1a;景天科技苑 &#x1f3c6;《头衔》&#xff1a;大厂架构师&#xff0c;华为云开发者社区专家博主&#xff0c;…

谁使用DITA?

▲ 搜索“大龙谈智能内容”关注公众号▲ Keith根据LinkedIn上的数据进行的统计&#xff0c;主要反应的西方世界使用DITA的公司。因为LinkedIn在国内不能访问&#xff0c;笔者认为针对中国的数据并不准确。 作者 | John Walker - NXP销售和市场营销业务分析师 2013年4月18日 …

栈实现队列

一、分析 栈的特点是先出再入&#xff0c;而队列的特点为先入先出&#xff0c;所以我们创造两个栈&#xff0c;一个用来存放数据&#xff0c;一个用来实现其它功能此时栈顶为队尾&#xff1b;当要找队头数据时将前n-1个数据移入到另一个栈中&#xff0c;此时剩余那个数据为队头…

ASP.NET网上图书预约系统的设计

摘 要 《网上图书预约系统的设计》是以为读者提供便利为前提而开发的一个信息管理系统&#xff0c;它不仅要求建立数据的一致性和完整性&#xff0c;而且还需要应用程序功能的完备、易用等特点。系统主要采用VB.NET作为前端的应用开发工具&#xff0c;利用SQL Server2000数据…

做题杂记666

[XYCTF2024] 铜匠 题目描述&#xff1a; from Crypto.Util.number import * from secrets import flagm bytes_to_long(flag) m1 getRandomRange(1, m) m2 getRandomRange(1, m) m3 m - m1 - m2def task1():e 149p getPrime(512)q getPrime(512)n p * qd inverse(e,…

VTK官方示例

VTK官方示例 -vtk字體 #!/usr/bin/env python# noinspection PyUnresolvedReferences import vtkmodules.vtkInteractionStyle # noinspection PyUnresolvedReferences import vtkmodules.vtkRenderingFreeType # noinspection PyUnresolvedReferences import vtkmodules.vtk…

Java - Json字符串转List<LinkedHashMap<String,String>>

需求&#xff1a;在处理数据时&#xff0c;需要将一个Object类型对象集合转为有序的Map类型集合。 一、问题 1.原代码&#xff1a; 但在使用时出现报错&#xff1a; Incompatible equality constraint: LinkedHashMap<String, String> and LinkedHashMap 不兼容的相等…

【软考】模拟考卷错题本2024-05-11

1 设计模式- 适配器模式 基本上上述的图解已经涵盖了绝大多数主流的设计模式和其特点。理解记忆下即可&#xff0c;这里对下午的考题也有帮助的。 2 计算机组成原理 cpu 访问速度 这个真的是憨憨咯~看到内存就选内存&#xff0c;题目都没审好。这里的速度比cpu内部的要比外部的…

【C语言】动态内存管理

一、为什么有动态内存分配 在进入正文前&#xff0c;我们简单了解一下变量在内存中的位置&#xff08;在最后具体讲&#xff09;&#xff1a; 函数形参&#xff0c;局部变量&#xff1a;栈区 动态开辟的空间&#xff1a;堆区 全局变量&#xff0c;静态变量&#xff08;static修…