RabbitMQ安装和快速入门

news2025/1/12 10:03:34

文章目录

  • 1. RabbitMQ
  • 2. 安装RabbitMQ
    • 2.1 创建shell文件
    • 2.2 编写shell文件
    • 2.3 检查rabbitmq状态
    • 2.4 设置开机自启动
    • 2.5 启动插件
    • 2.6 开放端口号
    • 2.7 创建用户
    • 2.8 登入管理页面
  • 3. SpringBoot中集成RabbitMQ
    • 3.1 依赖安装
    • 3.2 SpringBoot配置
    • 3.3 RabbitMQ的配置类
    • 3.4 定义消费者和生产者
    • 3.5 确认的三种方式
  • 4. RabbitMQ详解
    • 4.1 RabbitMQ的监听器机制
      • 4.1.1 Simple模式
      • 4.1.2 Direct模式
    • 4.2 Channel和Connection
    • 4.3 Exchange和Queue
      • 4.3.1 Exchange的作用
      • 4.3.2 Routing Key
      • 4.3.3 Queue的作用

1. RabbitMQ

RabbitMQ是一个消息队列，用于异步处理事务。所谓的消息队列本质上就是生产者-消费者模式，生产者产生消息，将消息压入消息队列中，消费者阻塞式读取消息队列，读取到数据后进行处理。消费者和生产者是两个独立的线程，通过将生产者和消费者分离，实现异步操作，提高高并发的性能。RabbitMQ作为一个专门用于实现消息队列的中间件相比于Redis有更丰富的功能。

2. 安装RabbitMQ

官网下载:https://www.rabbitmq.com/download.html
在Ubuntu22.04上安装RabbitMQ，官方提供了shell文件，直接运行shell文件就可以一步到位安装完毕。
注意:最新版的RabbitMQ是没有config文件的，如果想要进行RabbitMQ的配置需要登入Web管理页面。

2.1 创建shell文件

touch rabbitmq.sh

2.2 编写shell文件

以下是官方提供的Ubuntu22.0.4的安装脚本，如果是其他版本请参考官方教程将jammy改为对应的版本号。jammy是Ubuntu 22.0.4的代号，不同版本的系统有不同的代号，问chatgpt就知道了。

#!/bin/sh

sudo apt-get install curl gnupg apt-transport-https -y

## Team RabbitMQ's main signing key
curl -1sLf "https://keys.openpgp.org/vks/v1/by-fingerprint/0A9AF2115F4687BD29803A206B73A36E6026DFCA" | sudo gpg --dearmor | sudo tee /usr/share/keyrings/com.rabbitmq.team.gpg > /dev/null
## Community mirror of Cloudsmith: modern Erlang repository
curl -1sLf https://github.com/rabbitmq/signing-keys/releases/download/3.0/cloudsmith.rabbitmq-erlang.E495BB49CC4BBE5B.key | sudo gpg --dearmor | sudo tee /usr/share/keyrings/rabbitmq.E495BB49CC4BBE5B.gpg > /dev/null
## Community mirror of Cloudsmith: RabbitMQ repository
curl -1sLf https://github.com/rabbitmq/signing-keys/releases/download/3.0/cloudsmith.rabbitmq-server.9F4587F226208342.key | sudo gpg --dearmor | sudo tee /usr/share/keyrings/rabbitmq.9F4587F226208342.gpg > /dev/null

## Add apt repositories maintained by Team RabbitMQ
sudo tee /etc/apt/sources.list.d/rabbitmq.list <<EOF
## Provides modern Erlang/OTP releases
##
deb [signed-by=/usr/share/keyrings/rabbitmq.E495BB49CC4BBE5B.gpg] https://ppa1.novemberain.com/rabbitmq/rabbitmq-erlang/deb/ubuntu jammy main
deb-src [signed-by=/usr/share/keyrings/rabbitmq.E495BB49CC4BBE5B.gpg] https://ppa1.novemberain.com/rabbitmq/rabbitmq-erlang/deb/ubuntu jammy main

# another mirror for redundancy
deb [signed-by=/usr/share/keyrings/rabbitmq.E495BB49CC4BBE5B.gpg] https://ppa2.novemberain.com/rabbitmq/rabbitmq-erlang/deb/ubuntu jammy main
deb-src [signed-by=/usr/share/keyrings/rabbitmq.E495BB49CC4BBE5B.gpg] https://ppa2.novemberain.com/rabbitmq/rabbitmq-erlang/deb/ubuntu jammy main

## Provides RabbitMQ
##
deb [signed-by=/usr/share/keyrings/rabbitmq.9F4587F226208342.gpg] https://ppa1.novemberain.com/rabbitmq/rabbitmq-server/deb/ubuntu jammy main
deb-src [signed-by=/usr/share/keyrings/rabbitmq.9F4587F226208342.gpg] https://ppa1.novemberain.com/rabbitmq/rabbitmq-server/deb/ubuntu jammy main

# another mirror for redundancy
deb [signed-by=/usr/share/keyrings/rabbitmq.9F4587F226208342.gpg] https://ppa2.novemberain.com/rabbitmq/rabbitmq-server/deb/ubuntu jammy main
deb-src [signed-by=/usr/share/keyrings/rabbitmq.9F4587F226208342.gpg] https://ppa2.novemberain.com/rabbitmq/rabbitmq-server/deb/ubuntu jammy main
EOF

## Update package indices
sudo apt-get update -y

## Install Erlang packages
sudo apt-get install -y erlang-base \
                        erlang-asn1 erlang-crypto erlang-eldap erlang-ftp erlang-inets \
                        erlang-mnesia erlang-os-mon erlang-parsetools erlang-public-key \
                        erlang-runtime-tools erlang-snmp erlang-ssl \
                        erlang-syntax-tools erlang-tftp erlang-tools erlang-xmerl

## Install rabbitmq-server and its dependencies
sudo apt-get install rabbitmq-server -y --fix-missing

2.3 检查rabbitmq状态

systemctl status rabbitmq-server

2.4 设置开机自启动

systemctl enable rabbitmq-server

2.5 启动插件

sudo rabbitmq-plugins enable rabbitmq_management
systemctl restart rabbitmq-server

2.6 开放端口号

udo firewall-cmd --add-port=5672/tcp --permanent
udo firewall-cmd --add-port=15672/tcp --permanent
firewall-cmd --list-ports

2.7 创建用户

默认用户只能本地访问，如果想要远程访问必须新增用户

sudo rabbitmqctl add_user your_username your_password
sudo rabbitmqctl set_user_tags your_username administrator
sudo rabbitmqctl set_permissions -p / your_username ".*" ".*" ".*"

2.8 登入管理页面

管理页面的网址为:IP地址:15672
在这里插入图片描述
管理页面中的功能非常的多，建议用到时再按需学习

3. SpringBoot中集成RabbitMQ

3.1 依赖安装

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
    <version>3.1.5</version>
</dependency>

3.2 SpringBoot配置

spring:
  rabbitmq:
    host: 主机地址
    username: rabbitmq用户名
    password: 密码
    port: 5672
    virtual-host: 虚拟机默认为/
    listener:
      simple:
        acknowledge-mode: manual
        concurrency: 1
        max-concurrency: 2
        prefetch: 3
      type: simple

3.3 RabbitMQ的配置类

package com.hmdp.config;

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfig {
    /**
     * 创建队列
     * **/
    @Bean
    public Queue hello(){
        return new Queue("hello",true,false,false);
    }
}

3.4 定义消费者和生产者

package com.hmdp.demo;

import com.hmdp.dto.Result;
import com.hmdp.entity.User;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.AcknowledgeMode;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.io.IOException;

@RestController
@RequestMapping("/demo/rabbit")
public class RabbitDemoController {
    /**
     * 生产者
     */
    @Autowired
    RabbitTemplate rabbitTemplate;
    @PostMapping("/send")
    public void send(){
        String msg="Hello World";
        // 第一个参数:交换机名字 第二个参数:routeKey 第三个参数:消息
        rabbitTemplate.convertAndSend("hello",msg);
        System.out.println("生产者发送成功");
    }

    /**
     * 消费者
     */
    @RabbitListener(queues = {"hello"})
    public void receive(String msg, Message message, Channel channel) throws IOException, InterruptedException {
        System.out.println("消费者收到消息:"+msg);
        System.out.println(message);
        channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
        Thread.sleep(1000);
        System.out.println("******消费者"+message.getMessageProperties().getDeliveryTag()+"读取完毕，用时3s******");
    }
}

3.5 确认的三种方式

        /**
         * 【1 确认】
         * deliveryTag：消息的标识符
         * multiple：
         *     false：仅确认当前消息
         *     true：确认所有消息
         */
        channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
         /**
         *  【2 拒绝】
         *  第一个参数是消息的唯一ID
         *  第二个参数表示是否批量处理
         *  第三个参数表示是否将消息重发回队列
         */
        //channel.basicNack(message.getMessageProperties().getDeliveryTag(),false,true);
        /**
         * 【3 拒绝】
         * 第一个参数deliveryTag表示消息ID
         * 第二个参数为true表示是否重新入列，如果是true则重新丢回队列里等待再次消费，否则数据只是被消费，不会丢回队列里
         */
		//channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);

4. RabbitMQ详解

在这里插入图片描述

4.1 RabbitMQ的监听器机制

RabbitMQ通过@RabbitMQListener注解设置消费者者监听器，监听器有两种，默认情况下使用simple类型的监听器进行单线程的消费监听，即一个消费者对应一个消息队列，一个消费者就是一个线程。在高并发的情况下如果只有一个消费者，可能会造成消息堆积的现象，因此我们可以通过设置多个消费者读取同一个消息队列，从而提高系统的并发性。
在springboot中，可以通过设置

    listener:
      simple:
        acknowledge-mode: manual
        concurrency: 1
        max-concurrency: 2
        prefetch: 3

来指定最大和最小的并发消费者数量。其中``用于指定每个消费者最多缓存多少个unack的消息，通过该参数能够避免本地消费者无限制的缓存消息，从而导致内存爆炸。通过对消费者进行限流，达到削峰填谷的作用。

4.1.1 Simple模式

一个消费者对应一条线程
在这里插入图片描述

4.1.2 Direct模式

多个消费者公用一个线程池
在这里插入图片描述

4.2 Channel和Connection

在这里插入图片描述

一个TCP 被多个消费者线程共享，每个线程对应一个信道，信道在rabbit都有唯一的ID，保证了信道的私有性，对应上唯一的线程使用。也就是rabbitMq采用一个TCP连接处理多个消费者的多线程请求，实际上就是多路复用。通过设置channel可以防止频繁的建立TCP连接。

4.3 Exchange和Queue

4.3.1 Exchange的作用

交换机(Exchange)是RabbitMQ中最重要的部分，交换机与多个队列绑定，通过设置相应的Routing Key(路由键)，将生产者产生的消息分发到不同的Queue中。

4.3.2 Routing Key

交换机转发消息的转发规则。

4.3.3 Queue的作用

缓存队列，用于存储生产者产生的消息，一个Queue可以绑定多个消费者。

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

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

相关文章

【论文阅读】Deep Graph Infomax

【论文阅读】Deep Graph Infomax

目录 0、基本信息1、研究动机2、创新点2.1、核心思想&#xff1a;2.2、思想推导&#xff1a; 3、准备3.1、符号3.2、互信息3.3、JS散度3.4、Deep InfoMax方法3.5、判别器&#xff1a;f-GAN估计散度 4、具体实现4.1、局部-全局互信息最大化4.2、理论动机 5、实验设置5.1、直推式…
阅读更多...
ubuntu 挂载新硬盘

ubuntu 挂载新硬盘

1、检测新硬盘 新增加硬盘&#xff0c;检测硬盘识别情况。 命令检查&#xff1a;sudo fdisk -l 3、格式化磁盘 格式化&#xff1a;sudo mkfs.ext4 /dev/sdb 其中&#xff0c;/dev/sdb是新分区的设备文件名&#xff0c;ext4是要使用的文件系统类型。 4、挂载新分区 sudo mk…
阅读更多...
uni-app中实现音乐播放器

uni-app中实现音乐播放器

uni-app中实现音乐播放器 1、主要利用的是uni-app中提供的uni.createInnerAudioContext()来进行实现&#xff1b; 2、代码示例 &#xff08;1&#xff09;主页面代码展示 <template><view class"music-layout"><view class"tn-flex">…
阅读更多...
nvm管理多版本Node.js

nvm管理多版本Node.js

nvm管理多版本Node.js 可能大家都曾苦恼于Node环境问题&#xff0c;某个项目需要升版本&#xff0c;某项目又需要降&#xff0c;甚至还出现npm版本与Node对不上的情况。 通过nvm进行版本管理&#xff0c;即可解决。 卸载Node 通过命令行输入node -v命令查看是否已安装Node&…
阅读更多...
Realm Management Extension领域管理扩展之颗粒保护检查

Realm Management Extension领域管理扩展之颗粒保护检查

本节描述了RME引入的颗粒保护检查。颗粒保护检查使得能够在不同的物理地址空间之间动态分配内存区域。 本节将向您介绍以下功能： 颗粒保护表的结构用于颗粒保护检查的故障报告区域在物理地址空间之间的过渡正如在物理地址一节中所述，RME提供了四个物理地址空间。以下图表显示…
阅读更多...
金额用Long还是BigDecimal？

金额用Long还是BigDecimal？

问题 今天在网上看到一个有意思的问题&#xff0c;金额的数据类型用Long还是BigDecimal&#xff1f; 具体问题大概是这样的&#xff1a;关于金额的数据类型&#xff0c;组长认为使用BigDecimal比较稳妥&#xff0c;总监认为使用Long才不会出问题&#xff0c;然后开发认为Long…
阅读更多...
85.乐理基础-记号篇-速度记号

85.乐理基础-记号篇-速度记号

内容来源于&#xff1a;三分钟音乐社 上一个内容&#xff1a;85.乐理基础-记号篇-力度记号-CSDN博客 速度记号在下方两个里面已经写过一部分了&#xff0c;这些标记总体上是属于 不变速度 的标记&#xff0c;比如一首乐谱就记了 每分钟60拍&#xff0c;那整首速度就都是不变的…
阅读更多...
软件测试|如何在Linux中下载和安装软件包

软件测试|如何在Linux中下载和安装软件包

简介 在Linux操作系统中&#xff0c;下载和安装软件包是一项基本任务。不同的Linux发行版可能有不同的包管理工具和方式&#xff0c;但总体流程是类似的。以下是在Linux中下载和安装软件包的详细步骤。 步骤1&#xff1a;选择适当的包管理工具 因为Linux有不同的发行版本&am…
阅读更多...
【Kafka-3.x-教程】-【四】Kafka-消费者-Consumer

【Kafka-3.x-教程】-【四】Kafka-消费者-Consumer

【Kafka-3.x-教程】专栏&#xff1a; 【Kafka-3.x-教程】-【一】Kafka 概述、Kafka 快速入门 【Kafka-3.x-教程】-【二】Kafka-生产者-Producer 【Kafka-3.x-教程】-【三】Kafka-Broker、Kafka-Kraft 【Kafka-3.x-教程】-【四】Kafka-消费者-Consumer 【Kafka-3.x-教程】-【五…
阅读更多...
JDBC初体验（二）——增、删、改、查

JDBC初体验（二）——增、删、改、查

本课目标 理解SQL注入的概念 掌握 PreparedStatement 接口的使用 熟练使用JDBC完成数据库的增、删、改、查操作 SQL注入 注入原理&#xff1a;利用现有应用程序&#xff0c;将&#xff08;恶意的&#xff09;SQL命令注入到后台数据库引擎执行能力&#xff0c;它可以通过在…
阅读更多...
芯片命名大全：完整的器件型号包括主体型号、前缀、后缀等！

芯片命名大全：完整的器件型号包括主体型号、前缀、后缀等！

不少公司的采购会发现&#xff0c;拿到工程师提供的BOM中的器件去采购物料时&#xff0c;经常供应商还会问得更仔细&#xff0c;否则就不知道供给你哪种物料&#xff0c;严重时&#xff0c;采购回来的物料用不了。为什么会有这种情况呢&#xff1f;问题就在于&#xff0c;很多经…
阅读更多...
PFA撞击滤尘器-PFA冲击瓶-PFA缓冲瓶

PFA撞击滤尘器-PFA冲击瓶-PFA缓冲瓶

还在用玻璃材质冲击瓶吗&#xff1f;一碰就会碎的辛酸谁能理解啊&#xff1f;还会被各种酸气腐蚀&#xff0c;怎办&#xff1f; 进口氟树脂材质PFA冲击瓶&#xff0c;值得拥有。 与玻璃撞击器不同&#xff0c;PFA冲击瓶坚固&#xff0c;不易损坏&#xff0c;并且由于PFA材质本…
阅读更多...
自动驾驶状态观测1-坡度估计

自动驾驶状态观测1-坡度估计

背景 自动驾驶坡度对纵向的跟踪精度和体感都有一定程度的影响。行车场景虽然一般搭载了GPS和IMU设备&#xff0c;但pitch角一般不准&#xff0c;加速度也存在波动大的特点。泊车场景一般在室内地库&#xff0c;受GPS信号遮挡影响&#xff0c;一般无法获取高程和坡度。搭载昂贵…
阅读更多...
vue前端开发自学demo-input标签数据双向绑定

vue前端开发自学demo-input标签数据双向绑定

vue前端开发自学demo-input标签数据双向绑定&#xff01;今天为大家 展示的内容是&#xff0c;前端开发常见的&#xff0c;form表单里面的&#xff0c;一些输入数据的元素&#xff0c;动态绑定数据的案例。比如input,以及checkbox的状态绑定案例。 首先&#xff0c;老规矩&…
阅读更多...
别不信，搭建企业知识库后真的效率翻倍了

别不信，搭建企业知识库后真的效率翻倍了

在当今信息时代&#xff0c;知识是最宝贵的财富。一个企业要想越办越大&#xff0c;就需要保证信息的透明度和流通率。而搭建一套企业知识库&#xff0c;就能实现这个目标。今天我们就来聊聊为什么建立企业知识库后&#xff0c;你的工作效率会大大提高。同时&#xff0c;我们会…
阅读更多...
C/C++ 有关质数(素数)的问题

C/C++ 有关质数(素数)的问题

第一题:判断是否为质数 代码&#xff1a; #include <bits/stdc.h> using namespace std; int main() {int a;int flag 1;cin>>a;for(int j2;j<a;j){if(a % j 0){cout<<a<<"不是质数";flag0;break;}}if(flag1) cout<<a<<&quo…
阅读更多...
[足式机器人]Part3 机构运动学与动力学分析与建模 Ch00-3(2) 刚体的位形 Configuration of Rigid Body

[足式机器人]Part3 机构运动学与动力学分析与建模 Ch00-3(2) 刚体的位形 Configuration of Rigid Body

本文仅供学习使用&#xff0c;总结很多本现有讲述运动学或动力学书籍后的总结&#xff0c;从矢量的角度进行分析&#xff0c;方法比较传统&#xff0c;但更易理解&#xff0c;并且现有的看似抽象方法&#xff0c;两者本质上并无不同。 2024年底本人学位论文发表后方可摘抄 若有…
阅读更多...
Open100: 开源系统杰出成果

Open100: 开源系统杰出成果

了解更多&#xff1a;芝士AI吃鱼 背景 开源的根源可以追溯到计算机的早期&#xff0c;并在20世纪末发展迅猛。贝尔实验室在20世纪70年代开发的AT&T Unix是开源的关键里程碑&#xff0c;其共享源代码的概念为开源运动奠定了基础。开源已重溯软硬件产业生态&#xff0c;并正…
阅读更多...
C++ 之LeetCode刷题记录（八）

C++ 之LeetCode刷题记录（八）

&#x1f604;&#x1f60a;&#x1f606;&#x1f603;&#x1f604;&#x1f60a;&#x1f606;&#x1f603; 开始cpp刷题之旅&#xff0c;多学多练&#xff0c;尽力而为。 先易后难&#xff0c;先刷简单的。 35. 搜索插入位置 给定一个排序数组和一个目标值&#xff0c;…
阅读更多...
数字图像处理练习题

数字图像处理练习题

数字图像处理练习题 文章目录 数字图像处理练习题第 一 章1.什么是数字图像?2.数字图像有哪些特点?3.数字图像处理的目的是什么?4.简述数字图像的历史。5.数字图像有哪些主要应用?6.列举生活中数字图像的获得途径。7.结合自己的生活实例,举出一个数字图像的应用实例8.数字图…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023