Hazelcast - IList



java.util.List 提供了一個介面,用於儲存物件集合,這些物件不一定需要是唯一的。元素的順序無關緊要。

類似地,IList 實現了一個 Java List 的分散式版本。它提供了類似的功能:add、forEach 等。

IList 中存在的所有資料都儲存/存在於單個 JVM 上。所有 JVM 仍然可以訪問資料,但列表無法擴充套件到單個機器/JVM 之外。

該列表支援同步備份和非同步備份。同步備份確保即使儲存列表的 JVM 出現故障,所有元素也將被保留並可從備份中獲取。

讓我們來看一個有用函式的示例。

新增元素和讀取元素

讓我們在 2 個 JVM 上執行以下程式碼。一個 JVM 上執行生產者程式碼,另一個 JVM 上執行消費者程式碼。

示例

第一部分是生產者程式碼,它建立一個列表並向其中新增專案。

public static void main(String... args) throws IOException, InterruptedException {
   //initialize hazelcast instance
   HazelcastInstance hazelcast = Hazelcast.newHazelcastInstance();
   // create a list
   IList<String> hzFruits = hazelcast.getList("fruits");
   hzFruits.add("Mango");
   hzFruits.add("Apple");
   hzFruits.add("Banana");

   // adding an existing fruit
   System.out.println(hzFruits.add("Apple"));
   System.out.println("Size of list:" + hzFruits.size());
   System.exit(0);
}

第二部分是消費者程式碼,它讀取列表元素。

public static void main(String... args) throws IOException, InterruptedException {
   //initialize hazelcast instance
   HazelcastInstance hazelcast = Hazelcast.newHazelcastInstance();
   // create a list
   IList<String> hzFruits = hazelcast.getList("fruits");
   Thread.sleep(2000);
   hzFruits.forEach(System.out::println);
   System.exit(0);
}

輸出

生產者程式碼的輸出顯示它無法新增現有元素。

true
4

消費者程式碼的輸出列印列表大小,水果按預期順序排列。

4
Mango
Apple
Banana
Apple

有用方法

序號 函式名稱 & 描述
1

add(Type element)

將元素新增到列表中

2

remove(Type element)

從列表中移除元素

3

size()

返回列表中元素的數量

4

contains(Type element)

返回元素是否存在

5

getPartitionKey()

返回儲存列表的分割槽鍵

6

addItemListener(ItemListener<Type>listener, value)

通知訂閱者列表中元素被移除/新增/修改。

hazelcast_data_structures.htm
廣告