Kafka如何实现高效的消息队列机制？

本文共计1335个文字，预计阅读时间需要6分钟。

Kafka 是一个基于发布/订阅模式的分布式消息队列。消息队列有两种模式：点对点模式（一对一，消费者主动拉取数据，消息被接收后清除）和发布/订阅模式（多对一，多个消费者可订阅同一主题，消息由生产者发布，消费者被动接收）。特点是一个消息只能被一个消费者消费。

1、什么是kafka

Kafka 是一个分布式的基于发布/订阅模式的消息队列

消息队列的两种模式：

点对点模式（一对一，消费者主动拉取数据，消息收到后消息清除）。特点，一个消息只能被一个消费者消费

发布/订阅模式（一对多，消费者消费数据之后不会清除消息）。特点，一个消息可以被多个订阅的消费者消费

2、消息队列的优点：

解耦
允许独立扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束。
可恢复性
系统的一部分组件失效时，不会影响到整个系统。消息队列降低了进程间的耦合度，所以即使一个处理消息的进程挂掉，加入队列中的消息仍然可以在系统恢复后被处理。
灵活性 & 峰值处理能力
在访问量剧增的情况下，应用仍然需要继续发挥作用，但是这样的突发流量并不常见。如果为以能处理这类峰值访问为标准来投入资源随时待命是很浪费的，使用消息队列能够使关键组件顶住突发的访问压力，而不会因为突发的超负荷请求而崩溃。