消息队列

MQ系列11:如何保证消息可靠性传输(除夕奉上)

MQ系列1:消息中间件执行原理 MQ系列2:消息中间件的技术选型 MQ系列3:RocketMQ 架构分析 MQ系列4:NameServer 原理解析 MQ系列5:RocketMQ消息的发送模式 MQ系列6:消息的消费 MQ系列7:消息通信,追求极致性能 MQ系列8:数据存储,消息队列的高可用保障 M ... »

如何利用rabbitMq的死信队列实现延时消息

目录 前言 mq基本的消息模型 mq死信队列的消息模型 maven依赖 配置普通队列和死信队列 死信队列消费者 发送消息测试 测试成功 总结 前言 使用mq自带的死信去实现延时消息要注意一个坑点,就是mq只会检测队首的消息的过期时间,假设先放入队列10s过期消息,再放入2s过期。 »

消息队列常见的使用场景

本文已经收录到Github仓库,该仓库包含计算机基础、Java基础、多线程、JVM、数据库、Redis、Spring、Mybatis、SpringMVC、SpringBoot、分布式、微服务、设计模式、架构、校招社招分享等核心知识点,欢迎star~ Github地址:https://github.c ... »

tyson03

基于云基础设施快速部署 RocketMQ 5.0 集群

如何解决在云基础设施上部署 RocketMQ 时面临多节点部署带来的高操作成本等诸多挑战?快来了解 RocketMQ Operator 是怎样支撑 RocketMQ 集群在云基础设施上的自动化运维与管理吧! ... »

RocketMQ

C++实现一个简单消息队列的示例详解

目录 前言 一、如何实现 1、接口定义 2、用到的对象 3、基本流程 二、完整代码 三、使用示例 线程通信 总结 前言 消息队列在多线程的场景有时会用到,尤其是线程通信跨线程调用的时候,就可以使用消息队列进行通信。C++实现一个能用的消息队列还是比较简单的,只需要一个队列一个互斥变 »

工作总结:kafka踩过的坑

餐饮系统每天中午和晚上用餐高峰期,系统的并发量不容小觑。公司规定各部门都要轮流值班,防止出现线上问题时能够及时处理。 后厨显示系统属于订单的下游业务。 用户点完菜下单后,订单系统会通过发 Kafka 消息给系统; 系统读取消息后,做业务逻辑处理,持久化订单和菜品数据,然后展示到划菜客户端; 这样厨师 ... »

Prometheus 监测 RocketMQ 最佳实践

作为越来越重要的应用组件得特性,可观测性受到越来越多人的重视。RocketMQ是如何进行可观测性建设的呢?快来了解如何使用 Prometheus 监控 RocketMQ 吧~ ... »

RocketMQ

消息队列之RabbitMQ介绍与运用

RabbitMQ 说明 本章,我们主要从RabbitMQ简介、RabbitMQ安装、RabbitMQ常用命令、RabbitMQ架构模式、RabbitMQ使用、Quick.RabbitMQPlus的使用和RabbitMQ总结这几个方面对 RabbitMQ进行介绍! 1、?RabbitMQ 简介 Ra ... »

Linux 下搭建 Kafka 环境

Linux 下搭建 Kafka 环境 作者:Grey 原文地址: 博客园:Linux 下搭建 Kafka 环境 CSDN:Linux 下搭建 Kafka 环境 环境要求 操作系统:CentOS 7 下载地址 安装说明 Kafka 版本:2.11-2.1.0 下载地址 注:这个版本的 Kafka 需要 ... »

它让你1小时精通RabbitMQ消息队列(新增死信处理)

支持.NET/.NET Framework/.NET Core RabbitMQ作为一款主流的消息队列工具早已广受欢迎。相比于其它的MQ工具,RabbitMQ支持的语言更多、功能更完善。 本文提供一种市面上最/极简单的使用RabbitMQ的方式,只需要会调用以下三个方法,你就几乎可以掌握整个Rabb ... »

dotnet-college

MQ系列6:消息的消费

MQ系列1:消息中间件执行原理 MQ系列2:消息中间件的技术选型 MQ系列3:RocketMQ 架构分析 MQ系列4:NameServer 原理解析 MQ系列5:RocketMQ消息的发送模式 在之前的文章中,我们学习了RocketMQ的原理;RocketMQ中 命名服务 ServiceName 的 ... »

RocketMq 消息重试机制及死信队列详解

目录 生产者消息重试 消费者消息重试 并发消费 顺序消费 并发消费和顺序消费区别 死信队列 实践出真知 公共部分创建 测试并发消费 并发消费状态 测试顺序消费 顺序消费状态 测试死信队列 死信队列特性 生产者消息重试 消息队列中的消息消费时并不能保证总是成功的,那失败的消息该怎么 »

我的 Kafka 旅程 - Consumer

Kafka Consumer,消费者消费流程,配置介绍,offset的使用,消费者组,消费者组内再平衡,再平衡策略,提高消费者端吞吐量。 ... »

Sol-wang

我的 Kafka 旅程 - 文件存储机制

Kafka Partition中的文件存储机制,数据写入方式,数据查询方式,高效读写数据的原因,稀疏索引,数据顺序写入磁盘,零拷贝技术,数据文件的清理方式及配置。 ... »

Sol-wang

我的 Kafka 旅程 - broker

kafka broker,数据分区,kafka broker 应答机制,leader与副本数据同步,数据不重复,数据防丢失,数据按顺序,数据幂等性,partition 分区自动平衡,broker节点管理。 ... »

Sol-wang

拆解一下任务队列、消息队列、任务调度系统

最近调研了下任务调度系统中间件,包括xxl-job、elastic-job等,发现跟任务队列有一些类似的能力,比如通过API(事件)触发任务执行。 随即想到,能否用任务调度系统覆盖任务队列的场景呢? 另外,一直以来,很多同学也经常会产生困惑,任务队列和消息队列究竟有什么区别? 因此,本文通过多个维度 ... »

消息队列MQ核心原理全面总结(11大必会原理)

消息队列已经逐渐成为分布式应用场景、内部通信、以及秒杀等高并发业务场景的核心手段,它具有低耦合、可靠投递、广播、流量控制、最终一致性 等一系列功能。 无论是 RabbitMQ、RocketMQ、ActiveMQ、Kafka还是其它等,都有的一些基本原理、术语、机制等,总结分享出来,希望大家在使用消息 ... »

go+redis实现消息队列发布与订阅的详细过程

在做项目过程中,实现websocket得时候,不知道哪里写的不太合适,客户端消息收到一定程度,剩下的消息收不到,修改了缓冲区大小,还是没有解决问题,后面因为项目结束期比较紧张,没有时间调试消息的时候,改用了redis队列去做了消息得暂存,客户端轮询去拿对应的消息。 1.生产者随机发布消息,用rpu »