RabbitMQ 安装体验

news2024/9/22 1:33:51

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

}

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

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Servlet/Web开发概述/Http响应

Servlet/Web开发概述/Http响应

一、web开发概述 学习web开发&#xff0c;需要先安装一台web服务器&#xff0c;将开发好的web项目部署在web服务器中供外界访问. Web服务器是指驻留于因特网上某种类型计算机的程序&#xff0c;可以放置资源文件&#xff0c;别人可以访问、服务器可以做出响应&#xff1a; 可…
阅读更多...
基于PCA与LDA的数据降维实践

基于PCA与LDA的数据降维实践

基于PCA与LDA的数据降维实践 描述 数据降维&#xff08;Dimension Reduction&#xff09;是降低数据冗余、消除噪音数据的干扰、提取有效特征、提升模型的效率和准确性的有效途径&#xff0c; PCA&#xff08;主成分分析&#xff09;和LDA&#xff08;线性判别分析&#xff0…
阅读更多...
centos7怎么查看防火墙以及添加白名单

centos7怎么查看防火墙以及添加白名单

方法一&#xff1a;systemctl status firewalld 防火墙的开启、关闭、禁用命令 &#xff08;1&#xff09;设置开机启用防火墙&#xff1a;systemctl enable firewalld.service &#xff08;2&#xff09;设置开机禁用防火墙&#xff1a;systemctl disable firewalld.servic…
阅读更多...
积化和差公式推导

积化和差公式推导

积化和差公式是初等数学三角函数部分的一组恒等式&#xff0c;积化和差公式将两个三角函数值的积化为另两个三角函数值的和的常数倍&#xff0c;达到降次的作用。 基本上记不住这好几个哥们,不过幸运的是,利用诱导公式可以一式生万式子,记住一个就好了 式子1:sin⁡α∗cos⁡β1…
阅读更多...
【3D建模工具】上海道宁与McNeel为您提供强大的专业3D造型软件

【3D建模工具】上海道宁与McNeel为您提供强大的专业3D造型软件

Rhino可以对 NURBS曲线、曲面、实体、 细分几何图形 (SubD)、点云和多边形网格 进行创建、编辑、分析、记录、 渲染、动画制作与转换 只要硬件条件允许 不受复杂度、阶数与尺寸大小的限制 Rhino 7使用SubD工具 可以建立有机形状 使用Rhino.Inside.Revit 做为Revit附加…
阅读更多...
2023MathorCup数模A题思路数据代码论文【全网最全分享】

2023MathorCup数模A题思路数据代码论文【全网最全分享】

文章目录赛题思路赛题详情参赛建议&#xff08;个人见解&#xff09;选择队友及任务分配问题&#xff08;重要程度&#xff1a;5星&#xff09;2023MathorCup数模A题思路数据论文代码【最新】赛题思路 (赛题出来以后第一时间在CSDN分享) 最新进度在文章最下方卡片&#xff0c;…
阅读更多...
kruskal重构树

kruskal重构树

一&#xff0c;定义 kruskal是求最小生成树的一种算法。最小生成树 但是这种结合并查集的特殊方法给了他许多特殊的性质。可以用于解决树上瓶颈边权之类的问题 结合这种算法而诞生的就是——kruskal重构树 二&#xff0c;建树思路及其性质 kruskal求最小生成树是将边权小的…
阅读更多...
【超详细】小白初探FME--获取等时圈

【超详细】小白初探FME--获取等时圈

在规划分析过程中&#xff0c;往往会涉及等时圈的概念。什么是等时圈呢&#xff1f;小编帮你百度过了&#xff0c;网上的说法是&#xff1a;等时圈是指从某点出发&#xff0c;以某种交通方式在特定时间内能到达的距离覆盖的范围。比如我们在规划设计中接触到的15分钟生活圈就是…
阅读更多...
HTML5支持的视频文件格式和音频文件格式有哪些？

HTML5支持的视频文件格式和音频文件格式有哪些？

在 HTML5 标准中, 我们有了新的 <audio> 和 <video> 标签, 分别可以引入视频和音频文件的标签 那么这些标签又可以支持哪些文件格式呢 ? 格式支持 视频文件格式 MP4&#xff1a;MPEG-4 Part 14&#xff0c;支持H.264编码。几乎所有的浏览器都支持该格式。 Web…
阅读更多...
springboot+netty+mqtt实现

springboot+netty+mqtt实现

具体实现前言MQTT协议概念组成部分实现mqtt协议测试其他前言 首先说明一下&#xff0c;netty实现并封装了mqtt协议&#xff0c;同时也为其写好了编解码器&#xff0c;但是再了解并搭建之前&#xff0c;尤其是还不了解netty和mqtt的同学&#xff0c;必须要清楚一件事&#xff1…
阅读更多...
2023MathorCup数学建模比赛的思路汇总帖

2023MathorCup数学建模比赛的思路汇总帖

更新时间【4.13 19&#xff1a;45】ABCD均已更新&#xff0c;选题指导已更新&#xff0c;速看&#xff01;后续会出各题详细思路及代码&#xff01; 这里是小云的2023MathorCup数学建模比赛的思路汇总帖&#xff0c;比赛开始后将实时更新~ 竞赛共4道题目&#xff08;A题、B题…
阅读更多...
ELF 文件格式 ------- 符号表

ELF 文件格式 ------- 符号表

1. 符号的数据结构 typedef struct elf64_sym {Elf64_Word st_name; /* 该符号的名字在字符串表中的起始下标 */unsigned char st_info; /* 该符号的类型以及作用域信息 */unsigned char st_other; /* 暂未使用 */Elf64_Half st_shndx; /* 该符号所在的 section 的下标&…
阅读更多...
IDEA安装spotbugs插件替代findbugs插件

IDEA安装spotbugs插件替代findbugs插件

相信最近想在IDEA上安装findbugs插件的朋友&#xff0c;遇到与我一样的问题&#xff0c;findbugs与IDEA不兼容&#xff1a; https://plugins.jetbrains.com/plugin/3847-findbugs-idea 主要是FindBugs插件已经不更新了&#xff0c;它最新版本停留在2016年发布的1.0.1&#xff0…
阅读更多...
百度文心一言可以完胜ChatGPT的4点可能性

百度文心一言可以完胜ChatGPT的4点可能性

文心一言&#xff0c;百度全新一代知识增强大语言模型&#xff0c;文心大模型家族的新成员&#xff0c;能够与人对话互动&#xff0c;回答问题&#xff0c;协助创作&#xff0c;高效便捷地帮助人们获取信息、知识和灵感。但说实话&#xff0c;很多人拿他与ChatGPT相对比&#x…
阅读更多...
RabbitMQ（ 发布订阅模式 ==＞ DirectExchange）

RabbitMQ（ 发布订阅模式 ==＞ DirectExchange）

本章目录&#xff1a; 何为DirectExchangeDirectExchange具体使用一、何为DirectExchange 在上一篇文章中&#xff0c;讲述了FanoutExchange&#xff0c;其中publish向交换机发送消息时&#xff0c;我们并没有指定routkingKey&#xff0c;如下图所示 我们看看官方文档 之前使…
阅读更多...
【教学类-32-01】十二生肖1.0版（绘画+手工+排序+分类+玩牌）（中班：偏科学-数）

【教学类-32-01】十二生肖1.0版（绘画+手工+排序+分类+玩牌）（中班：偏科学-数）

作品展示 背景需求——从数字到图片 最佳孩子们做Python纸类&#xff08;数学&#xff09;的频率比较高。但都是数字类&#xff08;加减法、门牌号、火车箱、电话号码等&#xff09;我想翻新花样&#xff0c;设计新的内容&#xff0c;就想到了水果图片、动物图片。 百度图片找…
阅读更多...
大数据技术之DataX

大数据技术之DataX

目录 第一章 业务数据同步策略 1.1 全量同步策略 1.2 增量同步策略 1.3 数据同步策略的选择 第2章 DataX介绍 2.1 DataX概述 第3章 DataX架构原理 3.1 DataX的设计理念 3.2 DataX框架设计 3.3 DataX支持的数据源 3.4 DataX运行流程 3.5 DataX调度策略思路 3.6 Data…
阅读更多...
数据结构和算法学习记录——二叉树的存储结构二叉树的递归遍历（顺序存储结构、链表存储结构、先序中序后序递归遍历）

数据结构和算法学习记录——二叉树的存储结构二叉树的递归遍历（顺序存储结构、链表存储结构、先序中序后序递归遍历）

目录 顺序存储结构 链表存储结构 二叉树的递归遍历 先序递归遍历 中序递归遍历 后序递归遍历 先序遍历路线图 中序遍历路线图 后序遍历路线图 设想一下二叉树要用什么样的方式来存储&#xff0c;一种是用数组&#xff0c;一种是用链表。 顺序存储结构 用数组&…
阅读更多...
IDEA新手入门常用快捷键，方便软件构造

IDEA新手入门常用快捷键，方便软件构造

1. Ctrlo快速找方法 2. Alt EnTER 对这个代码快速智能补全trycatch 对这个快速加入要写的接口方法show 3. 使用Ctrl /&#xff0c; 添加行注释 4. 输入psvm 按Tab&#xff0c;自动生成void main 输入souf 按Tab就是System.out.printf() 5. CtrlF12 查看参考代码内部方法…
阅读更多...
「她时代」背后的欧拉力量

「她时代」背后的欧拉力量

2018年大热电视剧《北京女子图鉴》&#xff0c;讲述了一群在北京打拼的职业女性&#xff0c;她们背井离乡&#xff0c;被现实包裹&#xff0c;被压力、责任困扰&#xff0c;但依旧用倔强的个性、不屈的进取心和深厚的知识技能努力营造、交织出一片励志的天空&#xff0c;既激昂…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023