Ignite ClusterGroup.forAttribute 适用于客户端节点？

Question

我刚刚在另一个问题中了解到，我可以在客户端节点上运行计算任务，这很棒。 但是，我不想在所有客户端上执行任务，只在选定的客户端节点上执行。我通过配置中的属性来识别节点：

<property name="userAttributes">
    <map>
        <entry key="Role" value="FOR_COMPUTE" />
    </map>
</property>

然后我使用：

ignite.cluster().forClients().forAttribute("Role", "FOR_COMPUTE");

这似乎没有让我与那些设置了属性的客户端组成一个集群组。这不适用于客户端节点吗？

Answer 1

用户属性确实有效。 仔细检查您的设置。确保您使用正确的配置启动客户端。

运行以下测试：

        IgniteConfiguration serverConfig = new IgniteConfiguration();
        serverConfig.setIgniteInstanceName("server");
        Ignition.start(serverConfig);


        IgniteConfiguration clientConfig = new IgniteConfiguration();
        clientConfig.setClientMode(true);
        clientConfig.setIgniteInstanceName("client");

        Map<String, String> userAttributes = new HashMap<>();
        userAttributes.put("Role", "FOR_COMPUTE");
        clientConfig.setUserAttributes(userAttributes);


        Ignite ignite = Ignition.start(clientConfig);
        System.out.println("Role user attribute value: " + ignite.cluster().localNode().attribute("Role"));
        ClusterGroup filteredNodes = ignite.cluster().forClients().forAttribute("Role", "FOR_COMPUTE");
        for (ClusterNode node:  filteredNodes.nodes()) {
            System.out.println("filtered id: "+ node.id());
        }

您应该会看到正确的结果。