Блог

Я использую Hibernate 5.4.22 с Infinispan 11.0.4 в кластерной среде. Переход в спящий режим кэша второго уровня настроен на использование поставщика JCache:

     hbProps.setProperty("hibernate.cache.use_minimal_puts", "false");
    hbProps.setProperty("hibernate.cache.use_structured_entries", "false");
    hbProps.setProperty("hibernate.cache.use_query_cache", "false");
    hbProps.setProperty("hibernate.cache.use_second_level_cache", "true");
    hbProps.setProperty("hibernate.cache.region.factory_class", "org.hibernate.cache.jcache.JCacheRegionFactory");
    hbProps.setProperty("hibernate.javax.cache.provider", "org.infinispan.jcache.embedded.JCachingProvider");
  

Infinispan настроен следующим образом infinispan.xml:

 <infinispan
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="urn:infinispan:config:11.0 http://www.infinispan.org/schemas/infinispan-config-11.0.xsd"
      xmlns="urn:infinispan:config:11.0">
      
      <jgroups>
          <stack name="jgroups-stack">
              <TCP bind_port="7800"
                   recv_buf_size="${tcp.recv_buf_size:130k}"
                   send_buf_size="${tcp.send_buf_size:130k}"
                   max_bundle_size="64K"
                   sock_conn_timeout="300"
          
                   thread_pool.min_threads="0"
                   thread_pool.max_threads="20"
                   thread_pool.keep_alive_time="30000"/>
          
<!--              <TCPPING async_discovery="true"
                       initial_hosts="${jgroups.tcpping.initial_hosts:localhost[7800],localhost[7801]}"
                       port_range="2"/>-->
              <MPING/>
              <MERGE3  min_interval="10000"
                       max_interval="30000"/>
              <FD_SOCK/>
              <FD_ALL timeout="9000" interval="3000" />
              <VERIFY_SUSPECT timeout="1500"  />
              <BARRIER />
              <pbcast.NAKACK2 use_mcast_xmit="false"
                             discard_delivered_msgs="true"/>
              <UNICAST3 />
              <pbcast.STABLE desired_avg_gossip="50000"
                             max_bytes="4M"/>
              <pbcast.GMS print_local_addr="false" join_timeout="2000"/>
              <UFC max_credits="2M"
                   min_threshold="0.4"/>
              <MFC max_credits="2M"
                   min_threshold="0.4"/>
              <FRAG2 frag_size="60K"  />
              <!--RSVP resend_interval="2000" timeout="10000"/-->
              <pbcast.STATE_TRANSFER/>                    
          </stack>
      </jgroups> 
      
      <cache-container>
          <!-- turn off metrics -->
          <metrics gauges="false" histograms="false"/>
          <jmx enabled="true"/>
          <transport stack="jgroups-stack" cluster="infinispan-hibernate-cluster"/>
          
          <serialization marshaller="org.infinispan.commons.marshall.JavaSerializationMarshaller">
            <white-list>
              <regex>.*</regex>
            </white-list>   
          </serialization>
          
<!--          <replicated-cache name="MainCache" mode="SYNC"> 
            <memory max-count="100000"/>
            <expiration max-idle="3600000" lifespan="-1"/>
          </replicated-cache>-->

          <invalidation-cache name="MainCache" mode="SYNC">
            <memory max-count="100000"/>
            <expiration max-idle="3600000" lifespan="-1"/>
          </invalidation-cache>
      </cache-container>
</infinispan>
  

У меня есть тестовый объект «Profile», который должен кэшироваться со read-write стратегией:

 <hibernate-mapping>

  <class name="hibernatetest.Profile" table="Profiles" lazy="false">
    <cache usage="read-write" region="MainCache"/>
    <id column="id" name="id" unsaved-value="0">
      <generator class="native"/>
    </id>
    <discriminator column="type" type="string"/>
    <version name="version"/>
    <property name="name" type="string" length="100"/>
    <property name="available" type="yes_no"/>
  </class>
  
</hibernate-mapping>
  

Согласно таблице совместимости стратегии параллелизма кэша и режима кэша, комбинация <cache usage="read-write"> и <invalidation-cache> должна быть рабочим сценарием. В моих тестах у меня есть один узел, который непрерывно считывает объект, и один узел, который обновляет тот же объект. Я обнаружил, что узел чтения никогда не получает уведомления о том, что объект изменился, чтобы снова прочитать его из базы данных. Просматривая журнал, кажется, что кеш недействительности на узле записи не отправляет никаких сообщений на узел чтения.

Однако, если я изменю infinispan.xml чтобы использовать <replicated-cache> или <distributed-cache> вместо <invalidation-cache> , тогда узел чтения получает уведомление об изменении, внесенном узлом записи. Итак, я предполагаю, что это означает, что проблема не в jgroups.

Это проблема в кеше недействительности или я что-то упускаю в своей конфигурации?

Вот файл журнала экземпляра, который считывается из кэша недействительности inv-read.txt и файл журнала экземпляра, который обновляет кэш inv-update.txt .

Спасибо!

Проблема заключается в использовании JCache — таблица предполагает InfinispanRegionFactory вместо JCacheRegionFactory.

Похоже, что в Infinispan нет модуля для явной поддержки Hibernate 5.4 — я бы предположил, что модули для поддержки Hibernate 5.3 должны работать даже с Hibernate 5.4, поскольку в Hibernate 5.4 не произошло особых изменений в области кэша второго уровня.

Я удивлен, что 2LC вообще работает с JCache с реплицируемыми / распределенными кэшами — я был бы уверен, что он не работает «надежно» (транзакционно, охватывая крайние случаи и т. Д.) В любом случае.