SpringBoot開發案例之整合Kafka實現消息隊列

前言

最近在做一款秒殺的案例,涉及到了同步鎖、數據庫鎖、分佈式鎖、進程內隊列以及分佈式消息隊列,這裡對SpringBoot集成Kafka實現消息隊列做一個簡單的記錄。

Kafka簡介

Kafka是由Apache軟件基金會開發的一個開源流處理平臺,由Scala和Java編寫。Kafka是一種高吞吐量的分佈式發佈訂閱消息系統,它可以處理消費者規模的網站中的所有動作流數據。 這種動作(網頁瀏覽,搜索和其他用戶的行動)是在現代網絡上的許多社會功能的一個關鍵因素。 這些數據通常是由於吞吐量的要求而通過處理日誌和日誌聚合來解決。 對於像Hadoop的一樣的日誌數據和離線分析系統,但又要求實時處理的限制,這是一個可行的解決方案。Kafka的目的是通過Hadoop的並行加載機制來統一線上和離線的消息處理,也是為了通過集群來提供實時的消息。

Kafka是一種高吞吐量的分佈式發佈訂閱消息系統,有如下特性:

  • 通過O(1)的磁盤數據結構提供消息的持久化,這種結構對於即使數以TB的消息存儲也能夠保持長時間的穩定性能。

  • 高吞吐量:即使是非常普通的硬件Kafka也可以支持每秒數百萬的消息。

  • 支持通過Kafka服務器和消費機集群來分區消息。

  • 支持Hadoop並行數據加載。

SpringBoot開發案例之整合Kafka實現消息隊列


分享到:


相關文章: