Hazelcast.xml 配置文件说明

时间 2019-11-12

标签 hazelcast.xml hazelcast xml 配置文件说明栏目 XML 繁體版

原文原文链接

配置html

Hazelcast的使用能够经过XML配置和编程来实现，或者是二者共同配合使用来完成其功能；java

1-配置声明node

若是你建立Hazelcast实例的时候，不传递参数给Hazelcast的话（即：newHazelcastInstance(null)）或者使用空的工厂方法(Hazelcast.newHazelcastInstance) 来建立，Hazelcast将会本身自动的检查两个地方来寻找Hazelcast的配置文件：mysql

§ 系统属性：Hazelcast 首先会检查是否”hazelcast.config”系统属性被设置到某个配置文件下。例如：git

-Dhazelcast.config=C:/myhazelcast.xmlweb

§ Classpath:若是配置文件配置成系统属性，Hazelcast将会继续检查classpath 来寻找hazelcast.xml文件。算法

若是Hazelcast 没有找到任何配置文件，它将很乐意的使用默认的配置文件(hazelcast-default.xml),它在hazelcast.jar包下。（在配置 Hazelcast以前，建议您使用默认的配置文件来看看是否Hazelcast能正常的工做。默认的配置文件对于大部分的开发者来讲已是很好的了。如果您不想这样，那么就考虑为您的环境亲自配置一份吧）。spring

若是您想指定本身的配置文件来建立配置的话，Hazelcast提供了几种方式来供您选择,包括-filesystem,classpath,InputStream,URL等等：sql

§ Config cfg = new XmlConfigBuilder(xmlFileName).build();数据库

§ Config cfg = new XmlConfigBuilder(inputStream).build();

§ Config cfg = new ClasspathXmlConfig(xmlFileName);

§ Config cfg = new FileSystemXmlConfig(configFilename);

§ Config cfg = new UrlXmlConfig(url);

§ Config cfg = new InMemoryXmlConfig(xml);

2- 可编程配置

根据您的需求，初始化Config对象设置/修改属性，完成编程式的配置Hazelcast。

Config config =new Config();

config.getNetworkConfig().setPort(5900 );

config.getNetworkConfig().setPortAutoIncrement(false );

NetworkConfig network = config.getNetworkConfig();

JoinConfig join = network.getJoin();

join.getMulticastConfig().setEnabled( false );

join.getTcpIpConfig().addMember( "10.45.67.32").addMember( "10.45.67.100" ) .setRequiredMember("192.168.10.100" ).setEnabled( true );

network.getInterfaces().setEnabled( true ).addInterface("10.45.67.*" );

MapConfig mapConfig = new MapConfig();

mapConfig.setName( "testMap" );

mapConfig.setBackupCount( 2 );

mapConfig.getMaxSizeConfig().setSize( 10000 );

mapConfig.setTimeToLiveSeconds( 300 );

MapStoreConfig mapStoreConfig = new MapStoreConfig();

mapStoreConfig.setClassName("com.hazelcast.examples.DummyStore" )

.setEnabled(true );

mapConfig.setMapStoreConfig( mapStoreConfig );

NearCacheConfig nearCacheConfig = new NearCacheConfig();

nearCacheConfig.setMaxSize( 1000 ).setMaxIdleSeconds( 120)

.setTimeToLiveSeconds( 300 );

mapConfig.setNearCacheConfig( nearCacheConfig );

config.addMapConfig( mapConfig );

而后建立Config对象，你就能够用这个对象来建立Hazelcast实例。

HazelcastInstance hazelcast = Hazelcast.newHazelcastInstance( config );
建立一个名为HazelcastInstance对象，将config对象传给它。

Config config = new Config();

config.setInstanceName( "my-instance" );

Hazelcast.newHazelcastInstance( config );

· 用它的名字来取得一个已经存在的HazelcastInstance;

Hazelcast.getHazelcastInstanceByName("my-instance" );

· 用它的名字来取得全部已经存在的HazelcastInstance;

Hazelcast.getAllHazelcastInstances();

使用通配符

Hazelcast支持为全部分布式数据结构的通配符配置，它可使用Config来配置（但除了 IatomicLong,IatomicReference）。在不一样的map,queues,topics,semaphores实例等名字中使用星号（*）简单的配置。

注意，这种简单的用法，星号（*）能够放在配置中的任何位置。

好比：一个名叫‘com.hazelcast.test.mymap’的map可使用如下的几种配置方式：

...

</map>

...

</map>

...

</map>

...

</map>

或者一个queue ‘com.hazelcast.test.myqueue’;

...

</queue>

...

</queue>

网络配置

配置TCP/IP集群

若是你的环境中多播不是首选的话，那么你能够配置Hazelcast完整集群。像下面的配置显示那样，当多播属性被设置成false时，tcp-ip就不得不设置为true。

对于一个没有多播选择的环境，全部或者主机和IP节点必须列出。注意，全部的集群节点必须列出来，可是至少有一个是活动的当有一个新的节点进来时。

...

<portauto-increment="true">5701</port>

<join>

<multicastenabled="false">

<multicast-group>224.2.2.3</multicast-group>

<multicast-port>54327</multicast-port>

</multicast>

<tcp-ipenabled="true">

<member>machine1</member>

<member>machine2</member>

<member>machine3:5799</member>

</tcp-ip>

</join>

...

</network>

...

</hazelcast>

鉴于它须要被看到，IP地址和主机名能够做为节点的标签。你还能够给出一个IP范围，例如：192.168.1.0-7.

为了避免一行一行的配置，你可使用逗号做为标签，写在IP之间，以下所示：

若是节点的端口不支持，Hazelcast能够自动的尝试5701,5702等端口。

Hazelcast默认状况下，会自动的绑定本网络接口的全部通讯数据流。固然，这也能够经过系统属性来改变。

Hazelcast.socket.bind.any。当这个属性值被设置为false时，Hazelcast使用接口之间的特定接口(请参考 Specifying Network Interfaces 章节)。若是没有接口提供，那它会试着解析任何一个绑定的端口，在这个节点标签上让步。

Tcp-ip标签接收一个叫connection-timeout-seconds的属性，它的默认值是 5。推荐您增长这个值，若是你有许多IP列表的话，而且当节点不能很好的建立集群的话。

还有一个标签，required-member,用来识别特定的节点，须要设置在一个集群前面。

...

<join>

<tcp-ipenabled="true">

<required-member>192.168.1.21</required-member>

<member>machine2</member>

<member>machine3:5799</member>

</tcp-ip>

</join>

...

</network>

...

</hazelcast>

在这个例子中，这个集群不会生效，除非节点的IP 192.168.1.21 是有效的。

指定网络接口

你能够指定Hazelcast使用哪一个你指派的接口。服务器大部分都有超过一个的网络接口，因此你须要列出有效的全部IP。能够简易的使用 ‘*’ 和 ‘-’。例如 10.3.10.* ,能够替代10.3.10.0-10.3.10.255 .接口是 10.3.10.4-18(4,18也包括)。若是网络接口是配置为容许的（默认不容许），而且Hazelcast不能找到匹配的接口，那么它将会在控制台打印出一条信息，在那个节点上不能启动。

...

...

<interfacesenabled="true">

</interfaces>

</network>

...

</hazelcast>

EC2(弹性计算云) 自动发现

Hazelcast 支持EC2自动发现机制，这当你不想或是不能提供可能的IP地址时，会是颇有用的东西。能够你的集群配置成可以使用EC2自发发现功能，禁用加入多播和TCP / IP和启用AWS。还能够给你提供认信息（权限和秘钥）。

这须要你将hazelcast-cloud.jar添加到你的项目依赖中。注意，这个jar包被绑定到了hazelcast-all.jar包中。Hazelcast 不依赖其余任何第三方插件。

下面是一个配置样本：

<join>

<multicast-group>224.2.2.3</multicast-group>

<multicast-port>54327</multicast-port>

</multicast>

<tcp-ip enabled="false">

</tcp-ip>

<access-key>my-access-key</access-key>

<secret-key>my-secret-key</secret-key>

<!—默认是ec2.amazonaws.com，若是你要设置的话，请不要覆盖此属性-->

<host-header>ec2.amazonaws.com</host-header>

<security-group-name>hazelcast-sg</security-group-name>

<tag-key>type</tag-key>

<tag-value>hz-nodes</tag-value>

</aws>

</join>

标签aws 的属性值是一个叫作 connection-timeout-seconds 的属性，默认是5（s）。若是你有许多IP和而且节点不能很好适应集群的话，是能够增长这个值的。

Region参数指定了哪一个节点的机器是运行的。默认值是 us-east-1。若是集群在不一样的地方运行，必须指定地点。不然，集群将会不稳定，由于他们不能互相发现对方。

Tag-key 和 tag-value 参数提供不一样的key和value值，让你能够在同一个数据中心建立多个集群。

Securit-group-name 参数还能够用来过滤/组合节点。

注意：若是你采用了云的方式，而不是AWS，你可使用程序化的集群配置指定一个TCP / IP。节点须要从提供方那从新获取。

AWSClient:

确保EC2已经正确建立了，这时候AWSClient就可以使用了。它为EC2链接提供私有的IP地址。只要给它提供参数值，并在aws标签中指定便可。以下所示，你public static void main( String[] args )throws Exception{

AwsConfig config = new AwsConfig();

config.setSecretKey( ... ) ;

config.setSecretKey( ... );

config.setRegion( ... );

config.setSecurityGroupName( ... );

config.setTagKey( ... );

config.setTagValue( ... );

config.setEnabled("true");

AWSClient client = new AWSClient( config );

List<String> ipAddresses = client.getPrivateIpAddresses();

System.out.println( "addressesfound:" + ipAddresses );

for ( String ip: ipAddresses ) {

System.out.println( ip );

}

}能够知道你的EC2是否已经创建。

调试：

在须要的时候，Hazelcast会记录下在一个域的事件日志，改变日志等级为FINEST或DEBUG查看当集群的时候，活动节点发生了什么。以后，你还能够查看是否实例被接收了或是被拒绝，致使的缘由在日志文件中。注意，改变日志等级，也许会影响集群的效果。

相关信息

你能够从Hazelcast.com上下载Hazelcast on AWS: Best Practices for Deployment 白皮书。

端口

你能够为集群中的节点之间指定通讯端口。端口默认是 5701.

</network>

默认状况下，Hazelcast将会试着绑定100个端口，也就是说，若是你将端口设置为了5701，当有新节点进来的时候，Hazelcast会自动查找在5701-5801之间的节点。

若是在你的集群中节点过多，或是过少的话，你能够改变这种端口数参数 port-count，默认就是100.

<portport-count="20">5781</port>

</network>

根据上面的配置，Hazelcast会寻找从5781到5801的空闲端口。正常状况下，你不要去改变这个值，当须要的时候，也很方便设置。也许还有一种状况，你只须要使用一个端口，那么你能够取消自动增长查找使用auto-increment功能。以下所示：

<portauto-increment="false">5701</port>

</network>

固然，这种状况下，port-count参数会被忽略掉。

外部端口

默认状况下，Hazelcast容许系统在Socket操做时，打开一个临时端口。可是安全策略和防火墙也许会严格控制外部端口的访问。为了解决这个问题，你能够配置Hazelcast来配置自定义的外部端口。

...

<portauto-increment="true">5701</port>

<outbound-ports>

</outbound-ports>

...

</network>

...

</hazelcast>

或者以编程的方式:

...

NetworkConfig networkConfig = config.getNetworkConfig();

// ports between 35000 and 35100

networkConfig.addOutboundPortDefinition("35000-35100");

// comma separated ports

networkConfig.addOutboundPortDefinition("36001,36002, 36003");

networkConfig.addOutboundPort(37000);

networkConfig.addOutboundPort(37001);

...

注意：你能够定义一个端口范围或是用逗号来隔开各个端口。

IPv6 支持

Hazelcast很好的支持Ipv6（默认是被关闭的）。详细请看本章节最后部分。

你所要作的就是定义IPv6地址或网络配置中的接口配置。此刻仅有的限制是,你不能在tcp - ip链接配置中定义IPv6地址通配符。接口的话，没有这个限制，你能够像在IPv4中那样定义通配符。

...

<portauto-increment="true">5701</port>

<join>

<multicastenabled="false">

<multicast-group>FF02:0:0:0:0:0:0:1</multicast-group>

<multicast-port>54327</multicast-port>

</multicast>

<tcp-ipenabled="true">

</tcp-ip>

</join>

<interfacesenabled="true">

</interfaces>

...

</network>

...

</hazelcast>

JVM就像inet4和inet6同样，有两个系统属性来配置IPv4 和 IPv6。在一个双协议栈中，IPv6是默认首选的。这也能够经过Java .NET.preferIPv4Stack=& lt;true|false>系统属性配置。当查询服务名的时候，JVM首选IPv4地址而不是IPv6，而且返回IPv4地址也是有可能的。这个能够经过java.net.preferIPv6Addresses=<true|false>来改变。

请看补充细节：details on IPv6 support in Java

注意：IPv6支持默认是关闭的。由于一些平台在使用IPv6的时候出现了一些问题。其余平台像AWS根本就不支持的。想要IPv6支持生效，只要配置hazelcast.prefer.ipv4.stack 的属性为false 便可。请看详细说明：Advanced Configuration Properties.

分区分组

Hazelcast 使用一致性哈希散列算法将关键的主机分到分区中。这些分区都指派了节点。默认全部分区值是 271，经过hazelcast.map.partition.count值进行改变。详细参考Advanced Configuration Properties.

在这些分区之间，须要拷贝做为备份全部。在配置中配置 back count值，就能够设置多个备份了。好比，第一备份区，第二备份区...一般来讲，一个节点不能拥有超过一份的备份（全部者或备份）。默认Hazelcast是随机分区和备份的，而且集群节点之间的备份是公平的，就像全部的节点都同样似得。

如今，若是某些节点共享相同的JVM或物理机器，若是你想要备份这些节点分配给其余节点，那该怎么办？若是某些节点的处理和记忆能力是不一样的,而且你不但愿分配相同数量的分区分配给全部节点，又该怎么办?

你能够将同在一个JVM中或在同一个架构中的节点机器组合为一组。或者，你能够组合这些节点来达到一样的功能。咱们称这叫作分组。这中分组方式代替了单节点分组。备份的内容，放在其余的分组中。

当你受权分组的时候，Hazelcast给你提供了三种选择配置分组信息。

第一个是经过IP地址自动的分组节点，节点将会以相同的网络接口组合在一块儿。在同一个主机上的全部成员是一个单独的分组。这将有助于在物理服务器收到损坏的时候避免数据的丢失。可是当在每一个物理机上有多个网络接口的话，这种状况就无效了。

<partition-group enabled="true"group-type="HOST_AWARE" />

Config config = ...;

PartitionGroupConfig partitionGroupConfig =config.getPartitionGroupConfig();

partitionGroupConfig.setEnabled( true )

.setGroupType(MemberGroupType.HOST_AWARE );

• 第二个是经过Hazelcast接口匹配配置自定义分组。这种方式下，你能够增长多个不一样的接口到你的分组中。还能够在地址接口中使用通配符。好比，用户能够经过自定义分组建立机架感知或者数据仓库在分组中。

<partition-groupenabled="true" group-type="CUSTOM">

<member-group>

</member-group>

<member-group>

</member-group

</partition-group>

Config config = ...;

PartitionGroupConfigpartitionGroupConfig = config.getPartitionGroupConfig();

partitionGroupConfig.setEnabled(true )

.setGroupType( MemberGroupType.CUSTOM );

MemberGroupConfigmemberGroupConfig = new MemberGroupConfig();

memberGroupConfig.addInterface("10.10.0.*" )

.addInterface("10.10.3.*" ).addInterface("10.10.5.*" );

MemberGroupConfigmemberGroupConfig2 = new MemberGroupConfig();

memberGroupConfig2.addInterface("10.10.10.10-100" )

.addInterface("10.10.1.*").addInterface( "10.10.2.*" );

partitionGroupConfig.addMemberGroupConfig(memberGroupConfig );

partitionGroupConfig.addMemberGroupConfig(memberGroupConfig2 );

• 第三个是给每一个成员它本身的分组。这意味着,每一个成员是一群本身的随机分布和备份分区。这是Hazelcast集群的默认配置而且给出了最少保护数。

<partition-groupenabled="true" group-type="PER_MEMBER" />

Config config = ...;

PartitionGroupConfig partitionGroupConfig= config.getPartitionGroupConfig();

partitionGroupConfig.setEnabled(true )

.setGroupType(MemberGroupType.PER_MEMBER );

监听器配置

事件监听器可使用HazelcastAPI从相关的对象中增长或是移除。

经过API方式来配置监听器的趋势有所降低，多是因为建立对象和注册监听的时候丢失事件的缘由。为了克服这个问题，Hazelcast提供了在配置文件中注册监听器的方式。监听器的注册能够经过声明式和编程式或是spring的配置文件方式来配置

成员监听器

o 声明式配置

o <listeners>

o <listener>com.hazelcast.examples.MembershipListener</listener>

o </listeners>

o 编程式配置

o config.addListenerConfig(

o new ListenerConfig("com.hazelcast.examples.MembershipListener" ) );

o Spring XMLconfiguration

o <hz:listeners>

o <hz:listenerclass-name="com.hazelcast.spring.DummyMembershipListener"/>

o <hz:listener implementation="dummyMembershipListener"/>

o </hz:listeners>

• 分布式监听器

o 声明式配置

o <listeners>

o <listener>com.hazelcast.examples.DistributedObjectListener</listener>

o </listeners>

o 编程式配置

o config.addListenerConfig(

o new ListenerConfig("com.hazelcast.examples.DistributedObjectListener" ) );

o Spring XML配置

o <hz:listeners>

o <hz:listenerclass-name="com.hazelcast.spring.DummyDistributedObjectListener"/>

o <hz:listenerimplementation="dummyDistributedObjectListener"/>

o </hz:listeners>

• 移动式监听器

o 声明配置

o <listeners>

o <listener>com.hazelcast.examples.MigrationListener</listener>

o </listeners>

o 编程式配置

o config.addListenerConfig(

o new ListenerConfig("com.hazelcast.examples.MigrationListener" ) );

o Spring XML配置

o <hz:listeners>

o <hz:listenerclass-name="com.hazelcast.spring.DummyMigrationListener"/>

o <hz:listenerimplementation="dummyMigrationListener"/>

o </hz:listeners>

• 周期性监听器

o 声明配置

o <listeners>

o <listener>com.hazelcast.examples.LifecycleListener</listener>

o </listeners>

o 编程式配置

o config.addListenerConfig(

o new ListenerConfig( "com.hazelcast.examples.LifecycleListener") );

o Spring XML配置

o <hz:listeners>

o <hz:listenerclass-name="com.hazelcast.spring.DummyLifecycleListener"/>

o <hz:listenerimplementation="dummyLifecycleListener"/>

o </hz:listeners>

• Map 条目监听器

o 声明式配置

o <map name="default">

o ...

o <entry-listeners>

o <entry-listener include-value="true"local="false">

o com.hazelcast.examples.EntryListener

o </entry-listener>

o </entry-listeners>

o </map>

o 编程式配置

o mapConfig.addEntryListenerConfig(

o newEntryListenerConfig( "com.hazelcast.examples.EntryListener",

o false, false ) );

o Spring XML配置

o <hz:map name="default">

o <hz:entry-listeners>

o <hz:entry-listener include-value="true"

o class-name="com.hazelcast.spring.DummyEntryListener"/>

o <hz:entry-listener implementation="dummyEntryListener"local="true"/>

o </hz:entry-listeners>

o </hz:map>

• 多种映射的条目监听器

o 声明式配置

o <multimapname="default">

o <value-collection-type>SET</value-collection-type>

o <entry-listeners>

o <entry-listenerinclude-value="true" local="false">

o com.hazelcast.examples.EntryListener

o </entry-listener>

o </entry-listeners>

o </multimap>

o 编程式配置

o multiMapConfig.addEntryListenerConfig(

o new EntryListenerConfig("com.hazelcast.examples.EntryListener",

o false, false ) );

o Spring XML配置

o <hz:multimapname="default" value-collection-type="LIST">

o <hz:entry-listeners>

o <hz:entry-listener include-value="true"

o class-name="com.hazelcast.spring.DummyEntryListener"/>

o <hz:entry-listener implementation="dummyEntryListener"local="true"/>

o </hz:entry-listeners>

o </hz:multimap>

• Queue条目监听器

o 声明式配置

o <queuename="default">

o ...

o <item-listeners>

o <item-listenerinclude-value="true">

o com.hazelcast.examples.ItemListener

o </item-listener>

o </item-listeners>

o </queue>

o 编程式配置

o queueConfig.addItemListenerConfig(

o new ItemListenerConfig("com.hazelcast.examples.ItemListener", true ) );

o Spring XML配置

o <hz:queuename="default" >

o <hz:item-listeners>

o <hz:item-listenerinclude-value="true"

o class-name="com.hazelcast.spring.DummyItemListener"/>

o </hz:item-listeners>

o </hz:queue>

• 主题信息监听器

o 声明式配置

o <topic name="default">

o <message-listeners>

o <message-listener>

o com.hazelcast.examples.MessageListener

o </message-listener>

o </message-listeners>

o </topic>

o 编程式配置

o topicConfig.addMessageListenerConfig(

o newListenerConfig( "com.hazelcast.examples.MessageListener" ) );

o Spring XML配置

o <hz:topic name="default">

o <hz:message-listeners>

o <hz:message-listener

o class-name="com.hazelcast.spring.DummyMessageListener"/>

o </hz:message-listeners>

o </hz:topic>

• 客户端监听器

o 声明式配置

o <listeners>

o <listener>com.hazelcast.examples.ClientListener</listener>

o </listeners>

o 编程式配置

o topicConfig.addMessageListenerConfig(

o new ListenerConfig("com.hazelcast.examples.ClientListener" ) );

o Spring XML配置

o <hz:listeners>

o <hz:listenerclass-name="com.hazelcast.spring.DummyClientListener"/>

o <hz:listenerimplementation="dummyClientListener"/>

o </hz:listeners>

日志配置

Hazelcast提供了灵活的日志配置，而且不依赖任何日志框架，仅仅依靠JDK的日志功能。它有内置的适配器来完成日志框架功能，而且提供日志接口来自定义日志功能。

想使用内置的适配器，你须要配置hazelcast.logging.type属性来使用下列预置的类型。

• jdk: JDK logging (default)

• log4j: Log4j

• slf4j: Slf4j

• none: disable logging

你能够经过声明式，编程式或JVM系统属性来配置hazelcast.logging.type.

注意: 若是你选择log4j或是slf4j的话，一些依赖也要加载进来（classpath下）。

• 声明式配置

<hazelcastxsi:schemaLocation="http://www.hazelcast.com/schema/config

http://www.hazelcast.com/schema/config/hazelcast-config-3.0.xsd"

xmlns="http://www.hazelcast.com/schema/config"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

....

<propertyname="hazelcast.logging.type">jdk</property>

....

</properties>

</hazelcast>

• 编程式配置

Configconfig = new Config() ;

config.setProperty("hazelcast.logging.type", "log4j" );

• 系统属性

o 使用JVM参数：java -Dhazelcast.logging.type=slf4j

o 使用系统类: System.setProperty("hazelcast.logging.type", "none" );

若是你提供了一个不是静态工厂的日志机制，你可使用自定义日志来实现它。要使用这个，你须要实现com.hazelcast.logging.LoggerFactory 和com.hazelcast.logging.ILogger 接口。而且设置系统属性hazelcast.logging.class做为你自定义的日志工厂类名。

-Dhazelcast.logging.class=foo.bar.MyLoggingFactory

你还能够经过注册日志监听器（LogListeners）到日志服务（LoggingService）在Hazelcast运行时来监听日志事件的过程。

LogListenerlistener = new LogListener() {

public void log( LogEvent logEvent ) {

// do something

}

HazelcastInstanceinstance = Hazelcast.newHazelcastInstance();

LoggingServiceloggingService = instance.getLoggingService();

loggingService.addLogListener(Level.INFO, listener );

经过这个日志服务（LoggingService），你能够获得目前使用的日志接口，也能够记录你本身的信息。

注意：若是你不是使用的命令行来配置你的日志，你应该注意Hazelcast类，由于默认状况下有可能在最新配置的日志机制以前使用jdk日志。当日志机制被选定的话，这就不会变了。

高级属性配置

Hazelcasth还提供了一些高级的属性配置。这些属性能够经过声明式和编程式或JVM系统属性方式来设置key-value键值对进行配置。

声明配置

<hazelcastxsi:schemaLocation="http://www.hazelcast.com/schema/config

http://www.hazelcast.com/schema/config/hazelcast-config-3.0.xsd"

xmlns="http://www.hazelcast.com/schema/config"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

....

<propertyname="hazelcast.property.foo">value</property>

....

</properties>

</hazelcast>

声明式配置

Config config = new Config() ;

config.setProperty( "hazelcast.property.foo","value" );

系统属性

使用JVM参数: java -Dhazelcast.property.foo=value
使用系统类: System.setProperty( "hazelcast.property.foo", "value" );

下面的两张表列出了高级属性的配置以及说明。

属性名	默认值	类型说明
hazelcast.health.monitoring.level	SILENT	string	Health monitoring log level. When SILENT, logs are printed only when values exceed some predefined threshold. When NOISY, logs are always printed periodically. Set OFF to turn off completely.
hazelcast.health.monitoring.delay.seconds	30	int	Health monitoring logging interval in seconds.
hazelcast.version.check.enabled	true	bool	Enable Hazelcast new version check on startup.
hazelcast.prefer.ipv4.stack	true	bool	Prefer Ipv4 network interface when picking a local address.
hazelcast.io.thread.count	3	int	Number of input and output threads.
hazelcast.operation.thread.count	-1	int	Number of partition based operation handler threads. -1 means CPU core count x 2.
hazelcast.operation.generic.thread.count	-1	int	Number of generic operation handler threads. -1 means CPU core count x 2.
hazelcast.event.thread.count	5	int	Number of event handler threads.
hazelcast.event.queue.capacity	1000000	int	Capacity of internal event queue.
hazelcast.event.queue.timeout.millis	250	int	Timeout to enqueue events to event queue.
hazelcast.connect.all.wait.seconds	120	int	Timeout to connect all other cluster members when a member is joining to a cluster.
hazelcast.memcache.enabled	true	bool	Enable Memcache client request listener service.
hazelcast.rest.enabled	true	bool	Enable REST client request listener service.
hazelcast.map.load.chunk.size	1000	int	Chunk size for MapLoader 's map initialization process (MapLoder.loadAllKeys()).
hazelcast.merge.first.run.delay.seconds	300	int	Initial run delay of split brain/merge process in seconds.
hazelcast.merge.next.run.delay.seconds	120	int	Run interval of split brain/merge process in seconds.
hazelcast.operation.call.timeout.millis	60000	int	Timeout to wait for a response when a remote call is sent, in milliseconds.
hazelcast.socket.bind.any	true	bool	Bind both server-socket and client-sockets to any local interface.
hazelcast.socket.server.bind.any	true	bool	Bind server-socket to any local interface. If not set, hazelcast.socket.bind.any will be used as default.
hazelcast.socket.client.bind.any	true	bool	Bind client-sockets to any local interface. If not set, hazelcast.socket.bind.any will be used as default.
hazelcast.socket.client.bind	true	bool	Bind client socket to an interface when connecting to a remote server socket. When set to false, client socket is not bound to any interface.
hazelcast.socket.receive.buffer.size	32	int	Socket receive buffer (SO_RCVBUF) size in KB.
hazelcast.socket.send.buffer.size	32	int	Socket send buffer (SO_SNDBUF) size in KB.
hazelcast.socket.linger.seconds	0	int	Set socket SO_LINGER option.
hazelcast.socket.keep.alive	true	bool	Socket set keep alive (SO_KEEPALIVE).
hazelcast.socket.no.delay	true	bool	Socket set TCP no delay.
hazelcast.shutdownhook.enabled	true	bool	Enable Hazelcast shutdownhook thread.
hazelcast.wait.seconds.before.join	5	int	Wait time before join operation.
hazelcast.max.join.seconds	300	int	Join timeout, maximum time to try to join before giving.
hazelcast.max.join.merge.target.seconds	20	int	Split-brain merge timeout for a specific target.
hazelcast.max.wait.seconds.before.join	20	int	Maximum wait time before join operation.
hazelcast.heartbeat.interval.seconds	1	int	Heartbeat send interval in seconds.
hazelcast.max.no.heartbeat.seconds	500	int	Max timeout of heartbeat in seconds for a node to assume it is dead.
hazelcast.max.no.master.confirmation.seconds	450	int	Max timeout of master confirmation from other nodes.
hazelcast.master.confirmation.interval.seconds	30	int	Interval at which nodes send master confirmation.
hazelcast.member.list.publish.interval.seconds	600	int	Interval at which master node publishes a member list.
hazelcast.icmp.enabled	false	bool	Enable ICMP ping.
hazelcast.icmp.timeout	1000	int	ICMP timeout in ms.
hazelcast.icmp.ttl	0	int	ICMP TTL (maximum numbers of hops to try).
hazelcast.initial.min.cluster.size	0	int	Initial expected cluster size to wait before node to start completely.
hazelcast.initial.wait.seconds	0	int	Initial time in seconds to wait before node to start completely.
hazelcast.map.replica.wait.seconds.for.scheduled.tasks	10	int	Scheduler delay for map tasks those will be executed on backup members.
hazelcast.partition.count	271	int	Total partition count.
hazelcast.logging.type	jdk	enum	Name of logging framework type to send logging events.
hazelcast.jmx	false	bool	Enable JMX agent.
hazelcast.jmx.detailed	false	bool	Enable detailed views on JMX.
hazelcast.mc.max.visible.instance.count	100	int	Management Center maximum visible instance count.
hazelcast.mc.url.change.enabled	true	bool	Management Center changing server url is enabled.
hazelcast.connection.monitor.interval	100	int	Minimum interval to consider a connection error as critical in milliseconds.
hazelcast.connection.monitor.max.faults	3	int	Maximum IO error count before disconnecting from a node.
hazelcast.partition.migration.interval	0	int	Interval to run partition migration tasks in seconds.
hazelcast.partition.migration.timeout	300	int	Timeout for partition migration tasks in seconds.
hazelcast.partition.migration.zip.enabled	true	bool	Enable compression during partition migration.
hazelcast.partition.table.send.interval	15	int	Interval for publishing partition table periodically to all cluster members.
hazelcast.partition.backup.sync.interval	30	int	Interval for syncing backup replicas.
hazelcast.partitioning.strategy.class	null	string	Class name implementing com.hazelcast.core.PartitioningStrategy, which defines key to partition mapping.
hazelcast.migration.min.delay.on.member.removed.seconds	5	int	Minimum delay (in seconds) between detection of a member that has left and start of the rebalancing process.
hazelcast.graceful.shutdown.max.wait	600	int	Maximum wait seconds during graceful shutdown.
hazelcast.system.log.enabled	true	bool	Enable system logs.
hazelcast.elastic.memory.enabled	false	bool	Enable Hazelcast Elastic Memory off-heap storage.
hazelcast.elastic.memory.total.size	128	int	Hazelcast Elastic Memory storage total size in MB.
hazelcast.elastic.memory.chunk.size	1	int	Hazelcast Elastic Memory storage chunk size in KB.
hazelcast.elastic.memory.shared.storage	false	bool	Enable Hazelcast Elastic Memory shared storage.
hazelcast.elastic.memory.unsafe.enabled	false	bool	Enable usage of sun.misc.Unsafe when allocating, reading and modifying off-heap storage.
hazelcast.enterprise.license.key	null	string	Hazelcast Enterprise license key.
hazelcast.client.heartbeat.timeout	300000	string	Timeout for the heartbeat messages sent by the client to members. If there is no any message passing between client and member within the given time via this property in milliseconds the connection will be closed.
hazelcast.client.heartbeat.interval	10000	string	The frequency of heartbeat messages sent by the clients to members.
hazelcast.client.max.failed.heartbeat.count	3	string	When the count of failed heartbeats sent to members reaches this value, the cluster is deemed as dead by the client.
hazelcast.client.request.retry.count	20	string	The retry count of the connection requests by the client to the members.
hazelcast.client.request.retry.wait.time	250	string	The frequency of the connection retries.
hazelcast.client.event.thread.count	5	string	Thread count for handling incoming event packets.
hazelcast.client.event.queue.capacity	1000000	string	Default value of the capacity of executor that handles incoming event packets.

网络分区

想象你有10台机器的集群，因为某些缘由，网络被分为两份，共4台机器，其余6台机器看不见了。结果，你只有两个集群。4台机器的和6台机器的集群。这种状况下，每一个集群的机器都在想，其余的节点都死了甚至是不存在的。这种状况就叫作网络分区（a.k.a. Split-Brain Syndrome）。

然而，就像包括主机和备份机在内的同样，并非全部的271个分区都在小集群中。所以，从每一个小集群的角度来看，就像分区不存在同样，数据已经丢失了（它们在其余的分区里）。

若是使用Map存储的话，这些丢失的数据会从数据库从新加载，使得每一个小集群保持完整。每一个小集群的机器会从新建立丢失的主要分区，而后存储起来。也包括在其余节点的备份数据。

当主分区存在而且没有备份的话，一个关于备份版本的问题就会出现了，紧接着备份分区就会被建立。当备份分区存在而主分区不存在的话，这个备份分区就会升级为主分区，而后从新建立个合适的版本的备份分区。这时候，两个集群都已经修复好了，而且有271个分区和备份分区。而后在彼此没有知晓的状况下继续处理事务。想象它们都有足够的剩余内存，生产力较低。

若是使用Map存储，而且网络访问数据库可用的话，而如今集群中的一个在进行写/更新操做，这就产生了一个潜在的问题-若是在两个集群都作修改的话，这就重写了同一个缓存记录。这种重写状况会致使潜在的数据丢失。所以，数据库的设计应该在读的时候考虑到插入和结合问题，或者是版本问题，而不是更新数据。

若是网络访问数据库不可用，那么基于配置的和编码的事务、缓存中的条目更新都会被拒绝（保持一致性和同步性）。在缓存中的数据，更新操做的数据将会被认为是脏数据，当更新可用的时候，重写到数据库。集群成员能够在管理中心的web控制台看到脏条目数据（请参考 Map Monitoring）。

当网络不可用的时候，就没有办法避免以编程式的方式状况下你的集群会以两个独立的集群运行。可是，咱们应该能够回答下面的问题：”当网络修复好而且链接恢复了，程序又会怎样呢？这两个集群会再一次融合为一个吗？若是是这样，那数据又是怎样解决的呢？你将Map中相同的key的值删除？”

当网络恢复了，你应该保证全部271个分区在每一个集群中都是活着的，而且进行合并。一旦全部的主分区合并了，全部的备份分区将会从新写入，这时候它们的版本也就对了。也许你想经过MapMergePolicy接口写个合并策略，从数据库中将条目重建，而不是从缓存中。

从EntryView接口的观点来看，只有元数据（包括对象大小，点击次数，最后一次更新/存储数据，从0开始的随条目更新而增长的版本号）才能够起到合并的功能。你还能够建立你本身的版本控制计划，或者捕捉重建条目的时间序列。

下面例子，经过一步一步的告诉你，Hazelcast是怎么实现合并的：

1. 集群中时间最长的机器检查在网络中是否有另台带有相同组名或组密码的机器。

2. 若是发现了这样的机器，那这个探测主机将会判断它和哪一个集群进行合并。

3. 进行合并的集群中每台机器将会作下面的事情：

o 暂停

o 取出本地全部map条目

o 关闭全部网络链接

o 加入新的集群

o 给本地全部map条目发送合并信息请求

o 从新启动

所以合并集群中的每一个机器，事实上从新加入了新的集群，而后发送合并信息请求给每一个map条目。

两点重要提示：

较小的集群将会合并成更大的集群。若是它们有相同的集群量，那么就经过哈新散列算法来决定负责合并的集群。

· 每一个集群在同一个map中具备相同的key值的也许也会有不一样的版本。目的集群会基于合并策略（MergePolicy）为那个map决定怎么合并条目。由于有内置的合并策略就像 PassThroughMergePolicy，PutIfAbsentMapMergePolicy,HigherHitsMapMergePolicy 和 LatestUpdateMapMergePolicy.可是，你也能够设计你本身的合并策略经过实现 com.hazelcast.map.merge.MapMergePolicy.你应该设定你的实现的完整类名到merge-policy配置。

public interface MergePolicy {

/**

*合并条目以后返回具备相同key值的条目的value值

*你应该考虑到条目是null的状况

* @param mapName name of the map

* @param mergingEntry 条目合并到目的集群

* @param existingEntry 在集群中存在的集群

* @return final value of the entry. 若是返回null，条目会被删除

Object merge( String mapName, EntryViewmergingEntry, EntryView existingEntry );

}

在这里告诉你合并策略是怎么被每一个map识别的

...

<backup-count>1</backup-count>

<eviction-policy>NONE</eviction-policy>

<max-size>0</max-size>

<eviction-percentage>25</eviction-percentage>

<!--

当从网络分区恢复过来的时候,

基于在这里配置的策略，小集群的map条目将会合并到大集群中。当一个条目合并到集群中时，也许会出现相同key值的条目。

具备相同的key值的条目也许value值不一样.

出现冲突了，默认策略是hz.ADD_NEW_ENTRY

有内置的策略如：

com.hazelcast.map.merge.PassThroughMergePolicy; entry will be added if

这个key没有已存在的条目.

com.hazelcast.map.merge.PutIfAbsentMapMergePolicy ; entry will be

若是在集群中没有这个条目，就增长这个条目.

com.hazelcast.map.merge.HigherHitsMapMergePolicy ;

点击最多的条目有效.

com.hazelcast.map.merge.LatestUpdateMapMergePolicy ; entry with the