RocketMQ

redisson RocketMQ秒杀下单实战总结

之前完成了一个秒杀下单系统的开发，现在总结一下，起因业务场景是社区电商， 疫情期间，社区准备了一批口罩，打算分批让用户抢购。那时我们还在过年，客户也没通知我们，然后我们这个小电商系统，在当晚就挂掉了。下面是我们当时的架构：类似下面稍微思考到这个架构的问题，用户下单时,redisson进行加锁时...
2023-03-26 22:05 阅读数 198

RabbitMQ、RocketMQ、Kafka延迟队列实现

延迟队列在实际项目中有非常多的应用场景，最常见的比如订单未支付，超时取消订单，在创建订单的时候发送一条延迟消息，达到延迟时间之后消费者收到消息，如果订单没有支付的话，那么就取消订单。那么，今天我们需要来谈的问题就是RabbitMQ、RocketMQ、Kafka中分别是怎么实现延时队列的，以及他...
2022-12-22 09:59 阅读数 62

RocketMQ（2） - Broker 启动源码分析

1. broker 启动broker 启动需要指定启动参数，-c D:\IDEA_Project\Rule\rocketmq\conf\broker.conf, 其中的配置文件，主要是包括存储消息的路径、nameServer 地址，刷盘方式等，如下, 然后执行 org.apache.rock...
2021-11-28 16:36 阅读数 56

RocketMQ手册

一、RocketMQ介绍1.1. 简介RocketMQ 是一款分布式、队列模型的消息中间件，具有以下特点：能够保证严格的消息顺序提供丰富的消息拉取模式高效的订阅者水平扩展能力实时的消息订阅机制亿级消息堆积能力选用理由：强调集群无单点，可扩展，任意一点高可用，水平可扩展。海量消息堆积能力，消息堆...
2020-08-03 02:14 阅读数 61

Apache RocketMQ官方文档中文精简版-事务消息示例

什么是事务消息？事务消息，可以被认为是一种基于两阶段提交理论的消息实现，用来确保分布式系统中的最终一致性。事务性消息保证了本地事务的执行和消息的发送可以原子性地执行。使用限制(1) 不支持定时消息和批量消息。(2) 为了避免单个消息被检查次数过多，导致半队列消息累积，我们将单个消息的检查次数默...
2020-08-03 02:14 阅读数 134

事务消息源码学习

事务消息源码学习TransactionMQProducer发送事务消息事务消息发送时，需要打上相应的标记，与普通消息进行区分MessageAccessor.putProperty(msg, MessageConst.PROPERTY_TRANSACTION_PREPARED, true);Me...
2020-07-26 03:04 阅读数 191

RocketMQ多个namesrv使用遇到的坑

1业务背景最近在做新老系统的mysql数据同步，由于新系统切换为微服务，数据结构设计不同，使用RocketMQ进行异步同步数据。老系统已经有个老版本的MQ集群，所以在微服务的系统中，需要配置两个MQ集群，一个为新系统服务，另外一个专门为同步数据到老系统服务。2代码这里仅仅按照官方文档示例设置了...
2019-12-07 19:49 阅读数 69
技术
下载桌面版
GitHub
Gitee
SourceForge
百度网盘（提取码：draw）
云服务器优惠
华为云优惠券
腾讯云优惠券
阿里云优惠券
Vultr优惠券
站点信息
问题反馈
邮箱：[email protected]
吐槽一下
QQ群：766591547
关注微信
©2020-2024 ioDraw All rights reserved, Privacy Policy