一、kafka的定义
传统定义:kafka是一个分布式的基于发布/订阅模式的消息队列
发布订阅:消息的发布者不会将消息直接发送给特定的订阅者,而是将发布的消息分为不同的类别,订阅者只接收感兴趣的消息
1、消息队列
目前常见的消息队列产品主要有:Kafka、ActiveMQ、RabbitMQ,大数据常用kafka
1)传统消息队列的应用场景
主要应用的场景包括:缓存/消峰、解耦和异步通信
- 缓存/消峰:有助于控制和优化数据流经过系统的速度,解决生产消息和消费消息的处理速度不一致的情况
- 解耦:允许你独立的扩展或修改两边的处理过程,只要确保他们遵守同样的接口约束
- 异步通信:允许用于把一个消息放入队列,但并不立即处理它,然后在需要的时候再去处理 (先处理重要的消息,不重要的消息后续在慢慢的处理)
2)消息队列的两种模式
- 点对点模式:消费者主动拉取数据,消息收到后清除消息
- 发布/订阅模式
- 可以有多个topic主题(浏览、点赞、收藏、评论)
- 消费者消费数据后,不删除数据 (a消费完以后b仍然可以消费)
- 买个消费者相互独立,都可以消费到数据
2、
标签:订阅,消费,队列,模式,kafka,命令,消息 From: https://www.cnblogs.com/frankruby/p/17089227.html