java - Ignite AtomicSequence - 重置sequenceName值

Question

我有一个 Java 应用程序，它作为客户端使用以下原子序列代码连接到 Ignite

@Bean("id")
public IgniteAtomicSequence igniteAtomicSequence(Ignite ignite){
    return ignite.atomicSequence("id", 0, true);
}

我用初始值0启动了客户端。因此sequenceName是在ignite中创建的，我可以使用apiincrementAndGet()每次都获取新值。

现在我的应用程序已停止并作为客户端重新连接，我想使用新的序列值 4000 或任何其他特定值重新启动。但这不起作用。我使用 apiincrementAndGet() 得到的值仍然低于 4000。

@Bean("id")
public IgniteAtomicSequence igniteAtomicSequence(Ignite ignite){
    return ignite.atomicSequence("id", 4000, true);
}

有什么方法可以在不重新启动 ignite 集群的情况下更新 Ignite 序列值吗？

Answer 1

您可以关闭当前的原子序列并创建一个新的。

IgniteAtomicSequence id = ignite.atomicSequence("id", 4000, true); 
id.close();
id = ignite.atomicSequence("id", 1, true);
// should be 2
assert id.incrementAndGet() == 2;

引用:https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/IgniteAtomicSequence.html#close--