Introduction au rappel de programmation asynchrone Node.js (1)_node.js

Node.js est basé sur le moteur JavaScript v8 et est monothread. Node.js utilise des méthodes de programmation asynchrone similaires à JavaScript sur le Web pour gérer le blocage des opérations d'E/S. La lecture de fichiers, l'accès à des bases de données, les requêtes réseau, etc. dans Node.js peuvent tous être asynchrones. Pour ceux qui découvrent Node.js ou les développeurs migrant vers Node.js à partir d’autres langages, la programmation asynchrone est une partie douloureuse. Ce chapitre vous présentera tous les aspects de la programmation asynchrone Node.js, du plus simple au plus profond. Du rappel le plus basique au thunk, Promise, co à l'async/wait prévu pour ES7.

Tout d’abord, commençons par un exemple spécifique de programmation asynchrone.

Obtenez des informations météorologiques pour plusieurs emplacements IP

Dans le fichier ip.json, il y a un tableau où nous stockons plusieurs adresses IP, qui sont différents visiteurs de différents endroits. Le contenu est le suivant :

Copier le code Le code est le suivant :

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

J'espère pouvoir obtenir la météo actuelle pour chaque emplacement IP. Exportez les résultats dans le fichier Weather.json au format suivant :

Copier le code Le code est le suivant :

// météo.json
[
{ "ip": "115.29.230.208", "weather": "Nuages", "region": "Zhejiang" },
{ "ip": "180.153.132.38", "weather": "Clear", "region": "Shanghai" },
{ "ip": "74.125.235.224", "weather": "Pluie", "region": "Californie" },
{ "ip": "60.28.215.115", "weather": "Clair", "region": "Tianjin" }
]

Pour organiser nos pensées, nous la divisons selon les étapes suivantes :

1. Lisez l'adresse IP
2. Obtenez l'emplacement géographique de l'IP en fonction de l'adresse IP
; 3. Vérifiez la météo locale en fonction de la situation géographique
; 4. Écrivez les résultats dans le fichier Weather.json.

Ces étapes sont toutes asynchrones (la lecture et l'écriture de fichiers peuvent être synchrones, mais à titre d'exemple, l'asynchrone est utilisé).

rappel

Tout d'abord, nous essayons de l'implémenter de la manière que l'API Node.js propose habituellement : en passant un rappel en tant que rappel asynchrone sans utiliser de bibliothèque. Nous utiliserons trois modules de base :

1.fs : Lisez la liste IP à partir du fichier ip.json ; écrivez le résultat dans le fichier
2.request : utilisé pour envoyer des requêtes HTTP, obtenir des données géographiques basées sur l'adresse IP, puis obtenir des données météorologiques via des données géographiques
 ; 3.querystring : utilisé pour assembler les paramètres d'URL pour l'envoi des requêtes.

Créez un nouveau fichier callback.js et introduisez ces modules :

Copier le code Le code est le suivant :

// rappel.js
var fs = require('fs')
var requête = require('request')
var qs = require('querystring')

Lisez la liste IP dans le fichier, appelez fs.readFile pour lire le contenu du fichier, puis utilisez JSON.parse pour analyser les données JSON :

Copier le code Le code est le suivant :

...
fonction readIP(chemin, rappel) {
fs.readFile(chemin, fonction(erreur, données) {
Si (erreur) {
       rappel (erreur)
} autre {
Essayez {
         data = JSON.parse(data)
         rappel (null, données)
} attraper (erreur) {
        rappel (erreur)
>
>
})
>
...

L'étape suivante consiste à utiliser l'IP pour obtenir la géo. Nous utilisons la requête pour demander un service de géoouverte :

Copier le code Le code est le suivant :

...
fonction ip2geo(ip, rappel) {
var url = 'http://www.telize.com/geoip/'ip
demande({
URL : URL,
json : vrai
}, fonction (erreur, resp, corps) {
​ rappel(euh, corps)
})
>
...

Utiliser les données géographiques pour obtenir la météo :

Copier le code Le code est le suivant :

...
fonction geo2weather(lat, lon, rappel) {
var paramètres = {
latitude : latitude,
lon : lon,
APPID : '9bf4d2b07c7ddeb780c5b32e636c679d'
>
var url = 'http://api.openweathermap.org/data/2.5/weather?' demande({
URL : URL,
json : vrai,
}, fonction (erreur, resp, corps) {
​ rappel(euh, corps)
})
>
...

Maintenant que nous avons obtenu les interfaces pour la géo et la météo, nous avons encore un problème un peu plus compliqué à résoudre. Comme il y a plusieurs IP, nous devons lire la géo en parallèle et lire les données météorologiques en parallèle :

Copier le code Le code est le suivant :

...
fonction ips2geos(ips, rappel) {
var géos = []
var ip
var reste = ips.length
pour (var i = 0; i ip = ips[i];
(fonction(ip) {
ip2geo(ip, fonction(erreur, géo) {
Si (erreur) {
          rappel (erreur)
         } autre {
          geo.ip = ip
           geos.push(geo)
             rester--
>
Si (reste == 0) {
           rappel (null, géos)
>
})
})(ip)
>
>
fonction geos2weathers(geos, rappel) {

var météos = []
var géo
var reste = geos.length
pour (var i = 0; i Géo = géos[i];
(fonction(géo) {
geo2weather(geo.latitude, geo.longitude, function(err, météo) {
Si (erreur) {
          rappel (erreur)
         } autre {
météo.geo = géo
météo.push(météo)
             rester--
>
Si (reste == 0) {
            rappel (null, météo)
>
})
})(géo)
>
>
...

ips2geos et geos2weathers utilisent une méthode relativement primitive, rest pour calculer le nombre d'éléments en attente d'être renvoyés. Si rest est 0, cela signifie que la requête parallèle est terminée et que les résultats du traitement sont chargés dans un tableau et renvoyés. .

La dernière étape consiste à écrire les résultats dans le fichier Weather.json :

Copier le code Le code est le suivant :

...
function writeWeather (météos, rappel) {
var sortie = []
météo varoise
pour (var je = 0; je météo = temps[i]
Sortie.push({
IP : météo.geo.ip,
Météo : météo.weather[0].main,
Région : météo.geo.region
})
>
fs.writeFile('./weather.json', JSON.stringify(output, null, ' '), rappel)
>
...

En combinant les fonctions ci-dessus, nous pouvons atteindre notre objectif :

Copier le code Le code est le suivant :

...
fonction handlerError(err) {
  console.log('erreur : 'err)
>

readIP('./ip.json', function(err, ips) {
  si (erreur) {
    gestionnaireErreur(erreur)
  } autre {
    ips2geos(ips, fonction(erreur, géos) {
      si (erreur) {
        gestionnaireErreur(erreur)
      } autre {
        geos2weathers(geos, fonction(erreur, météos) {
          si (erreur) {
            gestionnaireErreur(erreur)
          } autre {
            writeWeather (météos, fonction (err) {
              si (erreur) {
                gestionnaireErreur(erreur)
              } autre {
                console.log('succès !')
              >
            })
          >
        })
      >
    })
  >
})

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

复制代码 代码如下 :

...
fonction ReadIPCallback(err, ips) {
  si (erreur) {
    gestionnaireErreur(erreur)
  } autre {
    ips2geos(ips, ips2geosCallback)
  >
>

fonction ips2geosCallback(euh, géos) {
  si (erreur) {
    gestionnaireErreur(erreur)
  } autre {
    geos2weathers(geos, geos2weathersCallback)
  >
>

fonction geos2weathersCallback(euh, météo) {
  si (erreur) {
    gestionnaireErreur(erreur)
  } autre {
    writeWeather (météos, writeWeatherCallback)
  >
>

fonction writeWeatherCallback(err) {
  si (erreur) {
    gestionnaireErreur(erreur)
  } autre {
    console.log('succès !')
  >
>

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

好了，这是我们 callback.js 的全部内容。运行：

复制代码 代码如下 :

nœud callback.js

Il s'agit de weater.json 文件：

复制代码 代码如下 :

[
  {
    "ip": "180.153.132.38",
    "météo": "Clair",
    "région": "Shanghai"
  },
  {
    "ip": "91.239.201.98",
    "météo": "Nuages"
  },
  {
    "ip": "60.28.215.115",
    "météo": "Clair",
    "région": "Tianjin"
  },
  {
    "ip": "74.125.235.224",
    "météo": "Nuages",
    "region": "Californie"
  },
  {
    "ip": "115.29.230.208",
    "météo": "Clair",
    "région": "Zhejiang"
  >
]

Alors quel est le vrai problème ?

Bien sûr, il s'agit d'un problème d'asynchrone qui doit essentiellement traiter de trois choses :

1. Lorsque l'opération asynchrone se termine, elle doit être notifiée. Le rappel est une solution ; 2. Les résultats générés de manière asynchrone doivent être renvoyés. Le rappel accepte un paramètre de données et renvoie les données
 ; 3. Que dois-je faire si une erreur asynchrone se produit ? Le rappel accepte un paramètre err et renvoie l'erreur.

Mais avez-vous constaté beaucoup de travail répétitif (rappels divers) ? Y a-t-il un problème avec le code ci-dessus ? Veuillez attendre avec impatience la suite de cet article.