logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

ZooKeeper 实现分布式锁的两种方式

维度普通临时节点(非公平)临时顺序节点(公平)公平性❌ 不保证严格 FIFO惊群效应严重无实现复杂度简单中等适用场景低并发、Demo生产环境、高可靠系统通知范围广播(所有等待者)单播(仅下一个)推荐程度⭐⭐⭐⭐⭐⭐结论:生产环境应优先采用基于临时顺序节点的公平锁实现。临时顺序节点 + Watcher 监听前驱;公平锁(顺序节点)是生产环境唯一推荐方案,有效避免惊群效应;不要直接使用原生 ZK AP

#分布式#zookeeper#后端
RocketMQ 基础学习

核心架构:NameServer(路由)+ Broker(存储)+ Producer/Consumer(收发),无状态设计保证高可用;核心特性:支持顺序、事务、延迟、批量消息,满足绝大多数业务场景;消费模式:推模式(90%场景)简单高效,拉模式适用于批处理/精准控制;生产准则:必须保证消费幂等、合理设置重试次数、监控消息堆积;避坑重点:顺序消息阻塞风险、事务消息回查幂等、批量消息大小限制。推荐使用:

#rocketmq#java#后端
Spring Boot和RocketMQ基础使用

配置核心和是必填项,需按业务规范命名;消息类型普通消息:直接发送,适配大部分场景;顺序消息:需指定hashKey,消费端设为ORDERLY;延迟消息:仅支持固定等级,需设置;事务消息:需实现,处理本地事务和回查;批量消息:需保证同Topic/Tag,消费端实现;生产规范:消息 Key 必设、消费幂等必做、重试次数合理配置。

#spring boot#rocketmq#java +1
Kafka ZooKeeper 模式 vs KRaft 模式对比

【代码】Kafka ZooKeeper 模式 vs KRaft 模式对比。

#kafka#zookeeper#后端
RocketMQ 消息可靠性保障与堆积处理

生产者:同步发送 + 重试 + 事务消息(关键业务)+ 发送日志兜底Broker:同步刷盘 + 同步复制 + Dledger集群(3节点多数派)消费者:手动确认 + 幂等消费 + 死信队列兜底终极防线:MQ不可用时写入DB/Redis,恢复后自动补偿。

#rocketmq#java#后端
Kafka + KRaft 模式架构基础介绍

自 Kafka 2.8 起,社区引入KRaft(Kafka Raft Metadata)模式,旨在完全移除对 ZooKeeper 的依赖。从 Kafka 3.3 开始,KRaft 成为官方推荐的生产部署模式。新项目:强制使用 Kafka 3.5+ + KRaft;容器化部署大规模集群:Dedicated Controller Mode + 独立元数据盘。

#kafka#后端
Kafka 基础介绍

目标:完全移除 ZooKeeper 依赖;优势:简化架构、提升元数据一致性、更快启动;状态:自 Kafka 3.3 起KRaft 成为默认模式;迁移建议新项目:直接使用 KRaft;老项目:谨慎评估迁移成本,可长期运行 ZK 模式。核心模型:Topic(逻辑)→ Partition(物理)→ Leader/Follower(高可用);可靠性基石acks=all+ 多副本 + 手动提交 offset

#kafka#java#后端
ShardingSphere-JDBC的基础使用

是 Apache ShardingSphere 的第二款核心产品,定位为轻量级 Java 框架。形态:它以 Jar 包形式存在,作为第三方依赖引入项目。原理:它基于 JDBC 协议进行扩展,对 JDBC 驱动进行增强。在 Java 的 JDBC 层提供额外服务,以插件化的形式存在。核心能力:它将数据库视为一个逻辑整体,应用层只需面向逻辑库和逻辑表进行开发。ShardingSphere-JDBC 负

#数据库#mysql#spring boot
BIO、NIO 和 AIO 基础介绍

BIO:同步阻塞 I/O(Blocking I/O)NIO:同步非阻塞 I/O(Non-blocking I/O),也叫 New I/O,核心是「多路复用」AIO:异步非阻塞 I/O(Asynchronous I/O),也叫 NIO 2.0。

#nio#网络
    共 25 条
  • 1
  • 2
  • 3
  • 请选择