Hazelcast入门指南第2部分

本文是我开始以Hazelcast （分布式内存数据库）为特色的系列文章的继续。如果尚未阅读第一篇文章，请单击此处。

分布式馆藏

Hazelcast具有许多可用于存储数据的分布式集合。以下是它们的列表：

清单
我设置
队列

清单

IList是一个集合，它保持放入内容的顺序，并且可以重复。实际上，它实现了java.util.List接口。这不是线程安全的，必须使用某种互斥或锁定来控制许多线程的访问。我建议Hazelcast的ILock。

我设置

ISet是一个集合， 它不会保持放置在其中的项目的顺序。但是，这些元素是独特的。此集合实现java.util.Set接口。与ILists一样，此集合也不是线程安全的。我建议再次使用ILock。

队列

IQueue是一个集合，用于保持进来顺序并允许重复项。它实现了java.util.concurrent.BlockingQueue，因此是线程安全的。这是集合中扩展性最强的，因为其容量随着实例数量的增加而增加。例如，假设一个队列限制为10个项目。一旦队列已满，除非再有另一个Hazelcast实例出现，否则将无法再进入那里，那么还有10个可用空间。还制作了队列的副本。 IQueues也可以通过实现QueueStore接口来持久化。

他们有什么共同点

它们三个都实现了ICollection接口。这意味着可以向其中添加一个ItemListener。这可以让您知道何时添加或删除项目。在“示例”部分中提供了一个示例。

可伸缩性

随着可伸缩性的发展，在Hazelcast 3.x中，ISet和IList的性能不佳。这是因为实现已从基于地图变为在MultiMap中成为集合。这意味着它们不会分区，也不会超出一台计算机。剥离馆藏可以走很长一段路，也可以基于强大的IMap自己制造馆藏。另一种方法是实现Hazelcast的spi。

例子

这是ISet，IList和IQueue的示例。他们三个都有一个ItemListener。 ItemListener已添加到hazelcast.xml配置文件中。人们还可以通过编程方式为那些倾斜的人添加一个ItemListener。将显示一个主类和配置该集合的配置文件片段。

CollectionItemListener

我实现了ItemListener接口，以显示所有三个集合都可以具有ItemListener。这是实现：

package hazelcastcollections;import com.hazelcast.core.ItemEvent;
import com.hazelcast.core.ItemListener;/**
*
* @author Daryl
*/
public class CollectionItemListener implements ItemListener {@Override
public void itemAdded(ItemEvent ie) {
System.out.println(“ItemListener – itemAdded: ” + ie.getItem());
}@Override
public void itemRemoved(ItemEvent ie) {
System.out.println(“ItemListener – itemRemoved: ” + ie.getItem());
}}

我设置

码

package hazelcastcollections.iset;import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.core.ISet;/**
*
* @author Daryl
*/
public class HazelcastISet {/**
* @param args the command line arguments
*/
public static void main(String[] args) {
HazelcastInstance instance = Hazelcast.newHazelcastInstance();
HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();
ISet<String> set = instance.getSet(“set”);
set.add(“Once”);
set.add(“upon”);
set.add(“a”);
set.add(“time”);ISet<String> set2 = instance2.getSet(“set”);
for(String s: set2) {
System.out.println(s);
}System.exit(0);
}}

组态

<set name=”set”>
<item-listeners>
<item-listener include-value=”true”>hazelcastcollections.CollectionItemListener</item-listener>
</item-listeners>
</set>

清单

码

package hazelcastcollections.ilist;import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.core.IList;/**
*
* @author Daryl
*/
public class HazelcastIlist {/**
* @param args the command line arguments
*/
public static void main(String[] args) {
HazelcastInstance instance = Hazelcast.newHazelcastInstance();
HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();
IList<String> list = instance.getList(“list”);
list.add(“Once”);
list.add(“upon”);
list.add(“a”);
list.add(“time”);IList<String> list2 = instance2.getList(“list”);
for(String s: list2) {
System.out.println(s);
}
System.exit(0);
}}

组态

<list name=”list”>
<item-listeners>
<item-listener include-value=”true”>hazelcastcollections.CollectionItemListener</item-listener>
</item-listeners>
</list>

队列

码

我将这一点留在了最后，因为我还实现了一个QueueStore。 IQueue上没有调用来添加QueueStore。 必须在hazelcast.xml文件中对其进行配置。

package hazelcastcollections.iqueue;import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.core.IQueue;/**
*
* @author Daryl
*/
public class HazelcastIQueue {/**
* @param args the command line arguments
*/
public static void main(String[] args) {
HazelcastInstance instance = Hazelcast.newHazelcastInstance();
HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();
IQueue<String> queue = instance.getQueue(“queue”);
queue.add(“Once”);
queue.add(“upon”);
queue.add(“a”);
queue.add(“time”);IQueue<String> queue2 = instance2.getQueue(“queue”);
for(String s: queue2) {
System.out.println(s);
}System.exit(0);
}}

队列存储代码

package hazelcastcollections.iqueue;import com.hazelcast.core.QueueStore;
import java.util.Collection;
import java.util.Map;
import java.util.Set;
import java.util.TreeMap;
import java.util.TreeSet;
/**
*
* @author Daryl
*/
public class QueueQStore implements QueueStore<String> {@Override
public void store(Long l, String t) {
System.out.println(“storing ” + t + ” with ” + l);
}@Override
public void storeAll(Map<Long, String> map) {
System.out.println(“store all”);
}@Override
public void delete(Long l) {
System.out.println(“removing ” + l);
}@Override
public void deleteAll(Collection<Long> clctn) {
System.out.println(“deleteAll”);
}@Override
public String load(Long l) {
System.out.println(“loading ” + l);
return “”;
}@Override
public Map<Long, String> loadAll(Collection<Long> clctn) {
System.out.println(“loadAll”);
Map<Long, String> retMap = new TreeMap<>();
return retMap;
}@Override
public Set<Long> loadAllKeys() {
System.out.println(“loadAllKeys”);
return new TreeSet<>();
}}

组态

在配置QueueStore时需要解决一些提及。有三个属性没有传递给实现。二进制属性处理Hazelcast如何将数据发送到商店。通常，Hazelcast将序列化的数据存储并反序列化，然后再发送到QueueStore。如果该属性为true，则将数据序列化发送。默认为false。内存限制是在放入QueueStore之前在内存中保留多少个条目。 10000个内存限制意味着将第10001个发送到QueueStore。在初始化IQueue时，正在从QueueStore加载条目。 bulk-load属性是一次可以从QueueStore中拉出多少个。

<queue name=”queue”>
<max-size>10</max-size>
<item-listeners>
<item-listener include-value=”true”>hazelcastcollections.CollectionItemListener</item-listener>
</item-listeners>
<queue-store>
<class-name>hazelcastcollections.iqueue.QueueQStore</class-name>
<properties>
<property name=”binary”>false</property>
<property name=”memory-limit”>10000</property>
<property name=”bulk-load”>500</property>
</properties>
</queue-store>
</queue>