node.js で何回かHTTP通信をしたときの対応。
node.jsはシングルスレッドで動作します。
さらにノンブロッキングなので同期的な処理は基本しません。
なのでHTTP通信を行って、結果を待って、次の処理というのは
普通に書くとネスト地獄になりコードの可読性が著しく悪くなります。
ということで今回は「Promise」を使用しました。
本当は「sync-request」を使おうと思ったのですが
非推奨？なのかあまり使うなと書かれていたので、今回はパス！
あと一応命名や文法も気にはしてますが、完全に守れてはいないのあしからず・・・
http://cou929.nu/data/google_javascript_style_guide/
http://popkirby.github.io/contents/nodeguide/style.html
何も考えないで実装した場合
app.js
const https = require ('https');
const url = require('url');
const ACCESS_URL = 'https://www.itcowork.co.jp/';
const opt = url.parse(ACCESS_URL);
opt.method = 'GET';
console.log('START');
// 変数を宣言
var code;
var body;
var req = https.request(opt, (res) => { console.log('status code : ' + res.statusCode); code = res.statusCode; body = ''; res.on('data', (chunk) => { body += chunk; console.log('data'); }); res.on('end', () => { console.log('end'); });
})
req.on('error', (err) => { console.log('request error : ' + err.message);
});
req.end();
console.log('LAST CHECK : ' + code);
console.log('END');START LAST CHECK : undefined END status code : 200 data end
先に「LAST CHECK」が出てあとからHTTP処理の結果が出ています。
１個だけHTTP処理をする分にはこれでも大丈夫です。
もしくは「end」の処理の部分に別Functionを呼び出してネストしまくるとか
でも一応は対応できます。
が、今回はもっとスマートに書きたいので「Promise」を使用します。
Promiseを利用した場合
app.js
const https = require ('https');
const url = require('url');
const ACCESS_URL = 'https://www.itcowork.co.jp/';
const opt = url.parse(ACCESS_URL);
opt.method = 'GET';
console.log('START');
test1().then((value) => { console.log('status code : ' + value); console.log('END');
}, (err) => { console.error("error:", err.message);
});
function test1(){ return new Promise ((resolve, reject) => { var req = https.request(opt, (res) => { console.log('1.status code(function) : ' + res.statusCode); var code = res.statusCode; var body = ''; res.on('data', (chunk) => { body += chunk; console.log('1.data'); }); res.on('end', () => { console.log('1.end'); resolve(code); }); }) req.on('error', (err) => { console.log('1.request error : ' + err.message); reject(err) }); req.end(); });
}START 1.status code(function) : 200 1.data 1.end status code : 200 END
Promiseオブジェクトを作成して、thenで実行し実行結果を取得しました。
正しい順序でログが出てることがわかります。
複数回HTTP通信
次に複数回のHTTP通信の実装です。
お試しなのでHTTP通信先はまったく同じですごめんなさいm(_ _)m
app.js
const https = require ('https');
const url = require('url');
const ACCESS_URL = 'https://www.itcowork.co.jp/';
const opt = url.parse(ACCESS_URL);
opt.method = 'GET';
console.log('START');
var promise = Promise.resolve();
promise .then(test1) .then((result) => { return new Promise(function(resolve, reject){ console.log("1.status code : " + result); resolve(1); }); }) .then(test2) .then((result) => { return new Promise(function(resolve, reject){ console.log("2.status code : " + result); resolve(2); }); }) .catch(onRejectted);
function test1(){ return new Promise ((resolve, reject) => { var req = https.request(opt, (res) => { console.log('1.status code(function) : ' + res.statusCode); var code = res.statusCode; var body = ''; res.on('data', (chunk) => { body += chunk; console.log('1.data'); }); res.on('end', () => { console.log('1.end'); resolve(code); }); }) req.on('error', (err) => { console.log('1.request error : ' + err.message); reject(err) }); req.end(); });
}
function test2(){ return new Promise ((resolve, reject) => { var req = https.request(opt, (res) => { console.log('2.status code(function) : ' + res.statusCode); var code = res.statusCode; var body = ''; res.on('data', (chunk) => { body += chunk; console.log('2.data'); }); res.on('end', () => { console.log('2.end'); resolve(code); }); }) req.on('error', (err) => { console.log('2.request error : ' + err.message); reject(err) }); req.end(); });
}
function onRejectted(error) { console.log("error：" + error);
}START 1.status code(function) : 200 1.data 1.end 1.status code : 200 2.status code(function) : 200 2.data 2.end 2.status code : 200
もし「test1」と「test2」のFunctionに引数を渡す場合は
以下のように呼び出せば正しく動作します。
var promise = Promise.resolve();
promise .then((result) => { return test1(1); }) .then((result) => { return new Promise(function(resolve, reject){ console.log("1.status code : " + result); resolve(1); }); }) .then((result) => { return test2(2); }) .then((result) => { return new Promise(function(resolve, reject){ console.log("2.status code : " + result); resolve(2); }); }) .catch(onRejectted);途中でエラーにしたい場合は以下のようにすればOKのはず
var promise = Promise.resolve();
promise .then(test1) .then((result) => { return new Promise(function(resolve, reject){ console.log("1.status code : " + result); if(result == 404) reject(new Error("わざとエラー")); //resolve(1); }); }) .then(test2) .then((result) => { return new Promise(function(resolve, reject){ console.log("2.status code : " + result); resolve(2); }); }) .catch(onRejectted);START 1.status code(function) : 404 1.data 1.end 1.status code : 404 error：Error: わざとエラー
まとめ
久しぶりに複数処理を書きましたが、
非同期とか久しぶりすぎて忘れてました！
そして未だにアロー関数（=>）に慣れませんｗ
ちなみにソース中でHTTPアクセスしてるのは
前職のWEBサイトです。怒られたら変更しよう！
以上
