本文整理汇总了Java中com.hazelcast.cache.HazelcastCachingProvider类的典型用法代码示例。如果您正苦于以下问题:Java HazelcastCachingProvider类的具体用法?Java HazelcastCachingProvider怎么用?Java HazelcastCachingProvider使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
HazelcastCachingProvider类属于com.hazelcast.cache包,在下文中一共展示了HazelcastCachingProvider类的12个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: initialize
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
void initialize(RepositoryImpl repo) {
this.repo = repo;
execService = repo.getHazelcastClient().getExecutorService(PN_XDM_SCHEMA_POOL);
//resCache = repo.getHazelcastClient().getMap(CN_XDM_RESULT);
xqCache = repo.getHazelcastClient().getReplicatedMap(CN_XDM_QUERY);
CachingProvider cachingProvider = Caching.getCachingProvider();
// retrieve the javax.cache.CacheManager
try {
URI uri = new URI("hzClient");
Properties props = HazelcastCachingProvider.propertiesByInstanceName(repo.getHazelcastClient().getName());
CacheManager cacheManager = cachingProvider.getCacheManager(uri, null, props);
resCache = cacheManager.getCache(CN_XDM_RESULT, Long.class, XDMResults.class);
} catch (URISyntaxException ex) {
logger.error("initialize.error;", ex);
}
}
开发者ID:dsukhoroslov,项目名称:bagri,代码行数:18,代码来源:QueryManagementImpl.java
示例2: jCacheCacheManager
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Bean
public javax.cache.CacheManager jCacheCacheManager() {
javax.cache.CacheManager cacheManager = Caching
.getCachingProvider(HazelcastCachingProvider.class.getName())
.getCacheManager();
MutableConfiguration<Object, Object> config = new MutableConfiguration<Object, Object>();
config.setStatisticsEnabled(true);
cacheManager.createCache("books", config);
cacheManager.createCache("speakers", config);
return cacheManager;
}
开发者ID:vikrammane23,项目名称:https-github.com-g0t4-jenkins2-course-spring-boot,代码行数:12,代码来源:CacheStatisticsAutoConfigurationTests.java
示例3: hazelcastAsJCacheWithCaches
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Test
public void hazelcastAsJCacheWithCaches() {
String cachingProviderFqn = HazelcastCachingProvider.class.getName();
try {
load(DefaultCacheConfiguration.class, "spring.cache.type=jcache",
"spring.cache.jcache.provider=" + cachingProviderFqn,
"spring.cache.cacheNames[0]=foo", "spring.cache.cacheNames[1]=bar");
JCacheCacheManager cacheManager = validateCacheManager(
JCacheCacheManager.class);
assertThat(cacheManager.getCacheNames()).containsOnly("foo", "bar");
}
finally {
Caching.getCachingProvider(cachingProviderFqn).close();
}
}
开发者ID:vikrammane23,项目名称:https-github.com-g0t4-jenkins2-course-spring-boot,代码行数:16,代码来源:CacheAutoConfigurationTests.java
示例4: hazelcastAsJCacheWithConfig
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Test
public void hazelcastAsJCacheWithConfig() throws IOException {
String cachingProviderFqn = HazelcastCachingProvider.class.getName();
String configLocation = "org/springframework/boot/autoconfigure/cache/hazelcast-specific.xml";
load(DefaultCacheConfiguration.class, "spring.cache.type=jcache",
"spring.cache.jcache.provider=" + cachingProviderFqn,
"spring.cache.jcache.config=" + configLocation);
JCacheCacheManager cacheManager = validateCacheManager(JCacheCacheManager.class);
Resource configResource = new ClassPathResource(configLocation);
assertThat(cacheManager.getCacheManager().getURI())
.isEqualTo(configResource.getURI());
}
开发者ID:vikrammane23,项目名称:https-github.com-g0t4-jenkins2-course-spring-boot,代码行数:14,代码来源:CacheAutoConfigurationTests.java
示例5: jCacheCacheWithCachesAndCustomizer
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Test
public void jCacheCacheWithCachesAndCustomizer() {
String cachingProviderFqn = HazelcastCachingProvider.class.getName();
load(JCacheWithCustomizerConfiguration.class, "spring.cache.type=jcache",
"spring.cache.jcache.provider=" + cachingProviderFqn,
"spring.cache.cacheNames[0]=foo", "spring.cache.cacheNames[1]=bar");
JCacheCacheManager cacheManager = validateCacheManager(JCacheCacheManager.class);
// see customizer
assertThat(cacheManager.getCacheNames()).containsOnly("foo", "custom1");
}
开发者ID:vikrammane23,项目名称:https-github.com-g0t4-jenkins2-course-spring-boot,代码行数:11,代码来源:CacheAutoConfigurationTests.java
示例6: hazelcastAsJCacheWithCaches
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Test
public void hazelcastAsJCacheWithCaches() {
String cachingProviderFqn = HazelcastCachingProvider.class.getName();
load(DefaultCacheConfiguration.class, "spring.cache.type=jcache",
"spring.cache.jcache.provider=" + cachingProviderFqn,
"spring.cache.cacheNames[0]=foo", "spring.cache.cacheNames[1]=bar");
JCacheCacheManager cacheManager = validateCacheManager(JCacheCacheManager.class);
assertThat(cacheManager.getCacheNames(), containsInAnyOrder("foo", "bar"));
assertThat(cacheManager.getCacheNames(), hasSize(2));
}
开发者ID:Nephilim84,项目名称:contestparser,代码行数:11,代码来源:CacheAutoConfigurationTests.java
示例7: hazelcastAsJCacheWithConfig
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Test
public void hazelcastAsJCacheWithConfig() throws IOException {
String cachingProviderFqn = HazelcastCachingProvider.class.getName();
String configLocation = "org/springframework/boot/autoconfigure/cache/hazelcast-specific.xml";
load(DefaultCacheConfiguration.class, "spring.cache.type=jcache",
"spring.cache.jcache.provider=" + cachingProviderFqn,
"spring.cache.jcache.config=" + configLocation);
JCacheCacheManager cacheManager = validateCacheManager(JCacheCacheManager.class);
Resource configResource = new ClassPathResource(configLocation);
assertThat(cacheManager.getCacheManager().getURI(),
equalTo(configResource.getURI()));
}
开发者ID:Nephilim84,项目名称:contestparser,代码行数:14,代码来源:CacheAutoConfigurationTests.java
示例8: jCacheCacheWithCachesAndCustomizer
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Test
public void jCacheCacheWithCachesAndCustomizer() {
String cachingProviderFqn = HazelcastCachingProvider.class.getName();
load(JCacheWithCustomizerConfiguration.class, "spring.cache.type=jcache",
"spring.cache.jcache.provider=" + cachingProviderFqn,
"spring.cache.cacheNames[0]=foo", "spring.cache.cacheNames[1]=bar");
JCacheCacheManager cacheManager = validateCacheManager(JCacheCacheManager.class);
assertThat(cacheManager.getCacheNames(), containsInAnyOrder("foo", "custom1")); // see
// customizer
assertThat(cacheManager.getCacheNames(), hasSize(2));
}
开发者ID:Nephilim84,项目名称:contestparser,代码行数:12,代码来源:CacheAutoConfigurationTests.java
示例9: testSimpleJCache
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Test
public void testSimpleJCache() {
Properties properties = new Properties();
properties.setProperty(HazelcastCachingProvider.HAZELCAST_CONFIG_LOCATION,
"classpath:my-hazelcast.xml");
CachingProvider provider = Caching.getCachingProvider();
CacheManager manager = provider.getCacheManager(URI.create("my-cache-manager"),
null,
properties);
Cache<String, String> cache = manager.getCache("simple-cache",
String.class,
String.class);
IntStream.rangeClosed(1, 5).forEach(i -> cache.put("key" + i, "value" + i));
assertThat(cache.get("key1"))
.isEqualTo("value1");
assertThat(cache.get("key5"))
.isEqualTo("value5");
assertThat(cache.get("key10"))
.isNull();
cache.close();
manager.close();
provider.close();
}
开发者ID:kazuhira-r,项目名称:hazelcast-examples,代码行数:28,代码来源:JCacheConfigurationTest.java
示例10: testEviction
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Test
public void testEviction() {
Properties properties =
HazelcastCachingProvider.propertiesByLocation("classpath:my-hazelcast.xml");
CachingProvider provider = Caching.getCachingProvider();
CacheManager manager = provider.getCacheManager(URI.create("my-cache-manager"),
null,
properties);
Cache<String, String> cache = manager.getCache("with-eviction-cache",
String.class,
String.class);
com.hazelcast.cache.ICache<String, String> icache =
cache.unwrap(com.hazelcast.cache.ICache.class);
com.hazelcast.config.CacheConfig config =
icache.getConfiguration(com.hazelcast.config.CacheConfig.class);
assertThat(config.getEvictionConfig().getSize())
.isEqualTo(5); // right
IntStream.rangeClosed(1, 30).forEach(i -> cache.put("key" + i, "value" + i));
int count = 0;
for (Cache.Entry<String, String> entry : cache) {
count++;
}
assertThat(count)
.isGreaterThan(25); // much larger than ENTRY_COUNT??
cache.close();
manager.close();
provider.close();
}
开发者ID:kazuhira-r,项目名称:hazelcast-examples,代码行数:37,代码来源:JCacheConfigurationTest.java
示例11: testEvictionWithExpire
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Test
public void testEvictionWithExpire() throws InterruptedException {
Properties properties =
HazelcastCachingProvider.propertiesByLocation("classpath:my-hazelcast.xml");
CachingProvider provider = Caching.getCachingProvider();
CacheManager manager = provider.getCacheManager(URI.create("my-cache-manager"),
null,
properties);
Cache<String, String> cache = manager.getCache("with-expire-cache",
String.class,
String.class);
IntStream.rangeClosed(1, 30).forEach(i -> cache.put("key" + i, "value" + i));
TimeUnit.SECONDS.sleep(3);
cache.get("key1");
cache.get("key3");
cache.get("key5");
cache.get("key10");
cache.get("key13");
cache.get("key15");
cache.get("key20");
cache.get("key25");
TimeUnit.SECONDS.sleep(3);
int count = 0;
for (Cache.Entry<String, String> entry : cache) {
count++;
}
assertThat(count)
.isLessThanOrEqualTo(8);
cache.close();
manager.close();
provider.close();
}
开发者ID:kazuhira-r,项目名称:hazelcast-examples,代码行数:41,代码来源:JCacheConfigurationTest.java
示例12: testExpire
import com.hazelcast.cache.HazelcastCachingProvider; //导入依赖的package包/类
@Test
public void testExpire() throws InterruptedException {
Properties properties =
HazelcastCachingProvider.propertiesByLocation("classpath:my-hazelcast.xml");
CachingProvider provider = Caching.getCachingProvider();
CacheManager manager = provider.getCacheManager(URI.create("my-cache-manager"),
null,
properties);
Cache<String, String> cache = manager.getCache("with-expire-cache",
String.class,
String.class);
IntStream.rangeClosed(1, 5).forEach(i -> cache.put("key" + i, "value" + i));
TimeUnit.SECONDS.sleep(3);
cache.get("key1");
cache.get("key3");
TimeUnit.SECONDS.sleep(3);
assertThat(cache.get("key1"))
.isEqualTo("value1");
assertThat(cache.get("key3"))
.isEqualTo("value3");
assertThat(cache.get("key2"))
.isNull();
assertThat(cache.get("key4"))
.isNull();
TimeUnit.SECONDS.sleep(6);
assertThat(cache.get("key1"))
.isNull();
assertThat(cache.get("key3"))
.isNull();
cache.close();
manager.close();
provider.close();
}
开发者ID:kazuhira-r,项目名称:hazelcast-examples,代码行数:44,代码来源:JCacheConfigurationTest.java
注:本文中的com.hazelcast.cache.HazelcastCachingProvider类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论