NodeJs 동시 및 비동기 콜백 처리에 대한 심층 분석_node.js

동시적, 비동기적이라는 말은 정확하지 않습니다. 연속적 비동기적이라고 말해야 합니다. NodeJs의 단일 스레드 비동기 기능은 여러 비동기 작업이 동시에 수행될 때 콜백이 최종 실행 결과를 결정할 수 없도록 직접적으로 발생시킵니다. 간단한 예를 들어보세요:

for(var i = 0; i < 5; i++) {
  fs.readFile('file', 'utf-8', function(error, data){});
} 

파일을 연속적으로 읽기 위해 5개의 비동기 작업을 시작했습니다. 그래서 문제는 모든 비동기 작업이 완료되었는지 어떻게 확인할 수 있느냐는 것입니다. 후속 작업은 모두 실행된 후에만 수행할 수 있기 때문입니다. 어느 정도 경험이 있는 학생들은 셈법을 사용하는 것을 생각할 것이라고 생각하지만 정확한 계산을 어떻게 보장하는지는 또 다른 문제입니다. 신중하게 생각해 보세요:

콜백은 각 비동기 작업마다 카운터를 1로 설정하고, 각 비동기 작업이 끝나면 카운터를 -1로 설정하는 함수로, 카운터가 0인지 판단하여 콜백 실행 여부를 결정합니다. 이 로직은 매우 간단합니다. 카운터로 실행 시간과 콜백 시간을 기준으로 하는 전역 변수가 필요하며, 비동기 메서드에 전달되면 1의 연산을 수행한 다음 콜백을 위한 함수를 반환해야 하는데 이는 약간 복잡합니다. , Js 기능의 고급 사용법을 살펴보세요:

var pending = (function() {
  var count = 0;
  return function() {
    count++;
    return function() {
      count--;
      if (count === 0) {
        // 全部执行完毕
      }
    }
  }
}); 

pending이 호출되면 보류 중()입니다. 예:

var done = pending(); 

이때 카운팅 변수 count는 0으로 초기화되고, 반환된 함수는 done에 첨부됩니다. 이때 done()이 실행되면 어떻게 될까요? 보류에서 반환한 첫 번째 함수, 즉 보류()()를 직접 실행하는 것입니까? 이 실행은 무엇입니까? 먼저 계산 변수 count 1이 반환되고, 이 함수가 콜백으로 직접 전달됩니다. 이 콜백을 실행할 때 먼저 카운트 변수 count-1을 설정한 후 카운트가 0인지 확인합니다. 0이면 모든 비동기 실행이 완료되었음을 의미하므로 동일한 작업으로 지속적인 비동기 작업이 이루어집니다. 콜백.

핵심은 두 가지 수익에 있습니다. 간단히 말해

첫 번째 반환 함수는 1을 센 후 콜백이 필요한 함수를 반환하는 것입니다

두 번째 반환 함수는 콜백이 필요한 함수입니다. 실행되면 count-1을 한 후 모든 비동기 실행이 완료되었는지 확인하여 콜백합니다.

여러 파일을 읽기 위한 비동기 콜백의 실제 예를 살펴보세요.

var fileName = ['1.html', '2.html', '3.html'];
var done = pending(function(fileData) {
  console.log('done');
  console.log(fielData);
});
for(var i = 0; i < fileName.lenght; i++) {
  fs.readFile(fileName[i], 'utf-8', done(fileName[i]));
}

완료된 메서드는 콜백하고 실행하려는 메서드를 마무리하기 위해 보류 메서드를 사용합니다. 카운터가 0이면 실행됩니다. 그런 다음 보류 메서드를 개선해야 합니다.

var pending = (function(callback) {
  var count = 0;
  var returns = {};
  console.log(count);
  return function(key) {
    count++;
    console.log(count);
    return function(error, data) {
      count--;
      console.log(count);
      returns[key] = data;
      if (count === 0) {
        callback(returns);
      }
    }
  }
}); 

콜백은 콜백 함수입니다. var done = 보류 중(콜백)인 경우 done은 반환된 값의 첨자로 사용할 수 있는 매개변수를 갖습니다. 따라서 루프 본문에는 done( fileName[i]), 파일 이름이 전달됩니다. 이 done()은 1을 계산한 후 비동기 메서드에 전달할 콜백 함수를 반환합니다. 앞서 언급했듯이 이 콜백 함수는 count 변수에 따라 실행하려는 콜백 함수를 실행할지 여부를 결정합니다. 그리고 파일의 내용이 전달됩니다. 즉, 반환됩니다. 자, 실행해 보겠습니다. 결과를 정확하게 볼 수 있을 것 같습니다.

0
1
2
3
2
1
0
완료
{"1.html": "xxx", "2.html": "xxx", "3.html": "xxx"}

0~3부터 0까지의 개수를 보면 명확하게 알 수 있으며 콜백 함수는 완료 및 파일 내용을 출력합니다.

이 문제는 해결되었으니, 이런 방법을 어떻게 캡슐화해서 재사용할 것인지 고민해야 합니다. 그렇지 않으면 매번 Pending을 쓰는 것은 비과학적이지 않을까요?

템플릿 파싱에서 하위 템플릿 작업에 적용되는 UnJ(나의 NodeJs 기반 웹 개발 프레임워크 중 하나)의 처리 방법을 살펴보겠습니다.

unjs.asyncSeries = function(task, func, callback) {
  var taskLen = task.length;
  if (taskLen <= 0) {
    return;
  }
  var done = unjs.pending(callback);
  for(var i = 0; i < taskLen; i++) {
    func(task[i], done);
  }
} 

asyncSeries에는 다음과 같은 세 가지 매개변수가 있습니다.

작업: 읽어야 할 파일 등 처리해야 할 객체가 리스트인 경우, 리스트가 아니거나 리스트 길이가 0인 경우에는 실행되지 않습니다

func: fs.readFile과 같은 비동기 메서드가 이를 통해 전달됩니다

콜백: 콜백하려는 메서드

done은 이전과 동일하지만 func에 전달되지만 실행되지는 않습니다. 애플리케이션 측에서 매개변수를 제어할 수 있기를 바라기 때문에 애플리케이션 측에서 실행하도록 합니다.

하위 템플릿을 다룰 때 작업 살펴보기:

var subTemplate = [];
var patt = /\{\% include \'(.+)\' \%\}/ig;
while(sub = patt.exec(data)) {
  var subs = sub;
  subTemplate.push([subs[0], subs[1]]);
}
unjs.asyncSeries(subTemplate, function(item, callback) {
  fs.readFile('./template/' + item[1], 'utf-8', callback(item[0]));
}, function(data) {
  for(var key in data) {
    html = html.replace(key, data[key]);
  }
}); 

하위 템플릿 목록은 하위 템플릿 분석을 기반으로 생성된 데이터입니다. 이는 2차원 배열입니다. 각 하위 항목의 첫 번째 값은 하위 템플릿의 호출 텍스트입니다. 즉, {% include 'header.html' %} 같은 문자열, 두 번째 매개변수는 하위 템플릿 파일 이름, 즉 header.html

asyncSeries의 두 번째 매개변수는 callback인데, 실제로는 세 번째 매개변수로, 앞서 언급한 것처럼 asyncSeries 내부에서는 실행되지 않는 콜백 함수입니다. 즉, 매개변수가 있는 callback(item[0])입니다. 나중에 상위 템플릿에서 하위 템플릿을 호출하는 문자열이 이 매개변수를 기반으로 하는 해당 하위 템플릿의 콘텐츠로 대체되기 때문입니다.

이런 방식으로 지속적인 비동기가 필요한 경우 asyncSeries 메서드를 사용하여 처리할 수 있습니다. 비동기식 관계로 인해 프로그램의 흐름이 다소 복잡해 처음에는 이해하기 어려울 수도 있지만, 예를 들어 익숙하지 않더라도 별 문제가 되지 않습니다. , 두 번째 매개변수의 콜백은 실제로 세 번째 매개변수에 의해 생성됩니다. 이 콜백이 정확히 무엇인지 궁금할 것입니다. 또한 보류 중인 반품이 두 개 있는데, 이는 이해하기 쉽지 않으며 더 많이 생각해야 합니다.

자, Js 함수의 고급 기능을 사용하여 연속 비동기 콜백이 완성되었습니다. 그러나 NodeJ의 비동기적 특성으로 인해 값 전송이 필요한 지속적인 비동기 작업 등 프로그램 제어가 매우 문제가 됩니다. 이는 모두 이 아이디어와 변경을 통해 달성할 수 있습니다.

위 내용은 편집자가 공유하는 NodeJs의 동시 및 비동기 콜백 처리에 대한 지식입니다.