そろそろnode.jsについて一言書いておくか

はじめに

毎年サーバーサイドJavaScriptが流行ると言ってるみなさんこんにちはダニーです。
ということで、node.jsをはじめてみました。
Twitter Streaming APIで取得したデーターをWebSocketで
接続したクライアントに出力するデモを作成したので紹介したいと思います。

今回のデモについて

今回作成したデモは
node.jsのHttpClinetでTwtter Streaming APIでTwtterからデータを取得して、
node.jsのWebSocket Serverでそのデータを接続してきたWebSocket対応ブラウザに送信するということを
やっています。

Twitter Streaming APIで取得できるようにする。

動かすのにhttp-basic-authが必要です。
[cc lang='bash']
npm install http-basic-auth
[/cc]

streaming.js
[cc lang='js']
var sys = require('sys');
var http = require('http-basic-auth');
var account = {
username: 'username',
password: 'password'
};
var client = http.createClient(80, 'stream.twitter.com', false, false, account);
var request = client.request('GET', '/1/statuses/sample.json', {'host': 'stream.twitter.com'});

request.end();
request.on('response', function (response) {
response.on('data', function(chunk) {
sys.puts(chunk);
});
});
[/cc]
twitterのユーザー名とパスワードを設定して
[cc lang='bash']
node streaming.js
[/cc]
Streaming APIのデーターが取得できるようになります。

WebSocketのサーバーを作る

動かすのにwebsocket-serverが必要です。
[cc lang='bash']
npm install websocket-server
[/cc]

server.js

[cc lang='js']
var sys = require('sys');
var ws = require('websocket-server');
var wsServer = ws.createServer();

wsServer.addListener("connection", function(connection) {
sys.puts("connect: " + connection._req.socket.remoteAddress);
});

wsServer.addListener("close", function(connection) {
sys.puts("close: " + connection._req.socket.remoteAddress);
});
wsServer.listen(8000);
[/cc]
addListenerでそれぞれ接続した場合、切断した場合に呼ばれます。
wsServer.listen(8000)で今回はwebsocketのサーバーのポートは8000に指定してます。

合わせてみる

streaming.js
[cc lang='js']
var sys = require('sys');
var ws = require('websocket-server');
var wsServer = ws.createServer();

wsServer.addListener("connection", function(connection) {
sys.puts("connect: " + connection._req.socket.remoteAddress);
});

wsServer.addListener("close", function(connection) {
sys.puts("close: " + connection._req.socket.remoteAddress);
});
wsServer.listen(8000);

var http = require('http-basic-auth');
var account = {
username: 'username',
password: 'password'
};
var client = http.createClient(80, 'stream.twitter.com', false, false, account);
var request = client.request('GET', '/1/statuses/sample.json', {'host': 'stream.twitter.com'});

request.end();
request.on('response', function (response) {
response.on('data', function(chunk) {
wsServer.broadcast(chunk);
});
});
[/cc]

合わせるとこのようになります。
http clientのレスポンスでデーターが取得した時に
wsServer.broadcast(chunk);でWebSocketのサーバーから
クライアントに送信をします。

クライアント側

client.html
[cc lang='js']

[/cc]
ws://localhost:8000はサーバ側で指定したポートが8000なのとlocalhostはローカルで動かしてるので
必要に応じて変更してください。
onopenがWebSocketのサーバー接続時に呼ばれます。
onmessageがWebSocketのサーバーからクライアントに対して送信された時に呼ばれます。

動かしてみる

[cc lang='bash']
node streaming.js
[/cc]
でブラウザからclient.htmlにアクセスします。
WebSocket対応ブラウザじゃないと動きませんので注意して下さい。

最後に

WebSocketは一回接続してしまえばブラウザをリロードしなくても
データを変更できるので便利ですね。
リアルタイムなことをするのにいいですね。