Grundlegendes Tutorial zur Verwendung des Request-Moduls in Node.js zur Verarbeitung des HTTP-Protokolls „requests_node.js“.

Hier stellen wir ein Node.js-Modul vor – Anfrage. Mit diesem Modul werden HTTP-Anfragen ganz einfach.

Request ist super einfach zu verwenden und unterstützt https und Umleitung.

var request = require('request');
request('http://www.google.com', function (error, response, body) {
 if (!error && response.statusCode == 200) {
 console.log(body) // 打印google首页
}
})

Stream:

Jede Antwort kann in einen Dateistream ausgegeben werden.

request('http://google.com/doodle.png').pipe(fs.createWriteStream('doodle.png'))

Umgekehrt können Sie Dateien auch an PUT- oder POST-Anfragen übergeben. Wenn kein Header angegeben wird, wird die Dateierweiterung erkannt und der entsprechende Inhaltstyp in der PUT-Anfrage festgelegt.

fs.createReadStream('file.json').pipe(request.put('http://mysite.com/obj.json'))
Anfragen können auch an Sie selbst weitergeleitet werden. In diesem Fall bleiben der ursprüngliche Inhaltstyp und die ursprüngliche Inhaltslänge erhalten.

request.get('http://google.com/img.png').pipe(request.put('http://mysite.com/img.png'))
Formular:

request unterstützt application/x-www-form-urlencoded und multipart/form-data zur Implementierung des Formular-Uploads.

x-www-form-urlencoded ist einfach:

request.post('http://service.com/upload', {form:{key:'value'}})

oder:

request.post('http://service.com/upload').form({key:'value'})

Verwenden Sie Multipart-/Formulardaten und Sie müssen sich nicht um triviale Dinge wie das Festlegen von Headern-Anfragen kümmern, um das Problem zu lösen.

var r = request.post('http://service.com/upload')
var form = r.form()
form.append('my_field', 'my_value')
form.append('my_buffer', new Buffer([1, 2, 3]))
form.append('my_file', fs.createReadStream(path.join(__dirname, 'doodle.png'))
form.append('remote_file', request('http://google.com/doodle.png'))

HTTP-Authentifizierung:

request.get('http://some.server.com/').auth('username', 'password', false);

oder

request.get('http://some.server.com/', {
 'auth': {
 'user': 'username',
 'pass': 'password',
 'sendImmediately': false
}
});

sendImmediately, standardmäßig true, sendet einen Basisauthentifizierungsheader. Nachdem es auf „false“ gesetzt wurde, wird es beim Empfang von 401 erneut versucht (die 401-Antwort des Servers muss die von WWW-Authenticate angegebene Authentifizierungsmethode enthalten).

Digest-Authentifizierung wird unterstützt, wenn sendImmediately „true“ ist.

OAuth-Anmeldung:

// Twitter OAuth
var qs = require('querystring')
 , oauth =
 { callback: 'http://mysite.com/callback/'
 , consumer_key: CONSUMER_KEY
 , consumer_secret: CONSUMER_SECRET
}
 , url = 'https://api.twitter.com/oauth/request_token'
;
request.post({url:url, oauth:oauth}, function (e, r, body) {
 // Ideally, you would take the body in the response
 // and construct a URL that a user clicks on (like a sign in button).
 // The verifier is only available in the response after a user has
 // verified with twitter that they are authorizing your app.
 var access_token = qs.parse(body)
 , oauth =
 { consumer_key: CONSUMER_KEY
 , consumer_secret: CONSUMER_SECRET
 , token: access_token.oauth_token
 , verifier: access_token.oauth_verifier
}
 , url = 'https://api.twitter.com/oauth/access_token'
;
 request.post({url:url, oauth:oauth}, function (e, r, body) {
 var perm_token = qs.parse(body)
 , oauth =
 { consumer_key: CONSUMER_KEY
 , consumer_secret: CONSUMER_SECRET
 , token: perm_token.oauth_token
 , token_secret: perm_token.oauth_token_secret
}
 , url = 'https://api.twitter.com/1/users/show.json?'
 , params =
 { screen_name: perm_token.screen_name
 , user_id: perm_token.user_id
}
;
 url += qs.stringify(params)
 request.get({url:url, oauth:oauth, json:true}, function (e, r, user) {
console.log(user)
})
})
})

Benutzerdefinierter HTTP-Header

User-Agent und dergleichen können im Optionsobjekt festgelegt werden. Im folgenden Beispiel rufen wir die Github-API auf, um die Sammlungsnummer und die abgeleitete Nummer eines bestimmten Lagers herauszufinden. Wir haben einen angepassten User-Agent und https.

verwendet

var request = require('request');

var options = {
 url: 'https://api.github.com/repos/mikeal/request',
 headers: {
 'User-Agent': 'request'
}
};

function callback(error, response, body) {
 if (!error && response.statusCode == 200) {
 var info = JSON.parse(body);
 console.log(info.stargazers_count +"Stars");
 console.log(info.forks_count +"Forks");
}
}

request(options, callback);

Cookies:

Standardmäßig sind Cookies deaktiviert. Setzen Sie jar in den Standardeinstellungen oder Optionen auf „true“, damit nachfolgende Anfragen Cookies verwenden.

var request = request.defaults({jar: true})
request('http://www.google.com', function () {
request('http://images.google.com')
})

Durch das Erstellen einer neuen Instanz von request.jar() können Sie benutzerdefinierte Cookies anstelle der globalen Anforderungs-Cookie-JAR verwenden.

var j = request.jar()
var request = request.defaults({jar:j})
request('http://www.google.com', function () {
request('http://images.google.com')
})

oder

var j = request.jar()
var cookie = request.cookie('your_cookie_here')
j.setCookie(cookie, uri, function (err, cookie){})
request({url: 'http://www.google.com', jar: j}, function () {
request('http://images.google.com')
})

Beachten Sie, dass setCookie mindestens drei Parameter erfordert, der letzte ist die Callback-Funktion.

Sie können die Request-Pipe-Methode verwenden, um den Dateistream des Bildes einfach abzurufen

 var request = require('request'),
 fs = require('fs');
 
 request('https://www.google.com.hk/images/srpr/logo3w.png').pipe(fs.createWriteStream('doodle.png'));

Für weitere Verwendungsmethoden und Anweisungen klicken Sie bitte hier, um weiterzulesen: https://github.com/mikeal/request/

Beispiel

Hier ist ein sehr einfaches Beispiel, um die Hotelabfragedaten von Qunar.com abzurufen (die Preisrangfolge jedes Zimmertyps im Hotel innerhalb eines bestimmten Zeitraums abzurufen):

 var request = require('request'),
 fs = require('fs');
 
 
 var reqUrl = 'http://hotel.qunar.com/price/detail.jsp?fromDate=2012-08-18&toDate=2012-08-19&cityurl=shanghai_city&HotelSEQ=shanghai_city_2856&cn=5';
 
 request({uri:reqUrl}, function(err, response, body) {
 
 //console.log(response.statusCode);
 //console.log(response);
 
 //如果数据量比较大，就需要对返回的数据根据日期、酒店ID进行存储，如果获取数据进行对比的时候直接读文件
 var filePath = __dirname + '/data/data.js';
 
 if (fs.exists(filePath)) {
  fs.unlinkSync(filePath);
 
  console.log('Del file ' + filePath);
 }
 
 fs.writeFile(filePath, body, 'utf8', function(err) {
  if (err) {
  throw err;
  }
 
  console.log('Save ' + filePath + ' ok~');
 });
 
 console.log('Fetch ' + reqUrl + ' ok~');
 });

Dieses Beispiel stammt von einem Freund, der in der Hotelbranche tätig ist und wissen möchte, wie wettbewerbsfähig die Preise sind, die er seinen Kunden auf seiner Website anbietet:

1. Wenn der angegebene Preis zu niedrig ist, verdienen Sie weniger. Wenn Ihr Preis also der niedrigste ist, müssen Sie den zweitniedrigsten Preis ermitteln und dann entscheiden, ob Sie eine Anpassung vornehmen möchten

2. Wenn der angegebene Preis zu hoch ist, werden die Suchergebnisse relativ niedrig sein und es wird keine Kunden geben, die das Hotel buchen, und das Geschäft wird weg sein

Da wir viele Hotelbuchungsgeschäfte tätigen, zum Beispiel mehr als 2.000 Hotels, wird es passiver, wenn wir uns auf die manuelle Überprüfung der Rankings nacheinander verlassen, und es wird schwierig, weiter zu expandieren, so ich Analysieren Sie seine Bedürfnisse und es ist machbar und kann in ein gutes Echtzeit-Warnsystem umgewandelt werden (natürlich werden die Daten alle 5 bis 10 Minuten automatisch auf der Seite aktualisiert). Nur so können Gewinne maximiert, die Arbeitseffizienz der Vertriebs- und Kundenabteilungen verbessert sowie die Zahl der Hotelkooperationen und der Personalausbau des Unternehmens beschleunigt werden:

1. Wenn Sie kein Geld verlieren, führen Sie keine verlustbringenden Transaktionen durch

2. Wenn Sie feststellen, dass der angegebene Preis zu niedrig oder zu hoch ist, müssen Sie den Aufruf der API-Schnittstelle der Plattform unterstützen, um den Preis direkt zu ändern

3. Es hat die Funktion, automatisch Analyseberichte zu erstellen, um Änderungen in den Preisanpassungsstrategien der Wettbewerber zu analysieren;