4

我正在使用 Hazelcast 来缓存 JMS 主题。

在某种程度上，一切都很好。运行大约 30-40 分钟后，我开始得到：

WARNING: [192.168.3.102]:5701 [devGroup] RedoLog{key=Data{partitionHash=-1465305045} size= 10, operation=CONCURRENT_MAP_PUT_IF_ABSENT, target=Address[192.168.3.102]:5701, targetConnected=false, redoCount=910, migrating=null
partition=Partition [186]{
0:Address[192.168.3.102]:5701
}
}

据我从开发论坛中了解到，这些是重做警告，这意味着 Hazelcast 无法连接到指定的实例target=Address[192.168.3.102]:5701来分发缓存。

然而奇怪的是，我的配置只有一个节点，即当前服务器实例：

INFO: [192.168.3.102]:5701 [devGroup] 
Members [1] {
    Member [192.168.3.102]:5701 this
}

我正在使用spring来配置它：

<hz:hazelcast id="hazelcastInstance">
    <hz:config>
        <hz:group
                name="devGroup"
                password="pass"/>
        <hz:properties>
            <hz:property name="hazelcast.merge.first.run.delay.seconds">5</hz:property>
            <hz:property name="hazelcast.merge.next.run.delay.seconds">5</hz:property>
        </hz:properties>
        <hz:network port="5701" port-auto-increment="true">
            <hz:join>
                <hz:multicast enabled="false" />    
                <hz:tcp-ip enabled="true">
                    <hz:members>192.168.3.102</hz:members>
                </hz:tcp-ip>
            </hz:join>
            <hz:symmetric-encryption enabled="true"
                                     algorithm="PBEWithMD5AndDES"
                                     salt="thesalt"
                                     password="thepass"
                                     iteration-count="19"/>
            <hz:asymmetric-encryption enabled="false"
                                      key-password="thekeypass"
                                      key-alias="local"
                                      store-type="JKS"
                                      store-password="thestorepass"
                                      store-path="keystore"/>
        </hz:network>
    </hz:config>
</hz:hazelcast>

我正在使用 Hazelcast 2.1、Spring 3.1 和 Tomcat 7

那么有人知道我为什么会收到警告吗？

谢谢，

要回答评论：

我这样使用它：

final ConcurrentMap<K, V> cachedMap = getHazelcast().getMap(region);
cachedMap.putIfAbsent(key, value);

该getHazelcast()方法通过spring返回注入HazelcastInstance的（上面配置中的那个，我检查了bean id，看起来没问题）。

更新 2。

以编程方式添加的地图上有一个最大尺寸：

final MapConfig mapConfig = hazelcast.getConfig().getMapConfig(region);

.... val is calculated here ....

mapConfig.getMaxSizeConfig().setSize(val);

val不能低于 25000

但是，我尝试过没有大小配置，但仍然收到警告。

我也用来map.values(SqlPredicate(""))按日期获取值。

4

1 回答 1

5

如果max-size为映射定义，put映射到达后的操作max-size将进入redo循环，直到映射大小减小到最大大小以下才能插入新条目。

您应该从地图中删除一些值，或者您应该为该地图定义某种驱逐。我的意思是您可以定义以下一项或多项；

  • 设置一个eviction-policy和eviction-percentage
  • 设置一个time-to-live-seconds
  • 设置一个max-idle-seconds

有关更多信息，请参阅Hazelcast 地图驱逐

于 2012-07-19T11:10:42.443 回答