Einführung in die Verwendung des Request-Moduls in Node.js zur Verarbeitung von HTTP-Protokollanforderungen

In diesem Artikel wird hauptsächlich das grundlegende Tutorial zur Verwendung des Request-Moduls in Node.js zur Verarbeitung von HTTP-Anfragen vorgestellt, das auch OAuth-Signaturanfragen unterstützt, was sehr gut und leistungsstark ist.

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'))

Sie können die Datei wiederum auch an eine PUT- oder POST-Anfrage ü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 sich 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:

Anfrage 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 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-Login:

// 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 finden Sie im set im Optionsobjekt. 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 Anpassen verwenden Cookies, anstatt die globale Cookie-Dose anzufordern.

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, den letzten one Ist die Rückruffunktion.

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'));

Weitere Verwendungsmethoden und Anweisungen finden Sie hier weiterlesen: https://github.com/mikeal/request/

Beispiel

Hier wird ein sehr einfaches Beispiel geschrieben, um Hotels aus der Qunar.com-Abfrage abzurufen Daten (erhalten Sie die Preisrangfolge jedes Zimmertyps im Hotel innerhalb eines bestimmten Zeitraums):

 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 es wissen möchte was er seinen Kunden auf seiner Website bietet Preiswettbewerbsfähigkeit:

1 Wenn der angebotene Preis zu niedrig ist, verdienen Sie weniger Geld. Wenn Ihr Preis also am niedrigsten ist, müssen Sie nach dem zweitniedrigsten suchen , und entscheiden Sie dann, ob eine Anpassung erfolgen soll;

2. Wenn der angegebene Preis zu hoch ist, werden die Ranking-Ergebnisse niedriger sein und es wird keine Kunden geben, die das Hotel buchen, und das Geschäft wird weg sein

Weil es viele Buchungsunternehmen gibt, zum Beispiel mehr als 2.000. Wenn Sie sich auf die manuelle Überprüfung der Rankings verlassen, wird es passiv sein, und es wird schwierig sein, es zu erweitern analysiert 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 und die Zahl der Hotelkooperationen sowie der Personalausbau des Unternehmens beschleunigt werden:

1 Führen Sie verlustbringende 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 gibt eine Funktion zum automatischen Generieren von Analyseberichten, um die Preisanpassungsstrategien der Wettbewerber zu analysieren.

Ich hoffe, dass dies hilfreich ist Weitere verwandte Inhalte finden Sie auf der chinesischen PHP-Website!

Verwandte Empfehlungen:

Einführung in Moduldefinitionen in NodeJS

Erfahren Sie mehr über das Clustermodul in Node

Wie NodeJS das asynchrone Bigpipe-Laden von Seiten implementiert

Das obige ist der detaillierte Inhalt vonEinführung in die Verwendung des Request-Moduls in Node.js zur Verarbeitung von HTTP-Protokollanforderungen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!