KafKa -- 消息中间件理解没有写完

水深无声 2024-04-18 19:18 52阅读 0赞

现在写的可能比较乱，回头整理

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU1MDQ5MA_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU1MDQ5MA_size_16_color_FFFFFF_t_70 1]

消息队列的应用场景

使用消息队列的好处

*  解耦
 *  可恢复性
 *  缓冲，解决生产速度和消费消息处理不一致
 *  灵活性和峰值处理能力，可以更具访问压力动态的调节峰值

**消息队列的两种模式**

*  点对点模式

消息生产者生成消费发送到queue中，然后消费者从queue中取出并消费消息，

消息被消费后，queue不再存储，所以消费者不可能消费到已经被消费的消息，queue支持存在多个消费者，但是一个消息，只会有一个消费者可以消费  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU1MDQ5MA_size_16_color_FFFFFF_t_70 2]

*  发布/订阅模式（一对多，消费者消费数据之后，不会清楚消息）

消息生产者，发布将消息发布到topic中，同时又多个消费者 订阅 消费该消息，和点对点方式不同，发布到topic的消费会被所有订阅者消费

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU1MDQ5MA_size_16_color_FFFFFF_t_70 3]  
发布订阅： 比如公众号，关注后，都会被订阅到  
拉去点对点： 消费者主动拉去数据，第二中跟公众号一样，主动推送的消息

kafka 是基于消息队列的 发布订阅模式，基于拉取。消费者的消费速度可以由自己决定

基于拉取的缺点，要想消费者拉去，需要问下topic有没有消息，消费者，要不定时的问有没有消息，如果长时间没有消息，需要频繁去问，长连接，尝试获取，比较浪费资源

消息队列，两种模式，点对点主题模式，发布订阅模式

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU1MDQ5MA_size_16_color_FFFFFF_t_70 4]  
明晚上补

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU1MDQ5MA_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/a4fe0651d8da4a43a0b32655247a5c36.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU1MDQ5MA_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/a851ed5161b34c38b38db8b505b606da.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU1MDQ5MA_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/281b653213b14c4e9960a30ab514ee1e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU1MDQ5MA_size_16_color_FFFFFF_t_70 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/b7a8c03b9ded4c14881a9382a26dd467.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU1MDQ5MA_size_16_color_FFFFFF_t_70 4]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/314331cf935f45e3b011ef49ba87fdbb.png