消息共16篇
RocketMQ消息处理流程-不念博客

RocketMQ消息处理流程

RocketMQ在接收到消息后,会执行下面的流程: 检查消息格式是否正确 进行消息空间检测(没有超过限制) 将消息存入内存队列 根据配置进行持久化 根据路由规则发送消息 触发消费者消费消息 记录消费...
不念的头像-不念博客不念9天前
0376113
kafka三高架构设计介绍-不念博客

kafka三高架构设计介绍

Kafka架构中的一般概念: 架构 Producer:生产者,也就是发送消息的一方。生产者负责创建消息,然后将其发送到 Kafka。 Consumer:消费者,也就是接受消息的一方。消费者连接到 Kafka 上并接收...
不念的头像-不念博客不念14天前
0359102
Kafka如何保证消息不丢失?-不念博客

Kafka如何保证消息不丢失?

使用一个消息队列,其实就分为三大块:生产者、中间件、消费者,所以要保证消息就是保证三个环节都不能丢失数据。 消息生产阶段:生产者会不会丢消息,取决于生产者对于异常情况的处理是否合理...
不念的头像-不念博客不念25天前
0241121
Spring Boot项目集成RabbitMQ实战以及坑点讲解-不念博客

Spring Boot项目集成RabbitMQ实战以及坑点讲解

本文给大家介绍一下在 Spring Boot 项目中如何集成消息队列 RabbitMQ,包含对 RibbitMQ 的架构介绍、应用场景、坑点解析以及代码实战。 我将使用waynboot-mall项目作为代码讲解,项目地址:http...
不念的头像-不念博客不念1个月前
0323109
关于Redisson延迟队列的一些思考-不念博客

关于Redisson延迟队列的一些思考

最近部门在做一套告警治理相关的系统,专门用于对整个业务线杂七杂八的告警进行治理管控。 例如Kakfa异常,业务异常,Dubbo超时等等场景,全部都首先会被这套系统给监控到,然后再通过一定的策...
不念的头像-不念博客不念1个月前
049254
分布式事务本地消息表实现原理-不念博客

分布式事务本地消息表实现原理

本地消息表是一种确保分布式事务最终一致性的方法。 它的工作原理是: 在执行本地事务的同时,将需要异步执行的远程服务调用相关信息存储在同一个本地数据库的消息表中。 本地事务和消息表的写...
不念的头像-不念博客不念3个月前
036457
什么是消息队列?-不念博客

什么是消息队列?

消息队列是在消息的传输过程中保存消息的容器,用于接收消息并以文件的方式存储,一个消息队列可以被一个也可以被多个消费者消费,包含以下 3 元素: Producer:消息生产者,负责产生和发送消息...
不念的头像-不念博客不念4个月前
048476