将Hazelcast用于Hibernate的Spring Session和2级缓存LC2

如何解决将Hazelcast用于Hibernate的Spring Session和2级缓存LC2

所以我想在Web应用程序中同时使用Hazelcast进行2级缓存（休眠层）和春季会话，设置非常简单，我希望能够将NearCache配置与网络上运行的服务器一起使用。

我首先遇到了兼容性问题，春季会议尚不支持Hazelcast 4. *的最新版本，因此我很高兴使用受支持的版本：3.12.6 ... 下面是我的hazelcast-client.xml，我已正确配置它，以便在启动应用程序时供 spring.hazelcast.config = file：// ... 使用Hazelcast实例未创建，因此我决定应该使用以下命令自己创建 ClientConfig 和 HazelcastInstance Bean下面的代码：

@Bean()
ClientConfig clientConfig() throws IOException{
    try(final InputStream stream = Files.newInputStream(Paths.get("proper-path/hazelcast-client.xml"))){
      com.hazelcast.client.config.XmlClientConfigBuilder builder = new com.hazelcast.client.config.XmlClientConfigBuilder(stream);
      return builder.build();
    }
  }
@Bean()
HazelcastInstance hazelcastInstance(final ClientConfig clientConfig){
    return HazelcastClient.newHazelcastClient(clientConfig);
}

现在我有一个问题，我无法在下面添加代码，因此可以在会话中使用它：

final MapAttributeConfig attributeConfig = new MapAttributeConfig()
            .setName(HazelcastIndexedSessionRepository.PRINCIPAL_NAME_ATTRIBUTE)
            .setExtractor(PrincipalNameExtractor.class.getName());

hazelcastInstance.getConfig().getMapConfig(HazelcastIndexedSessionRepository.DEFAULT_SESSION_MAP_NAME)
        .addMapAttributeConfig(attributeConfig)
        .addMapIndexConfig(new MapIndexConfig(HazelcastIndexedSessionRepository.PRINCIPAL_NAME_ATTRIBUTE,false));  

hazelcast-client.xml

    <?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-3.12.xsd">
    <group>
        <name>GroupName</name>
        <password>pass</password>
    </group>
    <instance-name>${application.container.name}</instance-name>
    <properties>
        <property name="hazelcast.client.shuffle.member.list">true</property>
        <property name="hazelcast.client.heartbeat.timeout">60000</property>
        <property name="hazelcast.client.heartbeat.interval">5000</property>
        <property name="hazelcast.client.event.thread.count">5</property>
        <property name="hazelcast.client.event.queue.capacity">1000000</property>
        <property name="hazelcast.client.invocation.timeout.seconds">120</property>
    </properties>
    <client-labels>
        <label>web-app</label>
        <label>${application.container.name}</label>
    </client-labels>
    <network>
        <cluster-members>
            <address>127.0.0.1</address>
        </cluster-members>
        <outbound-ports>
            <ports>5801</ports>
        </outbound-ports>
        <smart-routing>true</smart-routing>
        <redo-operation>true</redo-operation>
        <connection-timeout>60000</connection-timeout>
        <connection-attempt-period>3000</connection-attempt-period>
        <connection-attempt-limit>2</connection-attempt-limit>
        <socket-options>
            <tcp-no-delay>false</tcp-no-delay>
            <keep-alive>true</keep-alive>
            <reuse-address>true</reuse-address>
            <linger-seconds>3</linger-seconds>
            <buffer-size>128</buffer-size>
        </socket-options>
    </network>
    <executor-pool-size>40</executor-pool-size>
    <native-memory enabled="false" allocator-type="POOLED">
        <size unit="MEGABYTES" value="128"/>
        <min-block-size>1</min-block-size>
        <page-size>1</page-size>
        <metadata-space-percentage>40.5</metadata-space-percentage>
    </native-memory>
    <load-balancer type="random"/>
    <flake-id-generator name="default">
        <prefetch-count>100</prefetch-count>
        <prefetch-validity-millis>600000</prefetch-validity-millis>
    </flake-id-generator>
    <connection-strategy async-start="true" reconnect-mode="ASYNC">
        <connection-retry enabled="true">
            <initial-backoff-millis>2000</initial-backoff-millis>
            <max-backoff-millis>60000</max-backoff-millis>
            <multiplier>3</multiplier>
            <fail-on-max-backoff>true</fail-on-max-backoff>
            <jitter>0.5</jitter>
        </connection-retry>
    </connection-strategy>

   </hazelcast-client>

解决方法

您需要在服务器端配置映射，这意味着您需要在成员的类路径上具有一些Spring类。但是请记住，仅在使用HazelcastIndexedSessionRepository#findByIndexNameAndIndexValue时才需要此配置。

在客户端模式下，请不要忘记部署必要的类并为成员启用用户代码部署。否则会话更新将失败：

// member
config.getUserCodeDeploymentConfig().setEnabled(true)
      .setClassCacheMode(UserCodeDeploymentConfig.ClassCacheMode.ETERNAL);

// client
clientConfig.getUserCodeDeploymentConfig().setEnabled(true).addClass(Session.class)
            .addClass(MapSession.class).addClass(SessionUpdateEntryProcessor.class);

但是我建议在成员的cp上包括spring-session-hazelcast，而不是用户代码部署。这将满足上述两个需求。

最后，如果项目中的已知路径之一（例如，在hazelcast-client.xml下）存在resources/，则将使用此配置创建客户端。在这种情况下，您无需创建ClientConfig bean。