Kafka -- 消息引擎系统

术语

1. Apache Kafka是一款开源的消息引擎系统
2. 消息队列：给人某种暗示，仿佛Kafka是利用队列实现的
3. 消息中间件：过度强调中间件，而不能清晰地表达实际解决的问题

解决的问题

1. 系统A发送消息给消息引擎系统，系统B从消息引擎系统中读取A发送的消息
2. 消息引擎传输的对象是消息
3. 如何传输消息属于消息引擎设计机制的一部分

消息格式

1. 成熟解决方案：CSV、XML、JSON
2. 序列化框架：Google Protocol Buffer、Facebook Thrift
3. Kafka：纯二进制的字节序列

消息引擎模型

1. 点对点模型
   • 即消息队列模型，系统A发送的消息只能被系统B接收，其他任何系统不能读取A发送的消息
2. 发布订阅模型
   • 主题（Topic）、发布者（Publisher）、订阅者（Subscriber）
   • 多个发布者可以向相同的主题发送消息，多个订阅者可以接收相同主题的消息
3. Kafka同时支持上面两种消息引擎模型

JMS

1. JMS：Java Message Service
2. JMS也支持上面的两种消息引擎模型
3. JMS并非传输协议，而是一组API
4. JMS非常出名，很多主流的消息引擎系统都支持JMS规范
   • ActiveMQ、RabbitMQ、IBM WebSphere MQ、Apache Kafka（并未完全遵照）

优点

1. 削峰填谷
2. 解耦

参考资料

Kafka核心技术与实战