'readline'을 사용하여 node.js 프로그램에 대한 동기 실행

Question

노드와 비동기식으로 상호 작용하고 콜백 및 인터넷 검색 작업을 수행하는 데 몇 가지 문제가 있습니다. 나는 마침내 너희들을 바라본다.

노드의 readline 모듈을 사용하여 파일에서 줄을 읽어야하는 프로그램이 있습니다. 이 파일에는 노드 프로그램 내에서 정의 된 일부 비동기 함수에 전달되는 데이터가 들어 있습니다. 모든 데이터가 성공적으로 읽고 처리되면이 데이터를 JSON 형식으로 파싱 한 다음 출력해야합니다.

내 문제는 여기서 내가 호출 할 때 : readLine.on('close', function() { ...... } 비동기 함수가 실행되기 전에 실행되므로 아무 것도 출력되지 않지만 프로그램이 비동기 함수를 계속 실행합니다.

좀 더 명확하게 내 상황을 설명해야한다 기능의 간단한 골격을 만든 : 내가 처음/secondAsynFunction에 콜백을 추가하기 위해 노력했다

function firstAsyncFunc(dataFromFile) { 
    //do something asynchronously 

    return processedData; 
} 


function secondAsyncFunc(dataFromFile) { 
    //do something else asynchronously 

    return processedData; 
} 


//create readline 
var lineReader = require('readline').createInterface({ 
    input: require('fs').createReadStream('data.txt') 
}); 


//array to hold all the data processed 
var totalDataStorage; 


//read file 
lineReader.on('line', function(line) { 

    var processedData = firstAsyncFunction(line); 
    var moreProcessedData = secondAsyncFunction(line); 


    //store processed data and concatenate into one array 
    var tempDataStorage = [{ 'first': processedData, 'second': moreProcessedData }] 
    totalDataStorage = totalDataStorage.concat(tempDataStorage); 

}).on('close', function() { 

    var JSONString = JSON.stringify(... //create JSON for totalDataStorage ...); 
    console.log(JSONString); //DOESN'T OUTPUT ANYTHING! 

}); 

을, 나는 읽기와 분석을 만들기 위해 노력했다 조금씩 프로그램의 분리 된 함수를 만들고, 콜백을 작성하여 읽기가 끝났을 때 구문 분석을 호출하기 만하면되지만, 그 솔루션은 작동하지 않는 것 같고 정말 고민 중입니다.

감사합니다.

편집 : data.txt라는 파일 형태

IPData1 DataCenter1 
IPData2 DataCenter2 
... 
IPDataN DataCenterN 

나는 각각의 값을 얻을하고 적절하게 전달하는 str.split를 ("")를 사용이다. IPData은 숫자이며, 데이터 센터는 문자열

Answer 1

비동기 함수는 값을 반환하지 않습니다,하지만 당신은 대신에 콜백 함수를 통과해야합니다. 사용자의 라인

var processedData = firstAsyncFunction (line);

전혀 이해가되지 않습니다. 당신의 data.txt 파일이

IPData1 DataCenter1 
IPData2 DataCenter2 
IPData3 DataCenter3 

과 같은 경우

var fs = require('fs'); 
var rl = require('readline').createInterface({ 
    input: fs.createReadStream('data.txt') 
}); 
var arr = []; 

rl.on('line', a => { 
    a = a.split(' '); 
    arr.push({ 
    first: a[0], 
    second: a[1] 
    }); 
}).on('close',() => { 
    console.log(JSON.stringify(arr, null, 2)); 
}); 

을 다음과 같이 그것은

[ 
    { 
    "first": "IPData1", 
    "second": "DataCenter1" 
    }, 
    { 
    "first": "IPData2", 
    "second": "DataCenter2" 
    }, 
    { 
    "first": "IPData3", 
    "second": "DataCenter3" 
    } 
] 

Answer 2

를 기록합니다 데이터를 읽을 수 있습니다 나는 다음과 로컬 작업 변경되었습니다.

1. 사용은 여러분의 인생을 더 쉽게 만드는 것을 약속드립니다.
2. 제거 .close 당신은 인터페이스에 정의 된 출력을 해달라고 때문이다. 다음 중 하나가 발생할 때

'확대'이벤트가 방출된다

1. rl.close() 메소드를 호출하고 readline에있다.인터페이스 인스턴스는 입력 스트림과 출력 스트림에 대한 제어를 포기했습니다.
2. 입력 스트림은 'end'이벤트를 수신합니다.
3. 입력 스트림은 EOT (signal end-of-transmission)를 수신합니다.
4. 입력 스트림에 -C가 신호 SIGINT로 수신되고 readline.Interface 인스턴스에 등록 된 SIGINT 이벤트 수신기가 없습니다.

function firstAsyncFunc(dataFromFile) { 
    return new Promise(function(resolve, reject) { 
    //do something asynchronously 
    resolve(result); 
    }) 
} 

function secondAsyncFunc(dataFromFile) { 
    return new Promise(function(resolve, reject) { 
    //do something asynchronously 
    resolve(result); 
    }) 
} 

//create readline 
var lineReader = require('readline').createInterface({ 
    input: require('fs').createReadStream('data.txt') 
}); 

//array to hold all the data processed 
var totalDataStorage; 

//read file 
lineReader.on('line', function(line) { 
    Promise.all([ 
     firstAsyncFunc(line), 
     secondAsyncFunc(line) 
    ]) 
    .then(function(results) { 
     var tempDataStorage = [{ 
     'first': results[0], 
     'second': results[1] 
     }]; 
     // i'd use push instead of concat 
     totalDataStorage = totalDataStorage.concat(tempDataStorage); 
    }); 
})