hazelcast入门教程_Hazelcast入门指南第7部分

hazelcast入门教程

这是解释如何使用Hazelcast的系列文章的续篇。 如果一个人没有阅读其他六个帖子，请转到目录并阅读其他帖子。

不同的地图种类

Hazelcast的MultiMap打破了以前使用java.util.Collection接口的常规方式。 实际上，我认为MultiMap的概念完全打破了地图的概念。 虽然法线贴图将一个键关联到一个值，但是MultiMaps可以将多个值映射到同一键 。 这是一个非常重要的概念，同一键有多个值。 值可以存储在两个不同的集合（集合或列表）中。 这些集合的行为类似于java.util.Collections库的集合。

安全吗？

MultiMap有一种疯狂的方法。 在法线映射中，每个键可以存储多个值，但是必须手动完成。 这意味着将集合从存储中取出，进行任何更改，然后将集合放回存储中。 对于线程安全而言，这可能是个问题，因为先前的步骤需要原子完成，否则其他线程可能会读取陈旧或不一致的数据。 MultiMaps通过提供以下服务来帮助解决此问题：

  • 可以通过一个put操作添加一个值。
  • 一个人可以用钥匙锁定一个条目。 这是关键（双关语），因为这意味着开发人员不必跟踪每个条目的单独锁。

例

这个示例有些不同，因为在运行示例时，我使用Maven的failsafe插件作为主要引擎。 是的，我写了两个示例，因为我想展示使用MultiMap的两种不同方式。 一种方法是，每个线程都拥有自己的游乐场，被分配一个唯一的密钥，或者被分配一个共享的游乐场，或者所有线程共享相同的密钥。 这也是如何将Hazelcast的IdGenerator用作在应用程序中创建线程安全性的方法的示例。

Pom文件

请记住，此示例代码利用了Apache的Failsafe Maven插件 。 故障安全插件通过在第一次失败时不终止构建来帮助进行自动集成测试。 它是surefire插件的分支。 我也一直在尝试使用Maven提供的报告。 在命令行中输入“ mvn site”，它将生成一个网站。 

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0><groupId>com.darylmathison><artifactId>hazelcast-multimap-example><version>1.0-SNAPSHOT><description>Examples of using Hazelcast Multimap><developers><developer><name>Daryl Mathison><id>dmathison><roles><role>developer>>>><scm><connection>scm:git:https://github.com/darylmathison/hazelcast-multimap-example.git><url>https://github.com/darylmathison/hazelcast-multimap-example>><properties><maven.compiler.source>1.8><maven.compiler.target>1.8><project.build.sourceEncoding>UTF-8>><dependencies><dependency><groupId>com.hazelcast><artifactId>hazelcast><version>3.4.2>><dependency><groupId>junit><artifactId>junit><version>4.12><scope>test>>><build><plugins><plugin><groupId>org.apache.maven.plugins><artifactId>maven-failsafe-plugin><version>2.18.1><executions><execution><goals><goal>integration-test><goal>verify>>>>>>><reporting><plugins><plugin><groupId>org.apache.maven.plugins><artifactId>maven-project-info-reports-plugin><version>2.7><reportSets><reportSet><reports><report>dependencies><report>index><report>project-team><report>scm>>>>><plugin><groupId>org.apache.maven.plugins><artifactId>maven-javadoc-plugin><version>2.10.3><reportSets><reportSet><reports><report>javadoc><report>test-javadoc>>>>><plugin><groupId>org.apache.maven.plugins><artifactId>maven-surefire-report-plugin><version>2.18.1>><plugin><groupId>org.apache.maven.plugins><artifactId>maven-jxr-plugin><version>2.5><configuration><linkJavadoc>true>><reportSets><reportSet><reports><report>jxr><report>test-jxr>>>>>>>
>

MultimapAccessThread

这是每个访问类型线程的基类。 

package com.darylmathison.multimap;import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.core.HazelcastInstanceAware;
import com.hazelcast.core.MultiMap;import java.io.Serializable;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;/*** Abstract class to access MultiMap.*/
public abstract class MultiMapAccessThread implements Serializable, Runnable, HazelcastInstanceAware {protected com.hazelcast.core.HazelcastInstance instance;protected MultiMap<Long, Long> map;protected String mapName;protected Lock l = new ReentrantLock();public void setHazelcastInstance(HazelcastInstance instance) {l.lock();try {this.instance = instance;if (mapName != null && !mapName.isEmpty()) {map = instance.getMultiMap(mapName);}} finally {l.unlock();}}public String getMapName() {return mapName;}public void setMapName(String mapName) {l.lock();try {this.mapName = mapName;} finally {l.unlock();}}
}

IdMultiMapAccessThread 

package com.darylmathison.multimap;/*** This thread accesses only one "slot" in a multimap.*/
public class IdMultiMapAccessThread extends MultiMapAccessThread {private Long id;@Overridepublic void run() {l.lock();boolean shouldRun = (map != null && id != null);l.unlock();if(shouldRun) {for (long i = 0; i < 10; i++) {map.put(id, i);}}}public Long getId() {return id;}public void setId(Long id) {this.id = id;}
}

GroupMultiMapAccessThread 

package com.darylmathison.multimap;/*** Thread designed to share the same "slot" on a MultiMap.*/
public class GroupMultiMapAccessThread extends MultiMapAccessThread {private static final long MAX = 10;private Long groupId;/*** When an object implementing interface Runnable is used* to create a thread, starting the thread causes the object's* run method to be called in that separately executing* thread.*
* The general contract of the method run is that it may* take any action whatsoever.** @see Thread#run()*/@Overridepublic void run() {l.lock();boolean shouldRun = (groupId != null && map != null);l.unlock();if(shouldRun) {map.lock(groupId);try {if (map.get(groupId).isEmpty()) {System.out.println("adding to list");for (long i = 0; i < MAX; i++) {map.put(groupId, i);}} else {System.out.println("nothing to add");}} finally {map.unlock(groupId);}}}public void setGroupId(Long groupId) {l.lock();this.groupId = groupId;l.unlock();}
}

HazelcastInstanceResource

此规则启动并关闭运行线程所需的Hazelcast实例。 

package com.darylmathison.multimap.test.rule;import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.core.IExecutorService;
import org.junit.rules.ExternalResource;/*** Created by Daryl on 4/27/2015.*/
public class HazelcastInstanceResource extends ExternalResource {public static final String SERVICE_NAME = "Charlotte";HazelcastInstance instance;IExecutorService service;@Overrideprotected void before() throws Throwable {super.before();instance = Hazelcast.newHazelcastInstance();service = instance.getExecutorService(SERVICE_NAME);}@Overrideprotected void after() {super.after();service.shutdown();instance.shutdown();}public HazelcastInstance getInstance() {return instance;}public IExecutorService getService() {return service;}
}

IdMultiMapAccessIT

这是一个使用IdGenerator为线程放置数据的新“操场”或键的示例。 

package com.darylmathison.multimap;import com.darylmathison.multimap.test.rule.HazelcastInstanceResource;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.core.IExecutorService;
import com.hazelcast.core.IdGenerator;
import org.junit.ClassRule;
import org.junit.Test;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;/*** Integration test for IdMultiMapAccessThread*/
public class IdMultiMapAccessThreadIT {public static final String MAP_NAME = "idAccessMap";public static final String GEN_NAME = "singleAccess";public static final int NUM_THREADS = 10;@ClassRulepublic static HazelcastInstanceResource hazelcastInstanceResource = new HazelcastInstanceResource();@Testpublic void testIdThreads() {List threads = generateThreads(hazelcastInstanceResource.getInstance());List<Future<?>> futures = new ArrayList<>(NUM_THREADS);IExecutorService spinner = hazelcastInstanceResource.getService();for(IdMultiMapAccessThread thread: threads) {futures.add(spinner.submit(thread));}for(Future<?> future: futures) {try {future.get();} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}}}private List generateThreads(HazelcastInstance instance) {IdGenerator gen = instance.getIdGenerator(GEN_NAME);List threads = new ArrayList<>(NUM_THREADS);for(int i = 0; i < NUM_THREADS; i++) {IdMultiMapAccessThread thread = new IdMultiMapAccessThread();thread.setMapName(MAP_NAME);thread.setId(gen.newId());threads.add(thread);}return threads;}
}

GroupMultiMapAccessThreadIT

这是使用IdGenerator创建共享游乐场或插槽的示例。 

package com.darylmathison.multimap;import com.darylmathison.multimap.test.rule.HazelcastInstanceResource;
import com.hazelcast.core.IExecutorService;
import com.hazelcast.core.IdGenerator;
import org.junit.ClassRule;
import org.junit.Test;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;/*** GroupMultiMapAccessThread Integration Test*/
public class GroupMultiMapAccessThreadIT {public static final int NUM_THREADS = 10;public static final String GEN_NAME = "groupIdGenerator";public static final String MAP_NAME = "groupMap";@ClassRulepublic static HazelcastInstanceResource hazelcastInstanceResource = new HazelcastInstanceResource();@Testpublic void testGroupMultiMapAccessThread() {List threads = createThreads();IExecutorService service = hazelcastInstanceResource.getService();List<Future<?>> futures = new ArrayList<>(NUM_THREADS);for(GroupMultiMapAccessThread thread: threads) {futures.add(service.submit(thread));}for(Future<?> future: futures) {try {future.get();} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}}}private List createThreads() {List ret = new ArrayList<>(NUM_THREADS);IdGenerator gen = hazelcastInstanceResource.getInstance().getIdGenerator(GEN_NAME);Long groupId = gen.newId();for(int i = 0; i < NUM_THREADS; i++) {GroupMultiMapAccessThread thread = new GroupMultiMapAccessThread();thread.setMapName(MAP_NAME);thread.setGroupId(groupId);ret.add(thread);}return ret;}
}

结论

在这篇文章中，对Hazelcast的MultiMap进行了分析。 结果表明，MultiMaps可以为给定键存储多个值。 还显示了线程如何使用IdGenerator作为可能的密钥生成器来共享MultiMap中的数据或如何为其自身存储数据。 该代码可以在GitHub上找到 。

参考资料

  • http://www.hazelcast.com
  • http://www.hazelcast.org
  • https://github.com/hazelcast/hazelcast

翻译自: https://www.javacodegeeks.com/2015/04/beginners-guide-to-hazelcast-part-7.html

hazelcast入门教程

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/337952.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

python xlrd读取文件报错_python中xlrd库如何实现文件读取？

python xlrd读取文件报错_python中xlrd库如何实现文件读取？

俗话说得好&#xff0c;技多不压身&#xff0c;虽然我们已经掌握了多种可以实现读取文件的方式&#xff0c;但是丝毫不影响我们要学会精益求精&#xff0c;他说学习文件读取的奥秘&#xff0c;况且&#xff0c;数据分析是十分重要的&#xff0c;一切的代码运行&#xff0c;总归…
阅读更多...
c语言 %x,%d,%c,%s,%x各代表什么

c语言 %x,%d,%c,%s,%x各代表什么

点击上方蓝字关注我&#xff0c;了解更多咨询转换说明符%a(%A) 浮点数、十六进制数字和p-(P-)记数法(C99)%c 字符%d 有符号十进制整数%f 浮点数(包括float和doulbe)%e(%E) 浮点数指数输出[e-(E-)记数法]%g(%G) 浮点数不显无意义的零”0″%i 有符号十进制整数(与%d相同)%u 无符号…
阅读更多...
apache mesos_Apache Mesos + Marathon和Java EE

apache mesos_Apache Mesos + Marathon和Java EE

apache mesosApache Mesos是一个开放源代码群集管理器&#xff0c;可在分布式应用程序或框架之间提供有效的资源隔离和共享。 Apache Mesos从计算机&#xff08;物理或虚拟&#xff09;中提取CPU&#xff0c;内存&#xff0c;存储和其他计算资源&#xff0c;从而使容错和弹性的…
阅读更多...
C语言表达式用法快来看看

C语言表达式用法快来看看

点击上方蓝字关注我&#xff0c;了解更多咨询表达式是C语言的主体。在C语言中&#xff0c;表达式由操作符和操作数组成。最简单的表达式可以只含有一个操作数。根据表达式所含操作符的个数&#xff0c;可以把表达式分为简单表达式和复杂表达式两种&#xff0c;简单表达式是只含…
阅读更多...
虚拟机间延迟测量_简单的类来测量延迟

虚拟机间延迟测量_简单的类来测量延迟

虚拟机间延迟测量这是我编写的用于测量延迟的非常简单的类。 HDRHistogram不是劳斯莱斯解决方案&#xff0c;但是如果您只想在项目中添加一个类&#xff0c;那么效果就很好。 这是一个简单的测试程序&#xff0c;向您展示其用法&#xff1a; package util;public class Laten…
阅读更多...
python导入模块报错_Python 导入上层目录模块报错

python导入模块报错_Python 导入上层目录模块报错

背景&#xff1a;当前demo.py 文件&#xff0c;所处目录 D:\py\test\TestCase&#xff0c;需要调用test 目录下的模块&#xff0c;尝试了 新建__init__.py 文件 import test.模块名的方法&#xff0c;无效.报错信息&#xff1a;D:\py\test\TestCase>python demo.pyTraceback…
阅读更多...
java int 传引用吗_Java的参数传递是「值传递」还是「引用传递」？

java int 传引用吗_Java的参数传递是「值传递」还是「引用传递」？

关于Java传参时是引用传递还是值传递&#xff0c;一直是一个讨论比较多的话题。有人说Java中只有值传递&#xff0c;也有人说值传递和引用传递都是存在的&#xff0c;比较容易让人产生疑问。关于值传递和引用传递其实需要分情况看待。一、Java数据类型我们都知道&#xff0c;Ja…
阅读更多...
rest接口自动化测试_REST服务的自动化测试

rest接口自动化测试_REST服务的自动化测试

rest接口自动化测试尽管我是Java和Scala开发人员&#xff0c;但我仍然对软件测试充满热情。 如果更精确-Web应用程序。 开发Web应用程序并确保应用程序具有良好的质量真的很有趣。 当我开始职业生涯时&#xff0c;最流行的Web架构是MVC&#xff08;模型视图控件&#xff09;&a…
阅读更多...
C语言中变量的存储类别

C语言中变量的存储类别

点击上方蓝字关注我&#xff0c;了解更多咨询在程序中经常会使用到变量&#xff0c;在C程序中可以选择变量的不同存储形式&#xff0c;其存储类别分为静态存储和动态存储。可以通过存储类修饰符来告诉编译器要处理什么样的类型变量&#xff0c;具体主要有自动&#xff08;auto&…
阅读更多...
javafx 项目_JavaFX，Jigsaw项目和JEP 253

javafx 项目_JavaFX，Jigsaw项目和JEP 253

javafx 项目因此&#xff0c; Java 9可能会破坏您的代码 …… 如果您的项目使用JavaFX&#xff0c;则这尤其可能&#xff0c;因为许多自定义和自制控件都需要使用内部API。 借助Project Jigsaw&#xff0c;这些内容将无法在Java 9中访问。幸运的是&#xff0c; Oracle在几天前…
阅读更多...
C语言结构体用法很多，坑也很多

C语言结构体用法很多，坑也很多

点击上方蓝字关注我&#xff0c;了解更多咨询还在使用89年版C语言的Linux内核&#xff0c;现在终于要做出改变了。今天&#xff0c;Linux开源社区宣布&#xff0c;未来会把内核C语言版本升级到C11&#xff0c;预计5.18版之后生效&#xff0c;也就是今年5月。这个决定很突然&…
阅读更多...
java 消息队列服务_ActiveMQ 消息队列服务

java 消息队列服务_ActiveMQ 消息队列服务

1 ActiveMQ简介1.1 ActiveMQ是什么ActiveMQ是一个消息队列应用服务器(推送服务器)。支持JMS规范。1.1.1 JMS概述全称&#xff1a;Java Message Service &#xff0c;即为Java消息服务&#xff0c;是一套java消息服务的API标准。(标准即接口)实现了JMS标准的系统&#xff0c;称之…
阅读更多...
第一个C语言编译器是怎样编写的？

第一个C语言编译器是怎样编写的？

点击上方蓝字关注我&#xff0c;了解更多咨询以我们嵌入式开发中经常使用的C语言为例&#xff0c;我们来介绍一下第一个C语言编译器的来源。还是让我们回顾一下C语言历史&#xff1a;1970年Tomphson和Ritchie在BCPL&#xff08;一种解释型语言&#xff09;的基础上开发了B语言&…
阅读更多...
java循坏_Java的坏功能是什么

java循坏_Java的坏功能是什么

java循坏总览 当您第一次学习开发时&#xff0c;您会看到关于不同功能的过分笼统的陈述&#xff0c;它们对于设计&#xff0c;性能&#xff0c;清晰度&#xff0c;可维护性都是不好的&#xff0c;感觉就像是黑客&#xff0c;或者他们只是不喜欢它。 这可能会得到现实世界经验的…
阅读更多...
java 内存 开发 经验_有一到五年开发经验的JAVA程序员需要掌握的知识与技能！...

java 内存 开发 经验_有一到五年开发经验的JAVA程序员需要掌握的知识与技能！...

JAVA是一种平台&#xff0c;也是一种程序设计语言&#xff0c;如何学好程序设计不仅仅适用于JAVA&#xff0c;对C等其他程序设计语言也一样管用。有编程高手认为&#xff0c;JAVA也好C也好没什么分别&#xff0c;拿来就用。为什么他们能达到如此境界&#xff1f;我想是因为编程…
阅读更多...
C语言fgets()函数：以字符串形式读取文件

C语言fgets()函数：以字符串形式读取文件

点击上方蓝字关注我&#xff0c;了解更多咨询C语言 fgets() 函数从文本文件中读取一个字符串&#xff0c;并将其保存到内存变量中。fgets() 函数位于 <stdio.h> 头文件中&#xff0c;其使用格式如下&#xff1a;fgets(字符串指针,字符个数n,文件指针);格式说明&#xff1…
阅读更多...
js文件 import java类_实现JS脚本导入JAVA类包

js文件 import java类_实现JS脚本导入JAVA类包

本例演示怎样通过JS脚本导入JAVA类包&#xff0c;我们创建JS引擎后&#xff0c;通过eval方法调用 getScript() ,JS脚本中importPackage(java.util)为导入包。package ajava.code.javase;import javax.script.ScriptEngineManager;import javax.script.ScriptEngine;import java…
阅读更多...
摆脱冷气_摆脱匿名类

摆脱冷气_摆脱匿名类

摆脱冷气我真的很喜欢编写和阅读lambda表达式-它们简洁&#xff0c;富于表现力和时尚&#xff08;来吧&#xff0c;这样就没关系了&#xff01;&#xff09;。 将此与匿名类进行比较。 这就是为什么我喜欢摆脱它们&#xff01; 在过去的几个月里&#xff0c;这种认识慢慢地实现…
阅读更多...
深入了解C语言

深入了解C语言

点击上方蓝字关注我&#xff0c;了解更多咨询c语言在编程语言中是偏底层的语言&#xff0c;像JavaScript&#xff0c;以及java。都是在c语言的基础上编译出来的。像操作系统&#xff1a;unix &#xff0c;linux &#xff0c;windows都是依靠c语言开发出来的&#xff0c;使用c语…
阅读更多...
java imageview的使用_Android使用控件ImageView加载图片的方法

java imageview的使用_Android使用控件ImageView加载图片的方法

在 Android 加载图片一般使用 ImageView&#xff0c;这里简单记录一下这个控件的使用方法。最简单就是在 xml 里直接使用 ImageView 标签&#xff1a;android:orientation"vertical"android:layout_width"fill_parent"android:layout_height"fill_par…
阅读更多...
最新文章

Copyright @ 2022~2023