雙11購物車黑科技！SpringBoot + Hazelcast 實現數據同步與故障轉移
在分布式系統架構中，數據同步和故障轉移（Failover）是核心問題之一。Hazelcast 作為一種高性能的內存數據網格（IMDG），可以幫助我們實現分布式數據共享、緩存以及容錯機制，確保應用高可用性。本文將介紹如何在 Spring Boot 應用中集成 Hazelcast，實現數據同步和故障轉移，并提供完整的示例代碼。
Hazelcast 簡介
Hazelcast 是一個開源的內存計算平臺，提供分布式數據存儲、緩存和流處理功能，支持 Java、.NET、Node.js 等多種語言。它的核心特性包括：
- 對等架構無中心化節點，每個節點地位相同，避免單點故障。
- 自動發現節點可以自動發現并加入 Hazelcast 集群。
- 分區存儲數據在集群中的多個節點間進行分片存儲，提高性能和可靠性。
- 多種數據結構支持 IMap、MultiMap、Queue、Set、List 等數據結構。
- 持久化支持將數據持久化到磁盤，避免數據丟失。
官方網站：https://hazelcast.com/ 開源項目地址：https://github.com/hazelcast/hazelcast
引入 Hazelcast 依賴
在 pom.xml 文件中添加 Hazelcast 相關依賴：
<dependencies>
<dependency>
<groupId>com.hazelcast</groupId>
<artifactId>hazelcast</artifactId>
<version>5.2.0</version>
</dependency>
<dependency>
<groupId>com.hazelcast</groupId>
<artifactId>hazelcast-spring</artifactId>
<version>5.2.0</version>
</dependency>
</dependencies>Hazelcast 配置
在 com.icoderoad.config.HazelcastConfig 類中配置 Hazelcast：
package com.icoderoad.config;
import com.hazelcast.config.Config;
import com.hazelcast.config.NetworkConfig;
import com.hazelcast.config.JoinConfig;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class HazelcastConfig {
@Bean
public Config hazelcastConfig() {
Config config = new Config();
config.setInstanceName("hazelcast-instance");
NetworkConfig networkConfig = config.getNetworkConfig();
JoinConfig joinConfig = networkConfig.getJoin();
joinConfig.getMulticastConfig().setEnabled(true);
return config;
}
}創建 Hazelcast 服務類
在 com.icoderoad.service.CacheService 中創建數據存取服務：
package com.icoderoad.service;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.map.IMap;
import org.springframework.stereotype.Service;
import java.util.Map;
@Service
public class CacheService {
private final HazelcastInstance hazelcastInstance;
public CacheService(HazelcastInstance hazelcastInstance) {
this.hazelcastInstance = hazelcastInstance;
}
public void putValue(String key, String value) {
IMap<String, String> map = hazelcastInstance.getMap("distributed-cache");
map.put(key, value);
}
public String getValue(String key) {
IMap<String, String> map = hazelcastInstance.getMap("distributed-cache");
return map.get(key);
}
}創建 REST 接口
在 com.icoderoad.controller.CacheController 類中創建 REST API：
package com.icoderoad.controller;
import com.icoderoad.service.CacheService;
import org.springframework.web.bind.annotation.*;
@RestController
@RequestMapping("/cache")
public class CacheController {
private final CacheService cacheService;
public CacheController(CacheService cacheService) {
this.cacheService = cacheService;
}
@PostMapping("/put")
public String put(@RequestParam String key, @RequestParam String value) {
cacheService.putValue(key, value);
return "Success";
}
@GetMapping("/get")
public String get(@RequestParam String key) {
return cacheService.getValue(key);
}
}測試 Hazelcast 數據同步
運行多個 Spring Boot 實例，并在一個實例中存儲數據：
curl -X POST "http://localhost:8080/cache/put?key=test&value=hello"然后在另一個實例中獲取數據：
curl -X GET "http://localhost:8080/cache/get?key=test"你會發現數據可以在多個實例之間共享。
結論
本文介紹了 Hazelcast 的基本概念，并展示了如何在 Spring Boot 中集成 Hazelcast 進行分布式緩存管理。Hazelcast 作為一款強大的緩存框架，提供了對等架構、自動擴展和數據持久化等特性，適用于高并發場景。
相比于 Redis，Hazelcast 適用于對 JVM 友好的分布式環境，支持更豐富的數據結構，并且無需額外的外部依賴。如果你的應用需要高性能分布式緩存，不妨嘗試 Hazelcast。
你可以進一步擴展本示例，如：
- 結合 Spring Cache 進行注解式緩存管理
- 配置 Hazelcast 集群，實現高可用性
- 結合持久化存儲，確保數據可靠性
