這段內(nèi)容主要講解了 Apache Ignite 中緩存（IgniteCache）的基本操作，包括獲取緩存、創(chuàng)建緩存、銷毀緩存、執(zhí)行原子操作以及異步操作等。下面我將用中文對這些內(nèi)容進(jìn)行詳細(xì)解釋，幫助你更好地理解。

一、獲取緩存實(shí)例（Getting an Instance of a Cache）

所有對緩存的操作都必須通過 IgniteCache 實(shí)例來完成。你可以獲取一個(gè)已經(jīng)存在的緩存，或者動態(tài)創(chuàng)建一個(gè)新緩存。

示例代碼：

Ignite ignite = Ignition.ignite();
// 獲取名為 "myCache" 的緩存實(shí)例
IgniteCache<Integer, String> cache = ignite.cache("myCache");

?? 注意：不同緩存的泛型類型可能不同，比如 IgniteCache<Integer, String> 和 IgniteCache<String, Person> 是不同的類型。

二、動態(tài)創(chuàng)建緩存（Creating Caches Dynamically）

你也可以在運(yùn)行時(shí)動態(tài)創(chuàng)建一個(gè)緩存，使用 getOrCreateCache() 方法。如果緩存已經(jīng)存在，就直接返回；如果不存在，就根據(jù)配置創(chuàng)建。

示例代碼：

CacheConfiguration<Integer, String> cfg = new CacheConfiguration<>();
cfg.setName("myNewCache");
cfg.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
IgniteCache<Integer, String> cache = ignite.getOrCreateCache(cfg);

配置說明：

• setName(...)：設(shè)置緩存名稱。
• setAtomicityMode(...)：設(shè)置緩存的原子性模式（例如 TRANSACTIONAL 或 ATOMIC）。
• 還可以設(shè)置很多其他參數(shù)，比如備份數(shù)量、緩存模式（分區(qū)/復(fù)制）等。

注意事項(xiàng)：

• 如果在集群拓?fù)浒l(fā)生變化（如節(jié)點(diǎn)加入或退出）時(shí)調(diào)用 getOrCreateCache()，可能會拋出異常：

javax.cache.CacheException: class org.apache.ignite.IgniteCheckedException: Failed to start/stop cache, cluster state change is in progress.

• 遇到這個(gè)異常時(shí)，建議稍后重試。

三、銷毀緩存（Destroying Caches）

使用 destroy() 方法可以從整個(gè)集群中刪除一個(gè)緩存。

示例代碼：

Ignite ignite = Ignition.ignite();
IgniteCache<Long, String> cache = ignite.cache("myCache");
cache.destroy();  // 刪除名為 "myCache" 的緩存

?? 注意：此操作是不可逆的，會刪除所有節(jié)點(diǎn)上的緩存數(shù)據(jù)和配置。

四、基本原子操作（Basic Atomic Operations）

獲取到緩存后，可以進(jìn)行常見的 put、get、remove 等操作。

示例代碼：

IgniteCache<Integer, String> cache = ignite.cache("myCache");
// 存入數(shù)據(jù)
for (int i = 0; i < 10; i++) {
    cache.put(i, Integer.toString(i));
}
// 獲取數(shù)據(jù)
for (int i = 0; i < 10; i++) {
    System.out.println("Got [key=" + i + ", val=" + cache.get(i) + ']');
}

批量操作注意事項(xiàng)：

• 使用 putAll()、removeAll() 等批量操作時(shí)，是作為一系列原子操作執(zhí)行的。
• 如果部分操作失敗，會拋出 CachePartialUpdateException，并包含失敗的 key 列表。
• 如果希望批量操作作為一個(gè)整體完成，建議使用 事務(wù)。

五、條件更新操作（Conditional Updates）

Ignite 提供了一些帶有條件判斷的更新方法，用于實(shí)現(xiàn)線程安全的更新邏輯。

示例代碼：

// 如果 key 不存在，則插入，返回舊值
String oldVal = cache.getAndPutIfAbsent(11, "Hello");
// 如果 key 不存在，插入，返回是否成功
boolean success = cache.putIfAbsent(22, "World");
// 如果 key 存在，替換，返回舊值
oldVal = cache.getAndReplace(11, "New value");
// 如果 key 存在，替換，返回是否成功
success = cache.replace(22, "Other new value");
// 如果值匹配，才替換
success = cache.replace(22, "Other new value", "Yet-another-new-value");
// 如果值匹配，才刪除
success = cache.remove(11, "Hello");

六、異步操作（Asynchronous Execution）

Ignite 的很多緩存操作都有對應(yīng)的 異步版本，方法名通常帶有 Async 后綴。

示例代碼：

// 同步 get
V get(K key);
// 異步 get
IgniteFuture<V> getAsync(K key);

異步操作的處理方式：

• 返回一個(gè) IgniteFuture 對象，表示異步操作的結(jié)果。
• 可以阻塞等待結(jié)果，也可以注冊監(jiān)聽器來非阻塞地處理結(jié)果。

示例監(jiān)聽器：

IgniteCompute compute = ignite.compute();
IgniteFuture<String> fut = compute.callAsync(() -> "Hello World");
fut.listen(f -> System.out.println("Job result: " + f.get()));

七、線程池與閉包執(zhí)行（Closures Execution and Thread Pools）

• 如果異步操作在注冊監(jiān)聽器前就已經(jīng)完成，監(jiān)聽器會由當(dāng)前線程 同步執(zhí)行。
• 如果異步操作還未完成，監(jiān)聽器會在操作完成后由線程池中的線程 異步執(zhí)行。
  • 緩存操作的異步回調(diào)通常由 系統(tǒng)線程池 執(zhí)行。
  • 計(jì)算任務(wù)的異步回調(diào)通常由 公共線程池 執(zhí)行。

注意事項(xiàng)：

• 不要在監(jiān)聽器中再調(diào)用同步的緩存或計(jì)算操作，這可能導(dǎo)致 線程池饑餓（pool starvation） 或 死鎖。
• 如需嵌套異步操作，可以使用 自定義線程池 來避免資源爭用。

總結(jié)表格

如果你是剛開始學(xué)習(xí) Ignite，理解這些基本緩存操作非常重要。它們是構(gòu)建分布式緩存應(yīng)用的基礎(chǔ)。對于更復(fù)雜的場景，如事務(wù)、查詢、索引等，請參考 Ignite 的高級功能文檔。

到此這篇關(guān)于Apache Ignite緩存基本操作的文章就介紹到這了,更多相關(guān)Apache Ignite緩存內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論