Hazelcast не загружает распределенные записи карты - PullRequest
0 голосов
/ 11 сентября 2018

мы используем распределенную карту Hazelcast в нашем проекте.После доставки он просто перестал читать из базы данных записи .Хранение работ.Локально мы не могли воспроизвести проблему.

Мы попытались перезапустить сервер или очистить таблицу базы данных, но не сработало.Карта всегда пуста:

    @Autowired
    @Qualifier("hazelcast")
    private transient HazelcastInstance hazelcastInstance;
    ....
    hazelcastInstance.getMap(MAP_NAME).keySet() ;//is empty

Конфигурация Hazelcast для карты:

<hz:hazelcast id="hazelcast">
        <hz:config>
            <hz:group name="${hazelcast.clustername}" password="${hazelcast.password}" />
            <hz:properties>
                <hz:property name="hazelcast.logging.type">slf4j</hz:property>
                <hz:property name="hazelcast.jmx">${hazelcast.jmx:true}</hz:property>
            </hz:properties>
            <hz:network port="${hazelcast.port:8801}"
                port-auto-increment="${hazelcast.auto-increment:true}">
                <hz:join>
                    <hz:multicast enabled="${hazelcast.multicast-enabled:false}"
                        multicast-group="${hazelcast.multicast-group}"
                        multicast-port="${hazelcast.multicast-port}" />
                    <hz:tcp-ip enabled="${hazelcast.tcp-ip-enabled:true}">
                        <hz:members>${hazelcast.tcp-ip-members}</hz:members>
                    </hz:tcp-ip>
                </hz:join>
            </hz:network>    
<hz:map name="maps.*" backup-count="2" max-size="0" eviction-percentage="30" read-backup-data="true" eviction-policy="NONE" merge-policy="com.hazelcast.map.merge.PassThroughMergePolicy">
            <hz:map-store enabled="true" write-delay-seconds="0" implementation="persistenceProvider"/>
        </hz:map>

Наше приложение основано на Spring.Класс PersistenceProvider просто реализует com.hazelcast.core.MapLoader и com.hazelcast.core.MapStore для обработки записей в базе данных.

@Component
public class PersistenceProvider implements MapLoader<Key, Value>, MapStore<Key, Value> {...}

В журналах я видел только эту запись, которая может бытьявляется или не релевантным:

[hz._hzInstance_1_Cluster.cached.thread-2] INFO  com.hazelcast.nio.tcp.TcpIpConnector.log | [xxx]:8801 Could not connect to: /yyy:8802. Reason: SocketException[Verbindungsaufbau abgelehnt to address /yyyy:8802]
[hz._hzInstance_1_Cluster.cached.thread-2] INFO  c.hazelcast.cluster.impl.TcpIpJoiner.log | [xxx]:8801 [xxx]:8802 is added to the blacklist.

Напоминаем: код работал раньше, работает локально, но теперь в этой среде хранит только данные Hazelcast, но не загружает их!

Я новичокHazelcast, и мне было интересно, если это может быть проблема с кешем или что-то, что мы можем изменить в конфигурации.

Важно разблокировать это, так как клиент не может использовать приложение.

Сделайтеу тебя есть идеи?

...