0

我正在尝试通过一个简单的 for 循环将 x 个对象添加到分布式 hazelcast 队列（IQueue）。

        HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance();
        BlockingQueue<String> configs = hazelcastInstance.getQueue("test"); 
        for(int i = 0; i<1000;i++) {
            configs.add("Some string"+i);
        }

更改值和配置（见下文）对执行速度没有任何影响。我假设增加会阻止插入操作，而增加不会（实际上循环应该像 #add 操作在本地队列上一样快地运行）。但是，执行 for 循环的时间是相同的。即使我将两个值都设置为 0。为什么会这样（它是一个双节点集群，一个节点位于不同的虚拟机上）？

<?xml version="1.0" encoding="UTF-8"?>
<hazelcast xsi:schemaLocation=
  "http://www.hazelcast.com/schema/config hazelcast-config-3.7.xsd"
  xmlns="http://www.hazelcast.com/schema/config"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
    <network>
        <port auto-increment="true" port-count="20">5701</port>
        <join>
            <multicast enabled="false">
        </multicast>
        <tcp-ip enabled="true">
            <member>172.105.66.xx</member> 
        </tcp-ip>
        </join>
    </network>

    <queue name="test">
        <statistics-enabled>false</statistics-enabled>
        <max-size>0</max-size>
        <backup-count>0</backup-count>
        <async-backup-count>1</async-backup-count>
        <empty-queue-ttl>-1</empty-queue-ttl>
    </queue>
</hazelcast>
4

1 回答 1

2

异步备份不会阻止您的调用，因此设置 0 或 1 应该有最小的差异。在 2 节点集群上设置另一个值是没有意义的。

不同之处在于具有您的数据结构的分区的所有者是本地的还是远程的。在这种情况下，性能问题通常是由调用者（您的测试）和数据结构所有者（远程 Hazelcast 实例）之间的网络延迟引起的。

HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance();
IQueue<String> configs = hazelcastInstance.getQueue("test"); 
for(int i = 0; i<1000;i++) {
    configs.add("Some string"+i);
}
Member localMember = hazelcastInstance.getCluster().getLocalMember();
Member partitionOwner = hazelcastInstance.getPartitionService().getPartition(configs.getName()).getOwner();
boolean localCall = localMember.equals(partitionOwner);
System.out.println("Local calls to IQueue: " + localCall);
于 2019-06-17T06:02:26.727 回答