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>
结论
我希望有人能了解Hazelcast内部的分布式馆藏。 讨论了ISet,IList和IQueue。 ISet和IList仅保留在创建IQueue的副本时创建的实例上,并且可以保留,并且其容量随着实例数量的增加而增加。 该代码可以在这里看到。
参考文献
《榛子之书》: www.hazelcast.com
Hazelcast文档(hazelcast 下载随附)
翻译自: https://www.javacodegeeks.com/2014/10/beginners-guide-to-hazelcast-part-2.html
Hazelcast入门指南第2部分相关推荐
- Hazelcast入门指南第6部分
这是有关Hazelcast的一系列文章中的第六篇. 如果一个人没有看过过去的五年,请到表中的内容后 ,我创建赶上. 本地客户 在上一篇文章之后,我决定要去本地化. 是的,我将演示Hazelcast自己 ...
- Hazelcast入门指南第3部分
这是从初学者的角度来看一系列有关如何使用Hazelcast的文章的延续. 如果您还没有阅读最后两个,我鼓励您阅读它们: Hazelcast入门指南第1部分 Hazelcast入门指南第2部分 原始人来 ...
- Hazelcast入门指南第4部分
这是我的Hazelcast系列的第四部分. 如果一个人没有看到其他三个人,我建议一个人去看第1 部分 , 第2 部分和第3部分 . 记录中 日志记录是任何应用程序的重要功能,我的示例也是如此. Sys ...
- Hazelcast入门指南第7部分
这是解释如何使用Hazelcast的系列文章的续篇. 如果一个人没有阅读其他六个帖子,请转到目录并阅读其他帖子. 不同的地图种类 Hazelcast的MultiMap打破了以前使用java.util. ...
- Hazelcast入门指南第5部分
这是我撰写的有关Hazelcast的一系列文章的延续. 我强烈建议您阅读其他内容: 第1 部分 , 第2 部分 , 第3 部分和第4部分 . 让人一见倾心的东西? 这篇文章中将没有Hazelcast专 ...
- Hazelcast入门指南第1部分
介绍 我将在Hazelcast上做一个系列. 我从Twitter了解了该产品. 他们决定跟随我,经过对他们所做工作的研究后,我决定跟随他们. 我在推特上说,Hazelcast将是分布式密码破解者的重要 ...
- hazelcast入门教程_Hazelcast入门指南第6部分
hazelcast入门教程 这是有关Hazelcast的一系列文章中的第六篇. 如果一个人没有看过过去的五年,请到表中的内容后 ,我创建赶上. 本地客户 在上一篇文章之后,我决定要去本地化. 是的,我 ...
- hazelcast入门教程_Hazelcast入门指南第3部分
hazelcast入门教程 这是从初学者的角度来看一系列有关如何使用Hazelcast的文章的延续. 如果您还没有阅读最后两个,我鼓励阅读它们: Hazelcast入门指南第1部分 Hazelcast ...
- hazelcast入门教程_Hazelcast入门指南第4部分
hazelcast入门教程 这是我的Hazelcast系列的第四部分. 如果一个人没有看到其他三个人,我建议一个人去看第1 部分 , 第2 部分和第3部分 . 记录中 日志记录是任何应用程序的重要功能 ...
最新文章
- innodb表 手工导入导出
- WebBrowser!
- EC2上的ElasticSearch不到60秒
- cannot resolve symbol xxxx问题
- C# winform 按钮 响应鼠标经过变换图片,如何处理?
- Spark的操作列表
- php简历程序模板,PHP程序员工作简历模板下载word格式
- 数据权属界定面临的问题困境与破解思路
- FCC ES6篇中的解构赋值
- matlab求两向量夹角_MATLAB概率和统计(2)
- WIN8专业版安装SqlServer2008
- C primer plus编程练习答案(上)
- MySQL原理与实践(四):由数据库事务引出数据库隔离级别
- 最牛逼的心理学家是如何看待人生的
- 网易免费邮箱 - 中国第一大电子邮件服务商
- 790. 多米诺和托米诺平铺
- fifa11键盘按键_FIFA 20 Player集群
- 盲打打字php,讯飞输入法盲打键盘闪亮登场 是时候展示你真正的技术了
- C语言实现二进制与十进制的互转(带小数)
- HDU 4343 Interval query
热门文章
- Redis(案例一:注册登录-图形验证码+谷歌开源Kaptcha)
- ❤️ 爆肝一个月!JAVA零基础入门总结(上)❤️
- 如何实现下拉框的绑定
- Request获取参数封装方式
- java 读取 文本块_Java文本块
- idea 切换java11_Java 11就在这里,您准备好进行切换了吗?
- 关于高效企业测试的思考(1/6)
- java batch_Java EE 7 Batch中传递属性/参数的2种方式
- javaee编程题_在JavaEE中使用CDI的简单面向方面的编程(AOP)
- 在Java中将时间单位转换为持续时间