问题标签 [hazelcast-imap]

我的应用程序基于 spring boot + hazelcast。

我正在尝试将简单实体保存到 hazelcast 中：

我的服务方法如下所示：

当我尝试存储我收到com.hazelcast.nio.serialization.HazelcastSerializationException的带有跟踪的实体时：

这是我的榛树配置：

请告诉我如何解决这个问题。

更新：

如果您的集群成员包含一个对象的旧版本（旧库、未更新的对象等），由于库管理不正确，您可能会进入 IMAP 重复条目（从模型对象的角度来看） ...

如果您有 IMAP，例如， IMAP<MyKey, MyValue> 不同版本的MyKey，MyValue可以混合......

1. 当你对一个旧版本的对象进行 GET 操作时，你会得到一个 HazelcastSerializationException: java.io.InvalidClassException
2. 当您执行 PUT 时，您不会有任何异常？.....:(

有什么办法可以控制这个？

感谢你！

我有一个配置了 Mapstore 的 IMap，似乎当我从多个线程从 IMap 获取时，它只需要获取 1 次就可以正确运行，其他会自动命中。所以我想知道当尝试从缓存中获取时，Imap 是否会自动开启锁定机制，但我读到的任何地方都没有真正确认这一点，但它的行为就像它有锁定一样。

有人可以证实这一点吗？

我有一个成员，它有一个读取/写入数据库的 MapStore/Loader 以及一个添加 EntryAddedListener 侦听器的客户端。

如果该成员被退回，我会看到条目添加的侦听器被触发，因为 MapLoader 从数据库重新加载数据。

然而，这向客户端表明已经添加了新条目，而实际上，它们只是因为节点引导而被“添加”。

基本上我不希望这些侦听器因 MapLoader 引导地图而被触发——它们应该只在之后被触发。

如何阻止这些 MapLoader 事件触发 EntryAdded 侦听器？

我是使用 Hazelcast 的新手。我在我的 Web 应用程序中使用 Hazelcast 3.6-EA 作为数据存储。该应用程序将在多个实例上运行，因此当多个线程尝试使用同一个 Map 时，我需要实现锁定机制以避免竞争条件。

期望的行为如下：开始使用 Map 的第一个实例应该锁定它并执行所需的更新。另一个实例应该看到 Map 已锁定并跳过执行任何更新。

因此，这种锁定的主要好处应该是避免两次执行相同的代码。

我怀疑我是否正确理解了锁定机制，以及上面实施的行为是否给了我想要的结果。

我会很感激任何详细的解释。

另外，告诉我，如果线程锁定地图，而另一个只是执行get(key)操作，会有什么行为？

我是榛树和骆驼的新手。在使用骆驼创建地图加载器时，我在“加载”方法中调用骆驼路线。虽然容器显示“dataSyncLoad”容器存在，但仍然在应用程序启动时加载数据时，它给出了下面列出的错误。

Hazelcast 地图加载器

地图配置

//数据同步加载]。Exchange[消息：CellDataSyncKey [locoid=20695，dataTemplate=3，deviceName=CCA]] 在 org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:47)[142:org.apache.camel.camel -core:2.12.0.redhat-610379] 在 org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[142:org.apache.camel.camel-core:2.12.0.redhat-610379 ] 在 org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:73)[142:org.apache.camel.camel-core:2.12.0.redhat-610379] 在 org.apache.camel.impl。 ProducerCache$2.doInProducer(ProducerCache.java:378)[142:org.apache.camel.camel-core:2.12.0.redhat-610379] at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java: 346)[142:org.apache.camel.camel-core:2.12.0.redhat-610379] 在 org.apache.camel.impl。

我有一个包含两个成员的集群，这些成员具有到数据库的映射加载器。

3.6.1 版在启动过程中没有显示任何问题 - 但是当我升级到 3.7 时，出现了很多如下所示的异常 - 并且集群无法启动！

任何想法是什么意思？谢谢

14:32:50.613)，waitTimeout=-1，callTimeout=60000，name=TRADE_SETTLEMENT}，tryCount=250，tryPauseMillis=500，invokeCount=240，callTimeoutMillis=60000，firstInvocationTimeMs=1473427838152，firstInvocationTime='2016-09-09 14 :30:38.152', lastHeartbeatMillis=0, lastHeartbeatTime='1970-01-01 01:00:00.000', target=[xxx.co.uk]:5702, pendingResponse={VOID}, backupsAcksExpected=0, backupsAcksReceived=0 ，连接 = null}，原因：com.hazelcast.spi.exception.RetryableHazelcastException：地图 TRADE_SETTLEMENT 仍在从外部存储加载数据 2016 年 9 月 9 日下午 2:32:50 com.hazelcast.spi.impl.operationservice.impl.Invocation

我们将 hazelcast 2.5 作为集群运行，以通过应用程序复制对象。目前有 1 个生产者和 3 个消费者。来自 writer 的更新高达每分钟 10000 次，消费者每秒读取一次，以在集群地图中搜索更新。writer 是一个 java 原生应用程序，在带有 java 7 的 Debian 8 服务器下运行。hazelcast 服务器位于同一个服务器上机器作为生产者，但在独立的应用程序上。所有的消费者都是在 Debian 8 机器下运行 java 7 的 tomcat 7 应用程序。我们面临的问题是，平均大约 4% 的集群数据到达消费者端，在共享地图中出现乱码。生产者的代码如下：

其中 HazelCastobjGpsData datoGps; 是消费者要救援的对象，HazelCast.instMapGPS.put(current.getImei(), datoGps); 是有问题的地图。它有一把钥匙。

服务器的代码如下：

}

消费者代码如下

请注意，消费者只取出最近更新的数据，这样做是因为有一个更新了键的映射，一旦数据出来，键就会从该映射中删除。

以下是对象的代码

我们知道我们正在使用旧版本的 hazelcast，但升级它还不是一个选项，我们想先知道是否存在代码问题。你能帮我找到问题吗？

我正在尝试将数据同步存储在缓存和 mongoDB 中。我得到了这个例外

我有 POJO 类包含两个字符串，我正在使用 com.hazlecast.core.Mapstore 库

主类

/////道类

////地图存储类

我需要在 IMap 中动态添加某些类型为字符串、日期、int 的可移植字段的索引。

1. 首先，在向包含某些条目的 Map 添加索引时，会引发 Hazelcast 未处理异常，说明找不到工厂 ID 的 PortableFactory：XXX。
2. 其次，我在将条目加载到地图之前尝试了另一种添加索引的方法，在添加索引时没有发现任何问题，但是在再次设置条目时，我遇到了与上述相同的异常。但令人惊讶的是，我在地图内发现了一个异常情况的记录。

是否为期望在服务器端的类定义的可移植对象添加索引？但是对于便携式序列化，不需要按照文档在服务器端定义类。

会员配置：

请在下面找到客户端代码：