architecture-paradigm-event-driven
事件驱动异步消息解耦生产者消费者
安装使用
复制下面这段提示词发给你的 AI(Claude / Cursor / TRAE / Codex / WorkBuddy 等),它会自动帮你完成安装:
帮我安装这个 AI Skill:architecture-paradigm-event-driven。 它的用途是:事件驱动异步消息解耦生产者消费者 完整的 Skill 内容见:https://321skill.com/skills/architecture-paradigm-event-driven-x-6/raw/index.md 请读取该页面内容,如果是 SKILL.md 格式直接安装,如果是 README 提炼核心 prompt 后安装。
提示词包含完整的 Skill 内容链接,AI 读取后即可完成安装。你也可以 查看完整内容 确认无误。
使用示例
‘使用事件驱动架构,为订单服务创建一个事件,当订单创建时发布OrderCreated事件,然后让库存服务和通知服务分别订阅该事件’。AI会自动生成事件定义、发布代码和消费者监听代码,并配置好消息队列连接。
介绍
该 Skill 将事件驱动架构模式封装为可复用的异步消息处理模块,解决微服务或分布式系统中服务间紧耦合、消息丢失、扩展性差等问题。通过事件总线机制,生产者只需发布事件,消费者订阅感兴趣的事件类型,实现完全的异步解耦,同时内置重试、死信队列、超时控制等生产级保障。
使用时,只需在项目中引入该模块,定义事件类型和对应的消息结构,然后注册消费者监听特定事件。系统会自动根据配置的队列策略(如 RabbitMQ、Kafka 或内存队列)分发消息,支持批量消费、顺序消费、延迟消息等高级特性。开发者无需关心底层消息中间件的细节,只需聚焦业务逻辑。
适合后端开发工程师、全栈开发工程师、微服务架构师,以及需要构建高吞吐、高可靠异步通信系统的团队。尤其适用于电商订单处理、通知推送、日志采集、数据同步等场景,也适合将单体应用拆分为事件驱动架构时的快速落地。
使用前请确保已安装对应消息中间件(如 RabbitMQ、Kafka 或 Redis),并根据业务量调整队列参数。注意事件幂等性设计,消费端需实现去重逻辑。该 Skill 不提供可视化界面,需通过代码配置事件通道。
核心特点
与通用消息队列客户端库不同,该 Skill 内置了事件驱动架构的完整生命周期管理(发布、订阅、重试、死信、监控),并自动适配多种消息中间件,开发者只需定义事件类型即可开箱即用。
注意事项
不适合单机纯同步调用场景,也不适合需要强一致性的分布式事务场景(如金融转账)。
常见问题
这个 Skill 支持哪些消息中间件?
默认支持 RabbitMQ、Kafka 和内存队列,可通过配置扩展支持其他消息中间件。
如何处理消费者处理失败的消息?
内置重试机制和死信队列,失败消息会自动进入死信队列并记录日志,支持手动重新投递。
给 AI 助手的安装指引
如果你的 AI 编程助手(Claude Code、Cursor、TRAE 等)能看到这个页面,把下面这段发给它即可自动完成安装:
请访问 https://321skill.com/skills/architecture-paradigm-event-driven-x-6/raw/index.md 读取 architecture-paradigm-event-driven 的原始 Skill 定义(Markdown 格式),按其中说明在我的环境里完成安装和配置。
AI 可直接读取的原始 Markdown 地址:/skills/architecture-paradigm-event-driven-x-6/raw/index.md(查看排版版本)