RabbitMQ入门

发表于2025-07-03|更新于2025-07-21|编程

|浏览量:

简介

MQ（消息队列）是经典生产者消费者模型，实现生产者和消费者解耦。RabbitMq是目前常用的高性能异步通讯组件。

优势

解耦，增强可拓展性
异步调用，提高性能
故障隔离，业务报错相互独立，不会影响其他业务
平缓流量，削峰填谷

安装

docker run -e RABBITMQ_DEFAULT_USER=root \
        -e RABBITMQ_DEFAULT_PASS=123123 \
        -v mq-plugins:/plugins \
        --name rabbitmq \
        --hostname rabbitmq \
        -p 15672:15672 \
        -p 5672:5672 \
        -d \
        rabbitmq:3.8-management

核心概念

概念	解释
publisher	消息发送者
consumer	消息的消费者
queue	队列，存储消息
exchange	交换机，负责路由消息
virtual-host	虚拟主机，起到数据隔离作用

文章作者: way

文章链接: http://wayblog.top/2025/07/03/RabbitMQ/

版权声明: 本博客所有文章除特别声明外，均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来源 way的个人博客！

java Web 中间件 RabbitMQ 消息队列

相关推荐

SpringBoot笔记

记录了一些在学习SpringBoot和MyBatis时的知识点 SpringBoot 简介 Spring Boot是由Pivotal团队提供的全新框架，其设计目的是用来简化新Spring应用的初始搭建以及开发过程。该框架使用了特定的方式来进行配置，从而使开发人员不再需要定义样板化的配置。通过这种方式，Spring Boot致力于在蓬勃发展的快速应用开发成为领导者。依赖 12345678910111213141516171819202122232425262728<?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" ...

简介 Redis是一个基于内存的key-value结构的数据库，它存储的value类型比较丰富，也被成为结构化的非关系型数据库。特点：基于内存存储，读写性能高。适合存储热点数据（经常查询）适用场景：当作缓存任务队列消息队列分布式锁使用docker安装Redis 1docker run -itd --name redis-test -p 6379:6379 redis Redis常用命令字符串操作命令作用 set key value 设置指定key的值 setex key seconds value seconds为该key过期时间 get key 获取key的值 setex key value 当key不存在时设置value 1234567891011@Test public void testString(){ ValueOperations valueOperations = redisTemplate.opsForValue(); // 设置10s后过期，单位为s ...

简介 Nginx是一个开源的轻量级HTTP服务器，主要功能包括反向代理，负载均衡，HTTP服务器和争相代理。其具有占用内存少，并发能力强，可扩展性好等特点运行架构 Nginx 采用多进程模型，由一个主进程和多个工作进程组成。这种设计不仅提高了系统的稳定性，还充分利用了多核 CPU 的性能。 master进程启动时检查配置是否正确根据配置文件创建并监控wroker进程监听端口，接收http请求，并转发给worker进程响应请求监听运维命令，并将命令转发给worker worker进程处理master进程接收的http请求 worker进程数量根据又nginx.conf决定 worker进程之间会进行竞争，获胜者处理请求接收master进程发送来的命令编译安装依赖 1yum install pcre pcre-devel openssl openssl-devel zlib zlib-devel gzip 编译 12./configure --prefix=/opt/nginxmake && sudo make...

Java多线程笔记

记录了一些Java多线程demo 多线程 Thread 通过继承Thread类重写run函数来建立多线程，优点是操作简单，缺点是无法继承其他类 1234567891011121314151617181920public class ThreadDemo1 { public static void main(String[] args) { Thread t = new MyThread(); t.start(); for (int i = 0; i < 5; i++) { System.out.println("主线程： " + i); } }}class MyThread extends Thread{ @Override public void run() { for (int i = 0; i < 5; i++) { ...

SpringBoot项目实战

记录了一些SpringBoot项目实战过程中知识点和常用思路项目实战全局异常捕获创建全局异常类通过@RestControllerAdvice注解将该类作用于全部controller类在该类创建方法编写异常处理逻辑，行参为需要捕获的异常类通过@ExceptionHandler注解捕获异常 12345678910111213141516171819202122232425262728293031323334/** * 全局异常处理器，处理项目中抛出的业务异常 */@RestControllerAdvice@Slf4jpublic class GlobalExceptionHandler { /** * 捕获业务异常 * @param ex * @return */ @ExceptionHandler public Result exceptionHandler(BaseException ex){ log.error("异常信息：{}",...