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.
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 :
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 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, der Standardwert ist 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 im eingestellt werden Optionsobjekt. Im folgenden Beispiel rufen wir die Github-API auf, um die Sammlungsnummer und die abgeleitete Nummer eines bestimmten Lagers herauszufinden. Wir verwenden einen angepassten User-Agent und https. Setzen Sie jar in den Standardeinstellungen oder Optionen auf „true“, damit nachfolgende Anfragen Cookies verwenden.
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);
var request = request.defaults({jar: true}) request('http://www.google.com', function () { request('http://images.google.com') })
var j = request.jar() var request = request.defaults({jar:j}) request('http://www.google.com', function () { request('http://images.google.com') })
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') })
var request = require('request'), fs = require('fs'); request('https://www.google.com.hk/images/srpr/logo3w.png').pipe(fs.createWriteStream('doodle.png'));
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~'); });
Weil wir viele Hotelbuchungsgeschäfte tätigen, zum Beispiel mehr als 2.000 Hotels, wenn wir uns darauf verlassen Die manuelle Überprüfung der Rangliste nacheinander wird passiver und schwierig zu erweitern sein. Daher habe ich analysiert, dass dies machbar ist und in ein gutes Echtzeit-Warnsystem umgewandelt werden kann (natürlich). Die Daten werden 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.
Weitere verwandte Artikel zum grundlegenden Nutzungstutorial des Request-Moduls in Node.js zur Verarbeitung von HTTP-Protokollanfragen Bitte achten Sie auf die chinesische PHP-Website!