InfiniSpan如何获取缓存

Question

我正在尝试通过Hibernate会话获取名为‘InfiniSpan’的默认缓存(在我的persistence.xml中定义)：

获取缓存#1的代码：

            EntityManagerFactory emf = Persistence.createEntityManagerFactory("mytest");
            SessionFactory unwrap = emf.unwrap(SessionFactory.class);
            CacheImplementor cache = (CacheImplementor) unwrap.getCache();
            RegionFactory regionFactory = cache.getRegionFactory();

            if (regionFactory instanceof InfinispanRegionFactory) {
                InfinispanRegionFactory reg = (InfinispanRegionFactory) regionFactory;
                EmbeddedCacheManager cacheManager = reg.getCacheManager();
            }


            final Cache<String, String> cache2 = cacheManager.getCache("default");

            AdvancedCache ac = cache2.getAdvancedCache();

            TransactionManager tm = cache2.getAdvancedCache().getTransactionManager();

获取缓存#2的代码：

            // Not using EntityManagerFactory here, because otherwise the test-infinispan.xml is already loaded.
            EmbeddedCacheManager cacheManager = new DefaultCacheManager("./resources/test-infinispan.xml");

            final Cache<String, String> cache = cacheManager.getCache("default");
            TransactionManager tm = cache.getAdvancedCache().getTransactionManager();

我在tm初始化后使用的代码：

            try {
                tm.begin();
                
                if (cache.get("test1") != null) { 
                    System.out.println("FOUND IN CACHE: test1"); 
                } 

                cache.put("test1", "test1");

                tm.commit();

            } catch (Exception e) {
                try {
                    tm.rollback();
                } catch (Exception e2) {
                }
            } finally {
                cacheManager.stop();
            }

使用#2，我可以获得“默认”缓存并向其中添加项目。事务管理器tm不为空，所以这一切都很好。重新启动后，保存在缓存中的数据再次可用。

在#1中，事务管理器tm为空。使用TransactionManager的另一个实例，我可以将项添加到缓存中，但它们在重新启动后不再可用。我还尝试使用@Cacheable region。

Persistence.xml中使用的属性：

            <property name="hibernate.ogm.infinispan.configuration_resource_name" value="test-infinispan.xml" />
            <property name="hibernate.search.default.directory_provider" value="infinispan" />
            <property name="hibernate.search.infinispan.configuration_resourcename" value="test-infinispan-index.xml" />

            <property name="hibernate.cache.use_second_level_cache" value="true"></property>
            <property name="hibernate.cache.use_query_cache" value="true"></property>
            <property name="hibernate.cache.region.factory_class" value="org.infinispan.hibernate.cache.v53.InfinispanRegionFactory"></property>
            <property name="hibernate.cache.inifinispan.statistics" value="true"></property>
            <property name="hibernate.cache.default_cache_concurrency_strategy" value="transactional"></property>

            <property name="hibernate.search.services.jgroups.configurationFile" value="test-jgroups-tcp-static-cluster.xml" />
            <property name="hibernate.search.services.jgroups.clusterName" value="default-test-index-cluster-2" />

EntityManagerFactory加载持久性单元"mytest“，并从persistence.xml、InfiniSpan配置、InfiniSpan索引配置开始初始化整个结构。和jgroups配置。

test-infinispan.xml：

    <cache-container name="Database-Container" default-cache="default" statistics="false" shutdown-hook="DONT_REGISTER">
<transport stack="default-tcp-static-cluster" cluster="default-test-cluster" /> 
        <replicated-cache name="default" mode="SYNC" remote-timeout="480000">
            <locking striping="false" acquire-timeout="120000" concurrency-level="500" isolation="REPEATABLE_READ" />
            
            <transaction locking="PESSIMISTIC" auto-commit="false" mode="FULL_XA" transaction-manager-lookup="org.infinispan.transaction.lookup.JBossStandaloneJTAManagerLookup"/>
           <indexing index="NONE"></indexing>
            <memory>
                <object size="-1" />
            </memory>
            <expiration max-idle="-1" />

            <state-transfer enabled="true" timeout="480000" await-initial-transfer="true" />
            <persistence  passivation="false">
                <file-store shared="false" preload="false" fetch-state="true" read-only="false" purge="false" path="./database_data/DEFAULT">
                    <write-behind modification-queue-size="5" fail-silently="false"/>
                </file-store>
            </persistence>
        </replicated-cache> 
</cache-container>

我需要什么才能获得示例#1中的“默认”缓存？或者这是不可能的？或者我需要使用区域(使用@Cacheable注解)吗?如果需要，我需要什么才能使缓存变得短暂？持久化，所以我可以在重启后重新加载数据。

Answer 1

我坚持使用这种方法来获得一个缓存管理器：

EmbeddedCacheManager cacheManager =新DefaultCacheManager("my-cache.xml")；

具有在单独的xml文件中指定的高速缓存。这看起来就是我需要的。