如何使用 JCache 在客户端-服务器拓扑中使用 Hazelcast？答案

【问题标题】：How to work with Hazelcast in client-server topology with JCache?如何使用 JCache 在客户端-服务器拓扑中使用 Hazelcast？
【发布时间】：2021-09-03 16:50:56
【问题描述】：

我正在使用 Jakarta EE 8、JCache API 1.1.1 和 Hazelcast 客户端 4.2.1 和服务器（试用 4.2.1 和 5.0-beta）。我为缓存管理器创建了提供程序：

@ApplicationScoped
public class MyCacheManager {

   private CacheManager manager;

   @Produces
   public CacheManager getCacheManager() {
       if (manager == null) {
           var provider = Caching.getCachingProvider();
           manager = provider.getCacheManager();
       }
       return manager;
   }

   public void close(@Disposes final CacheManager instance) {
       var provider = instance.getCachingProvider();
       provider.close();
   }
}

这样我创建缓存：

@ApplicationScoped
public class SessionCacheBean extends CacheBean{
    @Inject
    private CacheManager manager;
    @Override
    protected Cache getCache() {
        if (manager.getCache("session-cache") == null) {
            var config = new MutableConfiguration<String, Object>();
            config.setTypes(String.class, Object.class);
            config.setStoreByValue(true);
            config.setExpiryPolicyFactory(TouchedExpiryPolicy.factoryOf(
                    new Duration(TimeUnit.MINUTES, 30)));
            return manager.createCache("session-cache", config);
        } else {
            return manager.getCache("session-cache");
        }
    }
}

如果应用程序配置为集群成员，此代码可以正常工作。但现在它被配置为客户端：

<?xml version="1.0" encoding="UTF-8"?>
<hazelcast-client xmlns="http://www.hazelcast.com/schema/client-config"
                  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
                  xsi:schemaLocation="http://www.hazelcast.com/schema/client-config
                  http://www.hazelcast.com/schema/client-config/hazelcast-client-config-5.0.xsd">
    <cluster-name>mimedia-session</cluster-name>
    <network>
        <aws enabled="true">
            <access-key>*****</access-key>
            <secret-key>*****</secret-key>
            <region>****</region>
            <tag-key>****</tag-key>
            <tag-value>****</tag-value>
            <use-public-ip>true</use-public-ip>
        </aws>
    </network>
</hazelcast-client>

服务器以命令sudo hz start -c /usr/share/hazelcast4/bin/hazelcast.xml -j /lib/cache-api-1.1.1.jar 和相同的hazelcast.xml 启动：

<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-4.2.xsd">

    <cluster-name>mimedia-session</cluster-name>

    <network>
        <port auto-increment="true" port-count="100">5701</port>
        <join>
            <auto-detection enabled="true"/>
            <multicast enabled="false"/>
            <aws enabled="true">
                <tag-key>****</tag-key>
                <tag-value>****</tag-value>
            </aws>
        </join>
    </network>
    <cache name="session-cache">
        <key-type class-name="java.lang.String"/>
        <value-type class-name="java.lang.Object"/>
        <management-enabled>true</management-enabled>
        <expiry-policy-factory>
            <timed-expiry-policy-factory expiry-policy-type="TOUCHED"
                                                    duration-amount="30"
                                                    time-unit="MINUTES"/>
        </expiry-policy-factory>
    </cache>
</hazelcast>

现在应用程序在 if (manager.getCache("session-cache") == null) 行返回错误

"java.io.InvalidClassException: javax.cache.configuration.FactoryBuilder$SingletonFactory; local class incompatible: stream classdesc serialVersionUID = 201305101634, local class serialVersionUID = 201402"

当我在服务器配置应用程序中删除 <cache name="session-cache"> 时，return manager.createCache("session-cache", config); 行返回错误

"java.io.InvalidClassException: javax.cache.configuration.FactoryBuilder$SingletonFactory; local class incompatible: stream classdesc serialVersionUID = 201402, local class serialVersionUID = 201305101634"

我需要在哪里修复类不匹配？

【问题讨论】：

该异常表示Serializable 类的序列化形式不兼容。您可以发布完整的堆栈跟踪吗？这应该包括关于在抛出异常时正在序列化哪个类的提示。

标签： java hazelcast jcache

【解决方案1】：

我认为问题在于我使用的是 TomEE。因为serialVersionUID = 201402 位于geronimo-jcache_1.0_spec，但我在我的项目中使用jsr107spec。一旦找到解决此问题的方法，我将更新答案。

更新

解决方法：我为 TomEE 创建了用作服务器的“cache-server.war”

【讨论】：