Nodejs - SolrClient，如何等待响应

Question

我有一个关于 nodejs 的 solr-client 模块的问题。我正在使用这个模块来查询 solr-index。

只要我不必等待查询完成并且我只需要异步结果的结果，模块本身就可以正常工作。

但目前我不知道如何才能等待搜索请求完成并按顺序使用结果。

我的经理有以下方法

SolrManager.prototype.promisedQuery = function(query, callback) {
var solrClient = solr.createClient(this.configuration.cores.page);

var docs = null;
var finished = false;
var deferred = Q.defer();

var request = solrClient.search(query, function(err,obj){
    if (!err) {
        if (obj.response.numFound > 0) {
            deferred.resolve(obj.response.docs);
        } else {
            deferred.resolve(null);
        }
    } else {
        deferred.reject(err);
    }
});

var records = null;
var promise = deferred.promise;
promise.then(function(result) {
    records = result;
}).fail(function(error){
    records = error;
});

return records;

};

这里的问题是，我尝试等待查询结果并将其用作“promisedQuery”的返回值。

我从几天前开始尝试在顺序调用中使用此方法，还使用不同的附加模块，如“wait.for”、“q”等，但似乎没有任何效果。

solr-client 的回调函数总是在 manager-method 已经返回后执行。同样，promise-methods 甚至会在 manager-method 返回后被调用。

有人可以在该主题上帮助我或提供一些提示，我如何等待 solr-client-search 操作的响应，然后按顺序返回？

感谢您的帮助。

乌多·格哈兹

Answer 1

一个多星期，现在看来我找到了解决办法：

SolrManager.prototype.promisedQuery = function(query, callback) {
var solrClient = solr.createClient(this.configuration.cores.page);

var docs = null;
var deferred = Q.defer();

var request = solrClient.search(query, function(err,obj){
    if (!err) {
        if (obj.response.numFound > 0) {
            deferred.resolve(obj.response.docs);
        } else {
            deferred.resolve(null);
        }
    } else {
        deferred.reject(err);
    }
  });

return deferred.promise;
};

在调用上述函数的所有其他管理器中：

...
var dbPromise = this.solrManager.promisedQuery(query);

var _self = this;
return Q.async(function*(){
    var result = yield dbPromise;
    return result;
});
...

在第一次测试之后，同步方法似乎会等到承诺完成。

唯一的一点是，它仅在 NodeJs 版本 0.11.10 上运行，该版本支持生成器功能，并带有激活的 --harmony-flag 和“q”-module。

最好的问候

乌多

Answer 2

您只是使用了一些不正确的承诺。您需要返回“deferred.promise”，而不是返回记录。它应该看起来像这样（请注意，您不需要传递给 promiseQuery 的回调）。

SolrManager.prototype.promisedQuery = function(query) {
    var solrClient = solr.createClient(this.configuration.cores.page),
    deferred = Q.defer();

    solrClient.search(query, function(err,obj){
        if (!err) {
            if (obj.response.numFound > 0) {
                deferred.resolve(obj.response.docs);
            } else {
                deferred.resolve(null);
            }
        } else {
            deferred.reject(err);
        }
    });

    return deferred.promise;
};

要使用它，您可以执行以下操作：

SolrManager.promisedQuery(myquery)
    .then(function (data) {
        // data is whatever your 'resolved' in promisedQuery
    }, function (err) {
        // err is whatever you rejected in promisedQuery
    });

Answer 3

根据 rquinns 的回答，我已将代码更改如下：

SolrManager.prototype.promisedQuery = function(query, callback) {
var solrClient = solr.createClient(this.configuration.cores.page);

var docs = null;
var finished = false;
var deferred = Q.defer();

var request = solrClient.search(query, function(err,obj){
    if (!err) {
        if (obj.response.numFound > 0) {
            deferred.resolve(obj.response.docs);
        } else {
            deferred.resolve(null);
        }
    } else {
        deferred.reject(err);
    }
});

return deferred.promise;
};

...

DemoObject.prototype.toString = function() {
 return SolrManager.promisedQuery(this.query).then(function(result){
   return result['title'];
 }).fail(function(error){
   return error;
 });
};

DemoObject.prototype.typeOf = function() {
 return SolrManager.promisedQuery(this.query).then(function(result){
   return result['title'];
 }).fail(function(error){
   return error;
 });
};

我认为，这是使用“承诺”对象的正确方法。但是当我执行以下操作时会发生什么：

...
var demoObject = new DemoObject();
demoObject.query = "id:1";
console.log(''+demoObject);
...

或者如果我通过将“demoObject”连接到一个字符串来使用它

...
var string = "Some string "+demoObject;
...

在字符串连接的情况下，我目前不确定该字符串是否还包含数据库中的标题字段。控制台输出相同。

nodejs 是否会如此智能以至于它可以解析例如数据库结果“之后”的字符串连接将可用？

BR

乌多