Node.js,Socket.io,Http-Proxy,Cluster,Express - Handshake drops on disconnect - delay in reconnect -

-

i'm using node.js , socket.io. i'm using http-proxy use port 80 on machine that's running apache also. apache on different ip. works great.

i added in cluster , things got funky. spawns 2 workers (dual core vm) expected. connection on client side, off. it's good, if disconnect, there's delay reconnecting (there wasn't without cluster).

here's code have.. ideas why there's delay between disconnect , connect using cluster?

var http          = require('http'),     httpproxy     = require('http-proxy'),     io            = require('socket.io'),     cluster       = require('cluster'),     express       = require('express'),     redisstore    = require('connect-redis')(express);   var numcpus = require('os').cpus().length;  if (cluster.ismaster) {        //fork workers.       (var = 0; < numcpus; i++) {         cluster.fork();       }        cluster.on('death', function(worker) {         console.log('worker ' + worker.pid + ' died');       });  } else {       //server workers     var app = express.createserver().listen(8585, '172.16.183.129');     app.configure(function(){           app.use(express.bodyparser());           app.use(express.methodoverride());           app.use(express.cookieparser());           app.use(express.session({ secret: "secret", store: new redisstore}));           app.use(app.router);           app.use(express.errorhandler({showstack: false, dumpexceptions: false}));           app.use(express.static(__dirname + '/public'));     });       //create proxy server use port 80     var proxy = httpproxy.createserver(8585, '172.16.183.129');     proxy.listen(80, '172.16.183.129');      //initilize socket.io     var io = require('socket.io').listen(app, {origins: '*:*'});           io.sockets.on('connection', function(socket){             var test = setinterval(function() {               socket.emit('test', { result: numcpus});                i++;           }, 900);             socket.on('disconnect', function () {                 console.log('disconnect');                 clearinterval(auctiontimer);             });            });  }

you need add in redisstore socket workers can work together. note latest version of socket.io has built in redisstore should use instead of connect-redis stuff.

socketio = require('socket.io')  var io = socketio.listen(app, {origins: '*:*'});   var host = 'redisserver' var opts = {redissub:{host:host},redispub:{host:host},redisclient:{host:host}} io.set('store', new socketio.redisstore(opts))

Comments

Post a Comment

Popular posts from this blog

jasper reports - Fixed header in Excel using JasperReports -

-
how can create excel report fixed header using japserreports? mean need header fixed when scroll excel file. this possible adding couple properties in jrxml file each report. take @ advanced excel features freeze panes. if wanted freeze after first column header (down left side basically) this: <statictext> <reportelement style="sans_bold" mode="opaque" x="0" y="60" width="104" height="20" forecolor="#ffffff" backcolor="#666666"> <property name="net.sf.jasperreports.export.xls.auto.filter" value="start"/> <property name="net.sf.jasperreports.export.xls.column.width" value="110"/> <property name="net.sf.jasperreports.export.xls.freeze.column.edge" value="left"/> </reportelement> &
Read more

media player - Android: mediaplayer went away with unhandled events -

-
i need duration of audio file series of voice announcements need play app. have added audio files resources , play fine. sample code below works perfect intended purpose: return duration of audio files. here code: float getdurationofaudioresource(locationenum loc, context context){ float duration = 0; try { mediaplayer mp; mp = mediaplayer.create(context, getaudioresource(loc)); duration = mp.getduration(); mp.release(); mp = null; } catch (illegalstateexception e) {e.printstacktrace(); logerror(25, "testdescitem:fault::could not open mediaplayer object audio resource.");} return duration; } here's weird thing. code called in main activity prepares set of audio instructions given test. there no errors within activity. second activity called, long string of errors on logcat. 03-07 13:23:43.820: i/actionlogger(21435): gentest_info_test #0 created. 03-07 13:23:43.830: i/actionlogger(21435): gente
Read more

python - ('The SQL contains 0 parameter markers, but 50 parameters were supplied', 'HY000') or TypeError: 'tuple' object is not callable -

-
import pyodbc,nltk,array cnxn = pyodbc.connect('driver={mysql odbc 5.1 driver};server=127.0.0.1;port=3306;database=information_schema;user=root; password=1234;option=3;') cursor = cnxn.cursor() cursor.execute("use collegedatabase ;") cursor.execute("select * sampledata ; ") cnxn.commit() s=[] j=[] x=[] words = [] w = [] sfq = [] pos=[] entry in cursor: s.append(entry.injury_type),j.append(entry.injury_desc) nltk.tokenize import punktwordtokenizer nltk.corpus import stopwords tokenizer = punktwordtokenizer() english_stops = set(stopwords.words('english')) in range(0,26): # filter stop words tokenizer.tokenize(j[i]) w.append([word word in tokenizer.tokenize(j[i]) if word not in english_stops]) in range(0 , 26):#converting tokenzied text ito string sfq.append(" ".join(w[a])) replacers import regexpreplacer replacer = regexpreplacer() in range (0,26):#pos tagging replacer.repl
Read more