消息队列
消息队列选型:Kafka与RabbitMQ的应用边界
从吞吐、时序与一致性模型对比两大消息系统的应用边界,并给出工程选型建议。
云消息服务选型:AWS SQS与Google Pub/Sub对比
比较两大云消息服务在吞吐、延迟与投递语义上的差异,指导跨云与规模化场景选型。
事件驱动架构:Outbox、CDC与消息顺序保障
构建可靠的事件流,保障跨服务一致性与顺序性,处理重复与失败恢复。
Redis Streams与消息处理:消费者组与持久化
以 Redis Streams 构建轻量消息系统,使用消费者组与持久化 offset 实现可靠处理与重平衡。
NATS与JetStream:主题路由与流存储选型
对比 NATS 的轻量消息与 JetStream 的流存储能力,在路由、持久化与消费模式上进行工程选型。
Kafka消费者重平衡与分配策略:Sticky/Range/RoundRobin
理解消费者组的重平衡机制与三种分配策略的差异,优化分区分配与稳定性。
Kafka延迟与重试退避策略实践
通过生产者/消费者重试与退避策略优化Kafka延迟与稳定性,提供可验证的配置与命令,保障高并发处理。
NATS JetStream流存储与消费语义实践
使用JetStream进行流存储与拉取/推送消费,提供可验证的配置与命令实现可靠处理与保留策略。
