요청을 동기화하는 방법은 무엇입니까?

Question

나는 nodejs + express + mongoose를 사용하고 있습니다. 두 개의 스키마와 모델을 "과일"과 "야채"라고 가정합니다.

가정 나는 다음과 같은 한 :

나는 변환 목록에 어디 토마토는 각각 '과일'과 '야채'컬렉션에 배열의 각 항목을 확인하고이를 삽입 할 수 완

var testlist = ["Tomato", "Carrot", "Orange"]; 
var convertedList = []; 
// Assume res is the "response" object in express 

, 당근, 브로콜리는 각각의 문서로 대체됩니다.

아래에는 내가 생각하는 것의 의사 코드가 있지만이를 수행하는 방법을 알지 못합니다.

for(var i = 0; i < testlist.length; i++) { 
var fruitfind = Fruit.find({"name":testlist[i]}); 
var vegfind = Vegetables.find({"name":testlist[i]}); 

// If fruit only 
if(fruitfind) { 
convertedList.push(fruitfindresults); 
} 
// If vegetable only 
else if(vegfind) { 

convertedList.push(vegfindresults); 
} 
// If identified as a fruit and a vegetable (assume tomato is a doc listed under both fruit and vegetable collections) 
else if (fruitfind && vegfind) { 
convertedList.push(vegfindresults); 
} 
} 

// Converted List should now contain the appropriate docs found. 
res.send(convertedList) // Always appears to return empty array... how to deal with waiting for all the callbacks to finish for the fruitfind and vegfinds? 

가장 적합한 방법은 무엇입니까? 아니면 이것도 가능합니까?

Answer 1

각 과일/야채 중 하나만 있다고 가정하고 두 컬렉션에있는 채소를 두 번 밀어 넣으려고했다고 가정합니다.

var async = require("async"), 
    testlist = ["Tomato", "Carrot", "Orange"]; 

async.map(testlist, function (plant, next) { 
    async.parallel([function (done) { 
    Fruit.findOne({"name": plant}, done); 
    }, 
    function (done) { 
    Vegetables.findOne({"name": plant}, done); 
    }], function (err, plants) { // Edited: before it was (err, fruit, veggie) which is wrong 
    next(err, plants); 
    }); 
}, 
function (err, result) { 
    var convertedList = [].concat(result); 
    res.send(convertedList); 
}); 

참고 : 실제로 코드를 테스트하지는 않았지만 작동해야합니다. The async module은이 btw와 같은 콜백 관리에 우수합니다.

업데이트

과 같이 다시 작성하기 위해 한 번만 각 열매를 얻으려면, async.parallel 콜백은 간단했다 :

function (err, plants) { 
    next(err, plants[0] || plants[1]); 
} 

을 그리고 .MAP 콜백에 더 이상 필요하지 CONCAT가 없습니다 :

function (err, result) { 
    res.send(result); 
} 

Answer 2

find은 비동기 함수이며 mongo 데이터베이스에 요청합니다. 이는 두 가지를 의미합니다.

1. 함수는 결과를 즉시 반환하지 않습니다. 몽구스의 find 기능은 매우 일반적인 비동기 패턴을 따릅니다. 그것은 결과 또는 오류와 함께 호출 할 "콜백"기능을 허용합니다. 노드 규칙에 따라 첫 번째 인수가 null이 아니면 오류입니다.

   // So typically you'd call find like this 
   SomeModel.find({your: 'conditions'}, function (err, results) { 
       if (err) { 
       // some error has occurred which you must handle 
       } else { 
       res.send(results); 
       } 
   }) 
   // note that if code existed on the lines following the find, it would 
   // be executed *before* the find completed. 
   

2. 모든 쿼리는 데이터베이스에 떨어져 또 다른 요청을 발사함에 따라, 당신은 일반적으로 당신이 할 수있는 경우의 수를 제한합니다. 이 경우, 과일/채소를 이름별로 찾는 대신 mongo의 $in을 사용하여 모든 이름을 한 번에 찾을 수 있습니다. 마음에 이러한 두 가지로

, 코드는 다음과 같이 보일 수 있습니다

// here *first* we're finding fruits 
Fruit.find({name: {$in: testlist}}, function (err, fruits) { 

    // when the fruit request calls back with results, we find vegetables 
    Vegetable.find({name: {$in: testlist}}, function (err, vegetables) { 

    // finally concat and send the results 
    res.send(fruits.concat(vegetables)); 
    }); 
}); 

두 요청이 동시에 발생하도록하려면 좀 더 많은 작업이 필요합니다. 당신은 자신이 좋아하는 async 같은 라이브러리를 사용하거나 뭔가를 쓸 수있다 : 당신이 처리 결과를 할 방법이 명확하지 단순히 결과 CONCAT 여기에 두 예는, 보내

var fruits 
    , vegetables 
    , done = function() { 
     if (fruits && vegetables) { 
     res.send(fruits.concat(vegetables)); 
     } 
    } 

Fruit.find({name: {$in: testlist}}, function (err, docs) { 
    fruits = docs; 
    done(); 
}); 

Vegetable.find({name: {$in: testlist}}, function (err, docs) { 
    vegetables = docs; 
    done(); 
}); 

참고.즉, 예를 들어 토마토가 두 목록에 모두있는 경우 결과에 야채 및 과일 문서가 두 번 표시됩니다.

또한 몽구스에서 오는 모든 오류를 처리해야합니다.

편집 : 고유 한 이름의 문서 귀하의 코멘트에 비추어

, 이것은 당신이 토마토 (또는 과일과 야채 모두 다른 기록)

// after retrieving fruits and vegetables, create a map which will 
// serve to weed out docs with duplicate names 
var map = {}; 

fruits.forEach(function (fruit) { 
    map[fruit.name] = fruit; 
}); 

vegetables.forEach(function (vegetable) { 
    map[vegetable.name] = vegetable; 
}); 

var results = []; 

// this would sort by name 
Object.keys(map).sort().forEach(function (key, i) { 
    results[i] = map[key]; 
}); 

res.send(results); 

에 대해 하나의 문서를 반환 할 수 있습니다 한 방법입니다

두 가지 쿼리의 결과를 정렬하고 페이지 매김하거나 다른 방식으로 제한해야하는 경우 이러한 종류의 작업이 훨씬 더 복잡해지고 필요한 경우 동일한 컬렉션에 문서를 보관하는 것이 좋습니다.