KOBA789 です。
なるほど、問題点の本質がわかりました。
まず、Socket.IO の仕様をよく知った方がよいかと思います。標準機能を適切に活用することで解決できる問題は多くあります。自身に接続してチャンネルに
join している点に関してはこれで解決できます。
また、現状の外側のスコープの変数による状態の受け渡しでは、ロックが必要になってしまいますし、クロージャを使える JavaScript
を用いた実装としては素直ではありません。はっきり言って悪い実装ですから避けなければなりません。なお、変数に無駄なスコープを持たせないことはバグの発見の容易さや、バグの回避につながります。
最後に重箱の隅をつつくようで申し訳ありませんが、変数の初期化に空文字列を乱用するのは避けたほうがよいでしょう。型に合わせた初期化をすることで、VM
はメモリ確保に関して最適化をします。ですから、不適切な型による初期化はパフォーマンス劣化につながります。
以上の点を踏まえてソースを書き直すと以下のようにできるかと思います。ただ、typo
と考えられるものなどがいくつかあり、ソースの真意が読めない部分が多いため、どうしても多くを憶測で書いてしまいました。挙動が異なってしまっていたら申し訳ありません。
======================================================================
var http = require("http");
var url = require("url");
function start(route,handle){
function onRequest(request,response){
var queryData = url.parse(request.url, true).query;
var url_parts = url.parse(request.url,true);
var query = url.parse(request.url, true).query;
var pathname = url.parse(request.url).pathname;
serversocket2("Appname",query);
request.setEncoding("utf8");
request.addListener("end",function(){
route(handle,pathname,response);
});
}
var server = http.createServer(onRequest).listen(8080);
//console.log("Serevr has sterted.");
// socket.io
var io = require('socket.io').listen(server);
var archiveMessages = {};
var channels = ['Appname'];
var appname = io.of('/appname');
appname.on('connection', function(socket){
console.log('connected: %s', socket.id);
// push available channel list
socket.emit('available_channel', channels);
socket.on('join', function(value){
console.log('%s joined channel: %s', socket.id, value.channelId);
socket.join(value.channelId);
socket.set('channel_id', value.channelId);
});
socket.on('post', function(message){
socket.get('channel_id', function(err, channelId){
console.log(' %s says<%s channel>: %s', socket.id, channelId, message);
});
});
socket.on('disconnect', function(){
console.log('%s disconnected', socket.id);
socket.get('channel_id', function(channelId){
socket.leave(channelId);
});
});
});
function serversocket2(channelId,data){
appname.in(channelId).emit('user:message', data);
}
};
exports.start = start;
2013年1月24日 20:28 matton <[email protected]>:
> KOBA789さん返信ありがとうございます。
>
> はじめにnode初めて間もない為、ソースが汚く申し訳ございません。
>
> setTimeoutを使用している理由は"serversocket1"にてクライアント（自分）→サーバ（自分）にjoinを行っているのですが、サーバ側の処理（socket.join）が終わる前に"serversocket2"が動くと"socket_c"が空の状態となる為、setTimeoutを用いています。
> ※"socket_c"は"socket.join"にてセットしています。
> http.createServerの処理とsocket.io間でコールバックをネストさせる方法はわかりませんでした。
>
> お手数ですが、アドバイスよろしくお願いします。
>
>
> 2013年1月24日木曜日 19時36分23秒 UTC+9 KOBA789:
>>
>> KOBA789 です。
>>
>> 指摘したい点はたくさんありますが、まず1点だけ失礼します。
>> なぜ、わざわざ setTimeout による時間差によって実行順序を指定するということをしているのでしょうか。
>>
>> 素直に考えて、コールバックをネストさせることで対応するのが最善だと思うのですが、そうしなかった理由を教えていただきたいです。その理由知ることでより踏み込んだアドバイスができると考えています。
>>
>> 2013年1月24日 11:03 matton <[email protected]>:
>> > お世話になります。 松尾と申します。
>> >
>> > node.jsにて下記の様な仕組みを作成しております。
>> >
>> > 現在、バッチプログラム(vs.net C#)にてDB監視を行い、結果をクライアントに通知する仕組みを作成しています。
>> > 監視バッチ→node.js→ios/android
>> >
>> > として、node.js→ios/androidはリアルタイム通知の為、soket-ioを使用しています。（※ちなみに監視バッチ→node.jsはwebsocketが使用できない為、URLにてデータを渡しています。http://xxx?1=a&2=B）
>> > node.js内でアクセスされたURL引数をJSONに変換してクライアントへsocket-ioにて一斉配信しています。
>> >
>> >
>> > とりあえず動いてはいるのですが、URLで受け取ったデータをsocket-ioにて配信する際、一度、自分自身のsocket-ioにconnectしてsocketにセットしています。
>> >
>> > connectが非同期となる為setTimeoutを利用している為、サーバの負荷次第ではconnect処理(serversocket1)を配信処理(serversocket2)が追い越してしまうと考えています。
>> >
>> > 何か良い制御方法は無いのでしょうか？
>> >
>> > よろしくお願いします。
>> >
>> > 環境
>> > windows2003 sp2
>> > node v0.8.17
>> >
>> >
>> > メイン部分のソースです。
>> >
>> > -------------------------------------------------------------------------------------------
>> > var http = require("http");
>> > var url = require("url");
>> >
>> > var socketval = 0;
>> >
>> >
>> > function start(route,handle){
>> > var query = "";
>> > function onRequest(request,response){
>> > var queryData = url.parse(request.url, true).query;
>> > var url_parts = url.parse(request.url,true);
>> > query = url.parse(request.url, true).query;
>> > var pathname = url.parse(request.url).pathname;
>> > if(socketval===0){
>> > setTimeout(function(){serversocket1("Appname",query)},1);
>> > };
>> >
>> > setTimeout(function(){serversocket2("Appname",query)},1000);
>> > request.setEncoding("utf8");
>> >
>> > request.addListener("end",function(){
>> > route(handle,pathname,response);
>> > });
>> > }
>> >
>> > var server = http.createServer(onRequest).listen(8080);
>> > //console.log("Serevr has sterted.");
>> >
>> > // socket.io
>> > var io = require('socket.io').listen(server);
>> >
>> >
>> > var archiveMessages = {};
>> > var channels = ['Appname'];
>> >
>> > var appname = io.of('/appname');
>> > var socket = "";
>> > var socket_c = "";
>> > appname.on('connection', function(socketin){
>> > console.log('connected: %s', socket.id);
>> > socket = socketin;
>> >
>> > // push available channel list
>> > socket.emit('available_channel', channels);
>> >
>> > socket.on('join', function(value){
>> > console.log('%s joined channel: %s', socket.id,
>> > value.channelId);
>> >
>> > socket.join(value.channelId);
>> > });
>> > socket.on('join_c', function(value){
>> > console.log('clientjoin %s joined channel: %s', socket.id,
>> > value.channelId);
>> >
>> > socket.join(value.channelId);
>> > socket_c = socket;
>> > socketval=1;
>> > });
>> >
>> > socket.on('post', function(message){
>> > socket.get('channel_id', function(err, channelId){
>> > console.log(' %s says<%s channel>: %s', socket.id,
>> > channelId, message);
>> >
>> > });
>> > });
>> >
>> > socket.on('disconnect', function(){
>> > console.log('%s disconnected', socket.id);
>> > socket.get('channel_id', function(channelId){
>> > socket.leave(channelId);
>> > });
>> > });
>> >
>> > });
>> >
>> > var io_c = require('socket.io').client;
>> > var appname_c = "";
>> > function serversocket1(channelId,data){
>> > var appname_c_1 = io_c.connect('http://localhost:8080');
>> > appname_c = appname_c_1.of('/appname');
>> >
>> > appname_c.emit('join_c', {
>> > channelId: 'Appname'
>> > });
>> >
>> > }
>> > function serversocket2(channelId,data){
>> > socket_c.set('channel_id', channelId, function(){
>> > socket_c.emit('posted', data);
>> > socket_c.broadcast.to(channelId).emit('user:message', data);
>> > });
>> > }
>> > };
>> >
>> > exports.start = start;
>> >
>> > ------------------------------------------------------------------------------------------------
>> >
>> >
>> >
>> > --
>> >
>> >
>> >
>
> --
>
>
>
--
