企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
# 消息引擎系统 * Kafka 是一款开源的`消息引擎`系统 * AKA Messaging System * 官方定义:消息引擎系统是一组规范。企业利用这组规范在不同系统之间传递语义准确的消息,实现松耦合的异步式数据传递。 * 民间定义:系统 A 发送消息给消息引擎系统,系统 B 从消息引擎系统中读取 A 发送的消息。 * 两个重要事实 * 消息引擎传输的对象是消息 * 如何传输消息属于消息引擎设计机制的一部分 * Kafka 传递的消息使用的是`纯二进制的字节序列` * 常见的消息传输方式(i.e. 传输协议) * 点对点模型(i.e. 消息队列模型) * 日常生活例子中:电话客服模式 * 发布 / 订阅模型 * 具有主题(Topic)概念,i.e. 逻辑语义相近的消息容器 * 发送方,i.e. Publisher * 接收方,i.e. Subscriber * 该模型可以支持 * 多个 publisher 向相同的 topic 发送消息 * 一个 topic 可以存在多个 subscriber * 参考生活中:报纸订阅 * Messaging system 的真实作用:`削峰填谷`