如何等待Aerospike AsyncClient完成所有事务？

Question

我正在使用Aerospike AsyncClient和Aerospike UDF模块在Aerospike 2节点集群中使用多线程插入1000万条记录。我遵循的步骤是：

>

创建了一个由10个线程组成的executor服务，所有线程都将使用相同的AsyncClient

运行循环1000万次，并使用下面的代码调用execute命令

对于（int 1-0；i<10000000；i++){final int j=i；executorService.execute（new Runnable（）{public void run（）{put（“test”,“binname”,“setname”,j,list1,list2,aerospikeClient）；}}）；}

private void put（String namespace,String setName,String binName,String keyVlaue,List campaignsIdsToBeAdd,List campaignsIdToBeRemoved,AsyncClient aerospikeClient.execute（writePolicy,new WriteHandler（）,Key,“Aerospike_UDF”,“update_record”,value.get（campaignsIdsToBeAdd）,value.get（campaignsIdToBeRemoved）,value.get（binName））；}

public void closed（）{system.out.println（“===1”）；

    if(aerospikeClient != null && aerospikeClient.isConnected())
        aerospikeClient.close();
    if(executorService != null && !executorService.isShutdown())
        executorService.shutdown();
}

executor、service和AsyncClient立即停止，之后没有插入发生，并且丢失了提交的数据。

有谁能帮我解决这个问题吗？或者建议我使用AsyncClient和Aerospike udf函数的更好方法。

我尝试使用同步客户端来完成这一操作，但它需要70分钟来插入所有值，但我希望在5分钟内完成。当我尝试在多个线程之间使用同步客户端时，它会引发客户端超时异常

Answer 1

看来您运行的UDF比常规的读/写操作慢。因此，即使您等待异步调用完成，也可能需要花费5分钟以上的时间。您需要调整集群的大小以满足性能需要。因此，您也需要考虑非编程的替代方案。

• 拥有更多的节点将有助于并行执行UDF，从而减少总时间。
• 如果在应用程序中实现udf的逻辑，请查看性能。由于一些计算成本被转移到客户端，服务器的工作量将会减少。