azure - 使用java驱动程序异步写入documentdb

Question

我正在使用 java-sdk 将文档插入到 cosmosdb 中。从驱动程序中我找不到任何 java api 来执行异步插入，但是我看到了 .Net api 的选项,

有没有办法(本地)在后台插入文档而不让客户端等待。

Answer 1

我查看了Azure DocumentDB SDK for Java的javadocs和源代码，不幸的是，没有任何 native 方法来支持异步操作。因此，如果您必须需要异步功能，有以下两种解决方法。

1. 使用异步http客户端调用Cosmos REST APIs ，如OkHttp .

2. Azure DocumentDB支持MongoDB协议(protocol)，所以我认为可以使用MongoDB Async Java Driver满足您的需求，但由于官方 MongoDB Async Java Driver 似乎不支持 Azure DocumentDB，所以我失败了。然而，有一个第三方MongoDB异步Java驱动程序mongodb-async-driver ，我尝试使用MongoDB协议(protocol)成功连接到Azure DocumentDB，但是它的API与MongoDB官方的不同。

   作为引用，这是我使用第三方驱动程序的示例代码，可以下载here ，没有 Maven 仓库。

   import java.util.concurrent.ExecutionException;
   import java.util.concurrent.Future;
   
   import com.allanbank.mongodb.MongoClient;
   import com.allanbank.mongodb.MongoCollection;
   import com.allanbank.mongodb.MongoDatabase;
   import com.allanbank.mongodb.MongoFactory;
   import com.allanbank.mongodb.MongoIterator;
   import com.allanbank.mongodb.bson.Document;
   import com.allanbank.mongodb.builder.Find;
   
   public class Test {
   
       public static void main(String[] args) throws InterruptedException, ExecutionException {
           String connectionString = "mongodb://<user>:<password>@<documentdb-name>.documents.azure.com:10255/?ssl=true&replicaSet=globaldb";
           MongoClient mongo = MongoFactory.createClient(connectionString);
           String dbName = "testdb";
           MongoDatabase database = mongo.getDatabase(dbName);
           String collName = "test";
           MongoCollection collection = database.getCollection(collName);
           Future<Long> future = collection.countAsync();
           System.out.printf("There are %,d documents in the collection.%n", future.get());
           MongoIterator iter = collection.find(Find.builder().build());
           while (iter.hasNext()) {
               System.out.println(((Document) iter.next()));
           }
       }
   
   }
   

希望有帮助。