Node.js 비동기 프로그래밍 콜백 소개(1)_node.js

Node.js는 JavaScript 엔진 v8을 기반으로 하며 단일 스레드입니다. Node.js는 웹의 JavaScript와 유사한 비동기 프로그래밍 방법을 사용하여 I/O 작업 차단을 처리합니다. Node.js에서 파일 읽기, 데이터베이스 액세스, 네트워크 요청 등은 모두 비동기식일 수 있습니다. Node.js를 처음 접하는 사람들이나 다른 언어 배경에서 Node.js로 마이그레이션하는 개발자들에게 비동기 프로그래밍은 고통스러운 부분입니다. 이 장에서는 가장 간단한 것부터 더 깊은 것까지 Node.js 비동기 프로그래밍의 모든 측면을 소개합니다. 가장 기본적인 콜백부터 썽크까지, Promise, co부터 async/await까지 ES7에 계획되어 있습니다.

먼저 비동기 프로그래밍의 구체적인 예부터 시작해 보겠습니다.

여러 IP 위치에 대한 날씨 정보 가져오기

ip.json 파일에는 다양한 장소에서 온 다양한 방문자인 여러 IP 주소를 저장하는 배열이 있습니다.

코드 복사 코드는 다음과 같습니다.

//ip.json
["115.29.230.208", "180.153.132.38", "74.125.235.224", "91.239.201.98", "60.28.215.115"]

각 IP 위치의 현재 날씨를 얻을 수 있기를 바랍니다. 결과를 다음 형식으로 Weather.json 파일에 출력합니다.

코드 복사 코드는 다음과 같습니다.

// 날씨.json
[
{ "ip": "115.29.230.208", "weather": "구름", "region": "절강" },
{ "ip": "180.153.132.38", "weather": "맑음", "region": "상하이" },
{ "ip": "74.125.235.224", "weather": "비", "region": "캘리포니아" },
{ "ip": "60.28.215.115", "weather": "맑음", "region": "천진" }
]

생각을 정리하기 위해 다음 단계로 나눕니다.

1. IP 주소를 읽습니다.
2. IP 주소를 기반으로 IP의 지리적 위치를 가져옵니다.
3. 지리적 위치에 따른 현지 날씨를 확인하세요.
4. 결과를 Weather.json 파일에 씁니다.

이러한 단계는 모두 비동기식입니다(파일 읽기 및 쓰기는 동기식일 수 있지만 예를 들어 비동기식이 사용됩니다).

콜백

먼저 Node.js API가 일반적으로 제공하는 방식으로 구현하려고 합니다. 라이브러리를 사용하지 않고 콜백을 비동기 콜백으로 전달합니다. 세 가지 기본 모듈을 사용합니다:

1.fs: ip.json 파일에서 IP 목록을 읽고 결과를 파일에 씁니다. 2.request: HTTP 요청을 보내고 IP 주소를 기반으로 지리 데이터를 얻은 다음 지리 데이터를 통해 날씨 데이터를 얻는 데 사용됩니다. 3.querystring: 요청 전송을 위한 URL 매개변수를 조합하는 데 사용됩니다.

새 callback.js 파일을 만들고 다음 모듈을 소개합니다.

코드 복사 코드는 다음과 같습니다.

// 콜백.js

var fs = require('fs')
var 요청 = require('요청')
var qs = require('querystring')

파일의 IP 목록을 읽고 fs.readFile을 호출하여 파일 내용을 읽은 다음 JSON.parse를 사용하여 JSON 데이터를 구문 분석합니다.

코드 복사 코드는 다음과 같습니다.

...

함수 readIP(경로, 콜백) {
fs.readFile(경로, 함수(err, 데이터) {
만약 (오류) {
       콜백(err)
} 그 밖의 {
{
을 시도해 보세요          데이터 = JSON.parse(데이터)
         콜백(null, 데이터)
} 잡기(오류) {
        콜백(오류)
}
}
})
}
...

다음 단계는 IP를 사용하여 지리 정보를 얻는 것입니다. 요청을 사용하여 공개 지리 서비스를 요청합니다.

코드 복사 코드는 다음과 같습니다.

...

함수 ip2geo(ip, 콜백) {
var url = 'http://www.telize.com/geoip/' ip
요청({
url: url,
JSON: 사실
}, 함수(err, resp, body) {
​ 콜백(err, body)
})
}
...

지리 데이터를 사용하여 날씨 확인:

코드 복사 코드는 다음과 같습니다.

...
함수 geo2weather(위도, 경도, 콜백) {
var 매개변수 = {
위도: 위도,
론: 론,
APPID: '9bf4d2b07c7ddeb780c5b32e636c679d'
}
var url = 'http://api.openweathermap.org/data/2.5/weather?' qs.stringify(params)
요청({
url: url,
json: 사실,
}, 함수(err, resp, body) {
​ 콜백(err, body)
})
}
...

이제 지리 및 날씨에 대한 인터페이스를 얻었으므로 처리해야 할 약간 더 복잡한 문제가 있습니다. IP가 여러 개 있으므로 지리를 병렬로 읽고 날씨 데이터를 병렬로 읽어야 합니다.

코드 복사 코드는 다음과 같습니다.

...
함수 ips2geos(ips, 콜백) {
var geos = []
변수 IP
var 유지 = ips.length
for (var i = 0; i ip = ips[i];
(함수(ip) {
ip2geo(ip, 함수(err, geo) {
만약 (오류) {
          콜백(err)
         } else {
          geo.ip = ip
           geos.push(geo)
             남음--
}
If (남은 == 0) {
           콜백(null, geos)
}
})
})(ip)
}
}

geos2weathers(geos, 콜백) 함수 {
var 날씨 = []
바지오
var 유지 = geos.length
for (var i = 0; i 지역 = 지역[i];
(함수(지역) {
geo2weather(geo.latitude, geo.longitude, 함수(err, 날씨) {
만약 (오류) {
          콜백(err)
         } else {
Weather.geo = 지리
날씨.푸시(날씨)
             남음--
}
If (남은 == 0) {
            콜백(null, 날씨)
}
})
})(지역)
}
}
...

ips2geos와 geos2weathers 모두 상대적으로 원시적인 방법을 사용하며, return을 기다리는 항목 수를 계산하기 위해 남아 있습니다. 남아가 0이면 병렬 요청이 종료되고 처리 결과가 배열에 로드되어 반환된다는 의미입니다. .

마지막 단계는 결과를 Weather.json 파일에 쓰는 것입니다.

코드 복사 코드는 다음과 같습니다.

...
함수 writeWeather(날씨, 콜백) {
var 출력 = []
다양한 날씨
for (var i = 0; i 날씨 = 날씨[i]
출력.푸시({
IP : Weather.geo.ip,
날씨: Weather.weather[0].main,
지역: Weather.geo.region
})
}
fs.writeFile('./weather.json', JSON.stringify(output, null, ' '), 콜백)
}
...

위 기능을 결합하면 다음과 같은 목표를 달성할 수 있습니다.

코드 복사 코드는 다음과 같습니다.

...
함수 handlerError(err) {
  console.log('오류: ' err)
}

readIP('./ip.json', function(err, ips) {
  if (err) {
    handlerError(err)
  } 그 밖의 {
    ips2geos(ips, function(err, geos) {
      if (err) {
        handlerError(err)
      } 그 밖의 {
        geos2weathers(geos, function(err, Weathers) {
          if (err) {
            handlerError(err)
          } 그 밖의 {
            writeWeather(날씨, 함수(err) {
              if (err) {
                handlerError(err)
              } 그 밖의 {
                console.log('성공!')
              }
            })
          }
        })
      }
    })
  }
})

哈哈，你妈这嵌套，你可能觉得这就是 JavaScript 异步的问题，说真的，嵌套不是 JavaScript 异步的真張段代码我们可以下면这样写：

复代码 代码如下:

...
함수 ReadIPCallback(err, ips) {
  if (err) {
    handlerError(err)
  } 그 밖의 {
    ips2geos(ips, ips2geosCallback)
  }
}

함수 ips2geosCallback(err, geos) {
  if (err) {
    handlerError(err)
  } 그 밖의 {
    geos2weathers(geos, geos2weathersCallback)
  }
}

geos2weathersCallback(err, Weathers) 함수 {
  if (err) {
    handlerError(err)
  } 그 밖의 {
    writeWeather(날씨, writeWeatherCallback)
  }
}

writeWeatherCallback(err) 함수 {
  if (err) {
    handlerError(err)
  } 그 밖의 {
    console.log('성공!')
  }
}

readIP('./ip.json', ReadIPCallback)

好了，这是我们 callback.js 의 전체 부분 内容。运行：

复代码 代码如下:

노드 콜백.js

将会生成 weeater.json 文件：

复代码 代码如下:

[
  {
    "ip": "180.153.132.38",
    "날씨": "맑음",
    "지역": "상하이"
  },
  {
    "ip": "91.239.201.98",
    "날씨": "구름"
  },
  {
    "ip": "60.28.215.115",
    "날씨": "맑음",
    "지역": "천진"
  },
  {
    "ip": "74.125.235.224",
    "날씨": "구름",
    "지역": "캘리포니아"
  },
  {
    "ip": "115.29.230.208",
    "날씨": "맑음",
    "지역": "절강"
  }
]

그렇다면 진짜 문제는 무엇일까요?

물론 비동기식의 문제는 기본적으로 다음 세 가지를 처리해야 합니다.

1. 비동기 작업이 끝나면 다시 알려야 합니다.
2. 비동기적으로 생성된 결과는 다시 전달되어야 합니다. 콜백은 데이터 매개변수를 받아 데이터를 다시 전달해야 합니다.
3. 비동기 오류가 발생하면 어떻게 해야 하나요? 콜백은 err 매개변수를 받아들이고 오류를 반환합니다.

그런데 반복적인 작업(다양한 콜백)을 많이 발견하셨나요? 위 코드에 문제가 있나요? 이 글의 계속을 기대해주세요.