1. 程式人生 > >spring boot 2.1.4 快取 Hazelcast實現(四)

spring boot 2.1.4 快取 Hazelcast實現(四)

hazelcast.xml檔案可以拆分成多個,並且在hazelcast.xml檔案中預設可以從系統配置項讀取配置屬性,這裡轉成在spring配置檔案中配置

private static final String GROUP_NAME = "group.name";
	private static final String MANAGERMENT_CENTER = "spring.cache.management-center";

	private void setCacheProperty() {
		String applicationName = environment.getProperty("spring.application.name", "");
		Assert.hasLength(applicationName, "配置項:spring.application.name不能為空");
		System.setProperty(GROUP_NAME, applicationName);
		String centerUrl = environment.getProperty(MANAGERMENT_CENTER, "");
		System.setProperty(MANAGERMENT_CENTER, centerUrl);
		System.setProperty(MANAGERMENT_CENTER + ".enable", StringUtils.isNotEmpty(centerUrl) + "");
	}

hazelcast.xml檔案中使用

<group>
        <name>${group.name}</name>
    </group>
    <management-center enabled="${spring.cache.management-center.enable}">${spring.cache.management-center}</management-center>
    <import resource="network-config.xml"/>
    <import resource="cache-config.xml"/>

 

nework-config.xml檔案單獨提取出來方便分散式配置,這裡單機都沒有啟用

<?xml version="1.0" encoding="UTF-8"?>
<hazelcast xmlns="http://www.hazelcast.com/schema/config"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xsi:schemaLocation="http://www.hazelcast.com/schema/config
           http://www.hazelcast.com/schema/config/hazelcast-config-3.11.xsd">
	<network>
		<port auto-increment="true" port-count="100">5701</port>
		<outbound-ports>
            <!--
            Allowed port range when connecting to other nodes.
            0 or * means use system provided port.
            -->
            <ports>0</ports>
        </outbound-ports>
		<join>
			<multicast enabled="false">
				<multicast-group>224.2.2.3</multicast-group>
				<multicast-port>54327</multicast-port>
			</multicast>
			<tcp-ip enabled="false">
				<interface>127.0.0.1</interface>
				<member-list>
					<member>127.0.0.1</member>
				</member-list>
			</tcp-ip>
		</join>
	</network>
</hazelcast>

 

cache-config快取配置比較常用,也單獨提取出來

<?xml version="1.0" encoding="UTF-8"?>
<hazelcast xmlns="http://www.hazelcast.com/schema/config"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.hazelcast.com/schema/config
           http://www.hazelcast.com/schema/config/hazelcast-config-3.11.xsd">
	<cache name="default">
		<key-type class-name="java.lang.Object" />
		<value-type class-name="java.lang.Object" />
		<statistics-enabled>true</statistics-enabled>
		<management-enabled>true</management-enabled>
		<read-through>true</read-through>
		<write-through>true</write-through>
		<backup-count>1</backup-count>
		<async-backup-count>1</async-backup-count>
		<in-memory-format>BINARY</in-memory-format>
		<eviction size="10000" max-size-policy="ENTRY_COUNT"
			eviction-policy="LRU" />
		<quorum-ref>quorum-name</quorum-ref>
		<disable-per-entry-invalidation-events>true
		</disable-per-entry-invalidation-events>
		<!-- 
		<cache-loader-factory class-name="com.example.cache.MyCacheLoaderFactory" />
		<cache-writer-factory class-name="com.example.cache.MyCacheWriterFactory" />
		<expiry-policy-factory class-name="com.example.cache.MyExpiryPolicyFactory" />
		<cache-entry-listeners>
			<cache-entry-listener old-value-required="false"
				synchronous="false">
				<cache-entry-listener-factory
					class-name="com.example.cache.MyEntryListenerFactory" />
				<cache-entry-event-filter-factory
					class-name="com.example.cache.MyEntryEventFilterFactory" />
			</cache-entry-listener>
		</cache-entry-listeners> 
		-->
	</cache>
</hazelcast>

 

其他的配置項跟hazelcast的jar包中hazelcast-default.