* If a service discovery solution is enabled (JHipster Registry or Consul), * then the host list will be populated from the service discovery. * *

* If the service discovery is not enabled, host discovery will be based on * the default transport settings defined in the 'config-file' packaged within * the Jar. The 'config-file' can be overridden using the application property * jhipster.cache.infinispan.config-file * *

* If no service discovery is defined, you have the choice of 'config-file' * based on the underlying platform for hosts discovery. Infinispan * supports discovery natively for most of the platforms like Kubernetes/OpenShift, * AWS, Azure and Google. * * @param jHipsterProperties the jhipster properties to configure from. * @return the infinispan global configurer. */ @Bean public InfinispanGlobalConfigurer globalConfiguration(JHipsterProperties jHipsterProperties) { log.info("Defining Infinispan Global Configuration"); <%_ if (serviceDiscoveryAny) { _%> if (this.registration == null) { // if registry is not defined, use native discovery log.warn("No discovery service is set up, Infinispan will use default discovery for cluster formation"); return () -> GlobalConfigurationBuilder .defaultClusteredBuilder().transport().defaultTransport() .addProperty("configurationFile", jHipsterProperties.getCache().getInfinispan().getConfigFile()) .clusterName("infinispan-<%= baseName %>-cluster") .jmx().enabled(jHipsterProperties.getCache().getInfinispan().isStatsEnabled()) .serialization().marshaller(new JBossUserMarshaller()) .build(); } else if (discoveryClient.getInstances(registration.getServiceId()).size() == 0) { return () -> GlobalConfigurationBuilder .defaultClusteredBuilder().transport() .transport(new JGroupsTransport()) .clusterName("infinispan-<%= baseName %>-cluster") .jmx().enabled(jHipsterProperties.getCache().getInfinispan().isStatsEnabled()) .serialization().marshaller(new JBossUserMarshaller()) .build(); } else { return () -> GlobalConfigurationBuilder .defaultClusteredBuilder().transport() .transport(new JGroupsTransport(getTransportChannel())) .clusterName("infinispan-<%= baseName %>-cluster") .jmx().enabled(jHipsterProperties.getCache().getInfinispan().isStatsEnabled()) .serialization().marshaller(new JBossUserMarshaller()) .build(); } <%_ } else { _%> return () -> GlobalConfigurationBuilder .defaultClusteredBuilder().transport().defaultTransport() .addProperty("configurationFile", jHipsterProperties.getCache().getInfinispan().getConfigFile()) .clusterName("infinispan-<%= baseName %>-cluster") .jmx().enabled(jHipsterProperties.getCache().getInfinispan().isStatsEnabled()) .serialization().marshaller(new JBossUserMarshaller()) .build(); <%_ } _%> } /** * Initialize cache configuration for Hibernate L2 cache and Spring Cache. *

* There are three different modes: local, distributed and replicated, and L2 cache options are pre-configured. * *

* It supports both jCache and Spring cache abstractions. *

* Usage: *

*
1. * jCache: *

   @CacheResult(cacheName = "dist-app-data") 

   * - for creating a distributed cache. In a similar way other cache names and options can be used *
*
2. * Spring Cache: *

   @Cacheable(value = "repl-app-data") 

   * - for creating a replicated cache. In a similar way other cache names and options can be used *
*
3. * Cache manager can also be injected through DI/CDI and data can be manipulated using Infinispan APIs, *

        *          @Autowired (or) @Inject
        *          private EmbeddedCacheManager cacheManager;
        *
        *          void cacheSample() {
        *              cacheManager.getCache("dist-app-data").put("hi", "there");
        *          }
        *          

   *
*

* MPING multicast is replaced with TCPPING with the host details discovered * from registry and sends only unicast messages to the host list. */ private JChannel getTransportChannel() { JChannel channel; List initialHosts = new ArrayList<>(); try { for (ServiceInstance instance : discoveryClient.getInstances(registration.getServiceId())) { log.debug("Adding Infinispan cluster member {}:{}", instance.getHost(), 7800); initialHosts.add(new InetSocketAddress(instance.getHost(), 7800)); } TCP tcp = new TCP(); tcp.setBindAddress(InetAddress.getLocalHost()); tcp.setBindPort(7800); tcp.setThreadPoolMinThreads(2); tcp.setThreadPoolMaxThreads(30); tcp.setThreadPoolKeepAliveTime(60000); TCPPING tcpping = new TCPPING(); initialHosts.add(new InetSocketAddress(InetAddress.getLocalHost(), 7800)); tcpping.setInitialHosts(initialHosts); tcpping.setErgonomics(false); tcpping.setPortRange(10); tcpping.sendCacheInformation(); NAKACK2 nakack = new NAKACK2(); nakack.setUseMcastXmit(false); nakack.setDiscardDeliveredMsgs(false); MERGE3 merge = new MERGE3(); merge.setMinInterval(10000); merge.setMaxInterval(30000); FD_ALL fd = new FD_ALL(); fd.setTimeout(60000); fd.setInterval(15000); fd.setTimeoutCheckInterval(5000); ProtocolStack stack = new ProtocolStack(); // Order shouldn't be changed stack .addProtocol(tcp) .addProtocol(tcpping) .addProtocol(merge) .addProtocol(new FD_SOCK()) .addProtocol(fd) .addProtocol(new VERIFY_SUSPECT()) .addProtocol(nakack) .addProtocol(new UNICAST3()) .addProtocol(new STABLE()) .addProtocol(new GMS()) .addProtocol(new MFC()) .addProtocol(new FRAG2()); channel = new JChannel(stack); stack.init(); } catch (Exception e) { throw new BeanInitializationException("Cache (Infinispan protocol stack) configuration failed", e); } return channel; } <%_ } _%> <%_ } _%> <%_ if (cacheProviderMemcached) { _%> private final Logger log = LoggerFactory.getLogger(CacheConfiguration.class); @Bean public CacheManager memcachedCacheManager(JHipsterProperties jHipsterProperties, List caches) throws Exception { if (!jHipsterProperties.getCache().getMemcached().isEnabled()) { // Note that Memcached cannot work with Spring Boot devtools // So it should be disabled in development mode log.debug("Memcached is disabled"); return new NoOpCacheManager(); } log.debug("Starting Memcached configuration"); SSMCacheManager cacheManager = new SSMCacheManager(); List ssmCaches = new ArrayList<>(); for (CacheFactory cache : caches) { SSMCache ssmCache = new SSMCache(cache.getObject(), jHipsterProperties.getCache().getMemcached().getExpiration(), false); ssmCaches.add(ssmCache); } cacheManager.setCaches(ssmCaches); return cacheManager; } @Bean CacheFactory defaultCacheFactory(JHipsterProperties jHipsterProperties) { return createCache("default", jHipsterProperties); } <%_ if (!skipUserManagement || (authenticationTypeOauth2 && !databaseTypeNo)) { _%> @Bean public CacheFactory usersByLoginCache(JHipsterProperties jHipsterProperties) { return this.createCache(UserRepository.USERS_BY_LOGIN_CACHE, jHipsterProperties); } @Bean public CacheFactory usersByEmailCache(JHipsterProperties jHipsterProperties) { return this.createCache(UserRepository.USERS_BY_EMAIL_CACHE, jHipsterProperties); } <%_ } _%> private CacheFactory createCache(String cacheName, JHipsterProperties jHipsterProperties) { if (!jHipsterProperties.getCache().getMemcached().isEnabled()) { // Note that Memcached cannot work with Spring Boot devtools // So it should be disabled in development mode return null; } CacheFactory defaultCache = new CacheFactory(); defaultCache.setCacheName(cacheName); defaultCache.setCacheClientFactory(new MemcacheClientFactoryImpl()); DefaultAddressProvider addressProvider = new DefaultAddressProvider(); addressProvider.setAddress(jHipsterProperties.getCache().getMemcached().getServers()); defaultCache.setAddressProvider(addressProvider); Map authInfoMap = new HashMap<>(); if (jHipsterProperties.getCache().getMemcached().getAuthentication().isEnabled()) { InetSocketAddress memcachedServers = AddrUtil.getOneAddress(jHipsterProperties.getCache().getMemcached().getServers()); AuthInfo authInfo = AuthInfo.plain( jHipsterProperties.getCache().getMemcached().getAuthentication().getUsername(), jHipsterProperties.getCache().getMemcached().getAuthentication().getPassword()); authInfoMap.put(memcachedServers, authInfo); } XMemcachedConfiguration cacheConfiguration = new XMemcachedConfiguration(); if (!authInfoMap.isEmpty()) { cacheConfiguration.setAuthInfoMap(authInfoMap); } cacheConfiguration.setConsistentHashing(true); cacheConfiguration.setUseBinaryProtocol(jHipsterProperties.getCache().getMemcached().isUseBinaryProtocol()); defaultCache.setConfiguration(cacheConfiguration); return defaultCache; } <%_ } _%> <%_ if (cacheProviderRedis) { _%> @Bean public javax.cache.configuration.Configuration jcacheConfiguration(JHipsterProperties jHipsterProperties) { MutableConfiguration jcacheConfig = new MutableConfiguration<>(); URI redisUri = URI.create(jHipsterProperties.getCache().getRedis().getServer()[0]); Config config = new Config(); if (jHipsterProperties.getCache().getRedis().isCluster()) { ClusterServersConfig clusterServersConfig = config .useClusterServers() .setMasterConnectionPoolSize(jHipsterProperties.getCache().getRedis().getConnectionPoolSize()) .setMasterConnectionMinimumIdleSize(jHipsterProperties.getCache().getRedis().getConnectionMinimumIdleSize()) .setSubscriptionConnectionPoolSize(jHipsterProperties.getCache().getRedis().getSubscriptionConnectionPoolSize()) .addNodeAddress(jHipsterProperties.getCache().getRedis().getServer()); if (redisUri.getUserInfo() != null) { clusterServersConfig.setPassword(redisUri.getUserInfo().substring(redisUri.getUserInfo().indexOf(':') + 1)); } } else { SingleServerConfig singleServerConfig = config .useSingleServer() .setConnectionPoolSize(jHipsterProperties.getCache().getRedis().getConnectionPoolSize()) .setConnectionMinimumIdleSize(jHipsterProperties.getCache().getRedis().getConnectionMinimumIdleSize()) .setSubscriptionConnectionPoolSize(jHipsterProperties.getCache().getRedis().getSubscriptionConnectionPoolSize()) .setAddress(jHipsterProperties.getCache().getRedis().getServer()[0]); if (redisUri.getUserInfo() != null) { singleServerConfig.setPassword(redisUri.getUserInfo().substring(redisUri.getUserInfo().indexOf(':') + 1)); } } jcacheConfig.setStatisticsEnabled(true); jcacheConfig.setExpiryPolicyFactory(CreatedExpiryPolicy.factoryOf(new Duration(TimeUnit.SECONDS, jHipsterProperties.getCache().getRedis().getExpiration()))); return RedissonConfiguration.fromInstance(Redisson.create(config), jcacheConfig); } <%_ if (enableHibernateCache) { _%> @Bean public HibernatePropertiesCustomizer hibernatePropertiesCustomizer(javax.cache.CacheManager cm) { return hibernateProperties -> hibernateProperties.put(ConfigSettings.CACHE_MANAGER, cm); } <%_ } _%> @Bean public JCacheManagerCustomizer cacheManagerCustomizer(javax.cache.configuration.Configuration jcacheConfiguration) { return cm -> { <%_ if (!skipUserManagement || (authenticationTypeOauth2 && !databaseTypeNo)) { _%> createCache(cm, <%= packageName %>.repository.UserRepository.USERS_BY_LOGIN_CACHE, jcacheConfiguration); createCache(cm, <%= packageName %>.repository.UserRepository.USERS_BY_EMAIL_CACHE, jcacheConfiguration); <%_ if (enableHibernateCache) { _%> createCache(cm, <%= packageName %>.domain.<%= asEntity('User') %>.class.getName(), jcacheConfiguration); createCache(cm, <%= packageName %>.domain.Authority.class.getName(), jcacheConfiguration); createCache(cm, <%= packageName %>.domain.<%= asEntity('User') %>.class.getName() + ".authorities", jcacheConfiguration); <%_ if (authenticationTypeSession) { _%> createCache(cm, <%= packageName %>.domain.PersistentToken.class.getName(), jcacheConfiguration); createCache(cm, <%= packageName %>.domain.<%= asEntity('User') %>.class.getName() + ".persistentTokens", jcacheConfiguration); <%_ } _%> <%_ } _%> <%_ } _%> // jhipster-needle-redis-add-entry }; } private void createCache(javax.cache.CacheManager cm, String cacheName, javax.cache.configuration.Configuration jcacheConfiguration) { javax.cache.Cache cache = cm.getCache(cacheName); if (cache != null) { cache.clear(); } else { cm.createCache(cacheName, jcacheConfiguration); } } <%_ } _%> <%_ if (!cacheProviderNo) { _%> @Autowired(required = false) public void setGitProperties(GitProperties gitProperties) { this.gitProperties = gitProperties; } @Autowired(required = false) public void setBuildProperties(BuildProperties buildProperties) { this.buildProperties = buildProperties; } @Bean public KeyGenerator keyGenerator() { return new PrefixedKeyGenerator(this.gitProperties, this.buildProperties); } <%_ } _%> }