我无法理解 Hazelcast 分布式执行的概念。据说能够对特定密钥的所有者实例执行执行。
来自文档:
<T> Future<T> submitToKeyOwner(Callable<T> task, Object key)
Submits task to owner of the specified key and returns a Future representing that task.
Parameters:
task - task
key - key
Returns:
a Future representing pending completion of the task
Run Code Online (Sandbox Code Playgroud)
我相信我并不是唯一拥有一个由多个映射构建的集群的人,这些映射实际上可能使用相同的密钥用于不同的目的,持有不同的对象(例如,以下设置中的某些内容):
IMap<String, ObjectTypeA> firstMap = HazelcastInstance.getMap("firstMap");
IMap<String, ObjectTypeA_AppendixClass> secondMap = HazelcastInstance.getMap("secondMap");
Run Code Online (Sandbox Code Playgroud)
对我来说,文档中关于密钥所有者的描述似乎很令人困惑。我真正的沮丧是我不知道它指的是哪个 - 在哪个地图 - 键?
该文档还给出了这种方法的“演示”:
import com.hazelcast.core.Member;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.IExecutorService;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.Set;
import com.hazelcast.config.Config;
public void echoOnTheMemberOwningTheKey(String input, Object key) throws Exception …Run Code Online (Sandbox Code Playgroud)