tag

事件驱动

共 15 篇文章。
全部文章GoTypeScript游戏开发小游戏游戏设计Godot书稿RustPython性能优化游戏引擎PRDSaaS游戏服务端
工作流引擎

事件驱动触发与消息集成

本文系统讲解工作流的事件驱动触发与消息集成,回答事件源如何映射到工作流实例、Kafka 与 Pulsar 集成时顺序与去重怎么保证、背压与触发风暴如何治理。覆盖推拉两种触发模型、分区键与消费组语义、幂等消费与去重表、事件时间与乱序处理、限流与合并窗口、事件驱动与定时调度的边界、死信兜底与观测告警,并给出可落地的配置片段与代码。

20 分钟阅读
工作流 事件驱动 幂等
saas

Webhook 专题导航:从入门原理到 SaaS 平台设计的 25 篇索引

本导航收录 content/posts/saas/webhook 下 25 篇文章,覆盖 Webhook 从概念入门、签名验签、重试幂等、高并发架构到多区域部署与监控告警的完整技术链条,并包含 GitHub、Stripe、Slack、飞书、钉钉五大平台的集成实战,以及一套「把 Webhook 做成 SaaS 产品」的商业文档。适合后端工程师、平台架构师与正在做事件驱动产品的创业者。

7 分钟阅读
Webhook 事件驱动 后端架构
kafka

Kafka 消息队列专题

Apache Kafka 是全球最广泛采用的分布式流处理平台,被用于构建高吞吐事件驱动架构、实时数据管道与流式计算系统。本专题从核心概念出发,深入讲解 Topic/Partition/Consumer Group 设计原理、生产者 ACK 策略与幂等性实现、消费者偏移量管理与再平衡机制、KRaft 元数据架构替代 ZooKeeper、Kafka Connect 数据集成与 CDC 方案、Kafka Streams 流处理编程模型,以及集群容量规划、运维监控与安全最佳实践,帮助开发者掌握 Kafka 企业级生产部署全链路能力,并深入消费组再平衡协议(Eager/CooperativeSticky/分区分配策略)、存储内核(日志段/留存策略/日志压缩/分层存储)、副本与控制器机制(ISR/HW/Leader 选举/KRaft)、broker 网络线程模型(请求队列/零拷贝/背压)、Producer 批量与吞吐调优(压缩/acks/幂等)与配额限流治理(多租户隔离/动态配额),并延伸分层存储与冷数据卸载(KIP-405/Remote Log Manager/成本与延迟)、Kubernetes 上的 Strimzi Operator 部署(Kafka CR/拓扑反亲和/PVC 扩容/滚动升级)、Share Groups 队列语义(KIP-932/ack 与超时重投/并发度)、消费延迟(Lag)分层诊断与治理(分区倾斜/并行度/背压限流)、自定义 Connector 开发(Source 与 Sink 接口/offset 与 Exactly-Once/SMT)与 ksqlDB 流式 SQL(流与表/窗口聚合/Pull 与 Push 查询/物化视图),并补齐 Debezium CDC 实战(快照与增量/事务边界/Exactly-Once)、Kafka Streams 状态存储与 RocksDB 调优(变更日志/待机副本/状态重建)、日志段与索引内部机制(稀疏索引/页缓存/索引重建)、Java 客户端参数精调(fetch 与 max.poll/心跳与重试)、Streams 拓扑测试(TopologyTestDriver/时间语义)与大消息处理(分片与引用传递/外部存储)。

10 分钟阅读
Kafka 消息队列 事件驱动