消息队列

[Redis系列1：深刻理解高性能Redis的本质](https://www.cnblogs.com/wzh2010/p/15886787.html "Redis系列1：深刻理解高性能Redis的本质") [Redis系列2：数据持久化提高可用性](https://www.cnblogs.com/w ... »

[MQ系列1：消息中间件执行原理](https://www.cnblogs.com/wzh2010/p/15888498.html "MQ系列1：消息中间件执行原理") [MQ系列2：消息中间件的技术选型](https://www.cnblogs.com/wzh2010/p/15311174.htm ... »

[Redis系列1：深刻理解高性能Redis的本质](https://www.cnblogs.com/wzh2010/p/15886787.html "Redis系列1：深刻理解高性能Redis的本质") [Redis系列2：数据持久化提高可用性](https://www.cnblogs.com/w ... »

# 消息队列Rabbitmq ## 1. 什么是消息队列(MQ) Message Queue消息队列是一种应用程序对应用程序的通信方法, 可以是线程(Queue), 也可以是`进程之间`, 而`rabbitmq`是进程之间的消息队列 `生产者消费者模型`: 通过一个容器来解决生产者和消费者之间的强耦 ... »

目录 阻塞队列和非阻塞队列 非阻塞队列 阻塞队列 抛出异常 特殊值 阻塞 超时 总结 阻塞队列和非阻塞队列 非阻塞队列 ConcurrentLinkedQueue 单向链表结构的无界并发队列, 非阻塞队列，由CAS实现线程安全，内部基于节点实现 ConcurrentLi »

目录 持久化和应答机制Ack 消息持久化 应答机制Ack 死信队列 延时队列 集群模式 持久化和应答机制Ack 消息队列中间件系列的最后一篇了，RabbitMQ消息的持久化、确认机制、死信队列、负载均衡等一系列进行说明。 消息持久化 当RabbitMq重启以后，未消费的消息，可 »

目录 1.MQ概述 1.1 RocketMQ简介 1.2 MQ用途 1.3 常见MQ产品 2.RocketMQ 基本概念 2.1 消息 2.2 主题 2.3 标签 2.4 队列 2.5 Producer 2.6 Consumer 2.7 NameServer 2.8 Broker 2.9 R »

目录 什么是幂等性 什么是消息的幂等性 为什么会出现消息幂等性问题 该如何解决消息幂等性问题 在分布式系统中，消息队列是一个常用的组件，用于解耦发送者和接收者之间的耦合。在消息队列中，保证消息幂等性是一个重要的问题，因为重复处理相同的消息可能会导致系统的状态不一致或者数据的错误。 什么是幂 »

目录 什么是消息队列 一、异步与同步 1.1 同步通讯与异步通讯 1.2 同步调用的问题 1.3 异步调用方案 二、MQ消息队列 2.1 单机部署MQ 2.2 结构和概念 2.3 常见的消息模型 三、SpringAMQP 3.1 用非自动装配的方式使用消息队列 3.2 SpringAMQ »

全文约8500字，阅读时长约10分钟。 智慧作业最近上线「个性化手册」（简称个册）功能，一份完整的个性化手册分为三部分： •学情分析：根据学生阶段性的学习和考试情况进行学情分析、归纳、总结，汇总学情数据；•精准推荐：推荐算法基于学情数据结合知识图谱进行精准练习题推荐；•错题回顾：错题的阶段性回顾复习 ... »

消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题 实现高性能，高可用，可伸缩和最终一致性架构。最全面的Java面试网站 使用较多的消息队列有 RocketMQ，RabbitMQ，Kafka，ZeroMQ，MetaMQ 以下介绍消息队列在实际应用中常用的使用场景。 异 ... »

MQ 中 broker 的作用，有无broker有什么差异？ MQ（Message Queue）中的broker是消息队列的核心组件之一，它的作用是接收、存储、分发和传递消息。具体来说，broker主要有以下几个作用： 接收消息：当生产者发送消息时，消息会被发送到MQ中的broker节点。 存储消息 ... »

什么是消息队列 消息队列是一种异步的服务间通信方式，适用于无服务器和微服务架构。 消息在被处理和删除之前一直存储在队列上。每条消息仅可被一位用户处理一次。 消息队列可被用于分离重量级处理、缓冲或批处理工作以及缓解高峰期工作负载。 提供消息的我们称为生产者；接收消息的我们称为消费者。 为什么要用消息队 ... »

目录 搭建生产者工程 创建工程 添加依赖 配置整合 发送消息 搭建消费者工程 创建工程 添加依赖 配置整合 消息监听器 搭建生产者工程 创建工程 添加依赖 修改pom.xml文件内容为如下： <?xml version="1.0" encoding=" »

目录 简介 生产端 添加依赖 启动类 配置RabbitMQ 配置文件 绑定交换机和队列 搭建消费者工程 创建工程 添加依赖 启动类 配置RabbitMQ 消息监听处理类 测试 简介 在Spring项目中，可以使用Spring-Rabbit去操作RabbitMQ https:// »

目录 1.redis 用zset做消息队列如何处理消息积压 2.redis分片并使用zset做消息队列 3. redis如何分片 4. redis使用java发送消息到zset队列并对消息进行分片处理 5. redis使用zset做消息队列时，有多个消费者同时消费消息怎么处理 6.redis使用z »

目录 1.redis 用zset做消息队列如何处理消息积压 2.redis分片并使用zset做消息队列 3. redis如何分片 4. redis使用java发送消息到zset队列并对消息进行分片处理 5. redis使用zset做消息队列时，有多个消费者同时消费消息怎么处理 6.redis使用z »

目录 1、Channels 定义 2、chan 常用操作 3、带缓冲chan实现消息队列功能 重点 1、Channels 定义 通道是一种支持多类型的管道，您可以通过它使用通道运算符 <- 发送和接收值。 数据沿箭头方向流动。 ch <- v // Send v to »

目录 1、Channels 定义 2、chan 常用操作 3、带缓冲chan实现消息队列功能 重点 1、Channels 定义 通道是一种支持多类型的管道，您可以通过它使用通道运算符 <- 发送和接收值。 数据沿箭头方向流动。 ch <- v // Send v to »

为什么在“双11”抢红包活动及大型数据系统中总是出现 RocketMQ 的身影？ RocketMQ Connect在RocketMQ 生态中扮演什么角色？本文为大家解答上述疑问。同时，介绍 OceanBase 与 RocketMQ 如何集成以及能帮助大家解决哪些问题。 ... »