当前位置: 首页 > 知识库问答 >
问题:

hazelcast AtomicInteger增量未更新

夏俊杰
2023-03-14

我正在尝试使用Hazelcast的映射实现一个简单的计数器。我初始化了一个映射,如下所示

HazelcastInstance hz = HazelcastClient.newHazelcastClient();
IMap<Long, AtomicInteger> map = hz.getMap("my-distributed-map");
map.putIfAbsent(testKey, new AtomicInteger(0));

当我尝试递增计数器(AtomicInteger)时,映射似乎根本没有更新(即使在本地也没有)。

map.get(testKey).incrementAndGet();
private final ConcurrentMap<Long, AtomicInteger> map = new ConcurrentHashMap<>();

共有1个答案

訾淇
2023-03-14
Map.put(key, value);
AtomicInteger counter = map.get(testKey).incrementAndGet();
map.put(key, counter);

对象的变化不会反映在成员/服务器实例中(它不是本地引用,它是分布式对象)。

 类似资料:
  • 如何使用数据砖增量从其他表中更新表中的多个记录。 我想达到这样的目标: 它失败并出现错误:不匹配的输入“发件人”期望

  • 运行我的桌面项目时,我有时会收到这个错误: < code >未跟踪更改,无法确定增量更改。 我尝试过使用和。我使用的是。 我尝试过这里提到的更改,但它们似乎是针对Kotlin项目的。 我正在努力寻找更多导致这种情况的信息。 我还可以尝试什么来解决此问题?

  • 当运行我的android项目时,如何知道这个错误的原因?无法确定 null

  • 我用Kafka和spring-布特: Kafka制作人班: Kafka-配置: 问题: 我有一个主题的5个分区,比方说。 发生的情况是,我获得成功(即消息成功发送到Kafka)日志,但是topic的无分区的偏移量增加。 正如您在上面看到的,我添加了日志和。我所期望的是,当Kafka不能发送消息给Kafka时,我应该得到一个错误,但在这种情况下,我没有收到任何错误消息。 Kafka的上述行为以的比例

  • 问题内容: 我正在做一些有关Java的研究,发现这很令人困惑: 这是永无止境的循环! 有人很好地解释了为什么会发生这种事情吗? 问题答案: 上面的循环与以下内容基本相同:- 3 次你的一部分声明- ,被评估为: - 您需要从此处删除分配,以使其起作用:- (根据评论的OP请求) 的行为:- 就注释中指定的问题而言,以下表达式的结果:- 获得如下:- 让我们标记第二条语句的不同部分:- 现在,首先将

  • 我正在尝试与使用Stripe的Laravel出纳一起实现数量增量。我可以在创建新订阅时设置数量,如下所示: 但是,当我尝试更新数量号到现有的订阅,它不工作: 当我转到条纹的支付页面时,它仍然在1个数量上,并且没有显示那里增加的数量。我哪里错了?我应该获得令牌并在更新时再次传递令牌吗?我读了Laravel文档,并遵循它说:http://laravel.com/docs/5.1/billing#sub