javascript - node-ipc cluster only using 1 worker -


i using node-ipc alongside cluster in nodejs on windows 8.1, , have clustered ipc server , created many processes have cpu's (4 in case), of them sharing same port , id.

i connecting multiple clients clustered server , expecting master process delegate task worker free. not work , master chooses same worker.

i have checked , worker processes running. how can master chooses least busy worker every time?

below server code

var os = require('os'); var numcpus = os.cpus().length; var cluster = require('cluster'); var ipc = require('node-ipc');  if (cluster.ismaster) {      console.log("i master, launching workers");      (var = 0; < numcpus; i++) {         cluster.fork();         console.log("worker " + + " launched");     }  } else {      ipc.config.id = 'worldserver';     ipc.config.retry= 1500;     ipc.config.silent = true;      console.log(`i worker #${cluster.worker.id}`, process.pid);      ipc.serve(         function(){             ipc.server.on('sayhello', function(data,socket) {                     console.log(`i worker #${cluster.worker.id}`, process.pid);                     ipc.server.emit(                         socket,                         'message',                         'hello'                     );                 }             );             ipc.server.on('error', function(e) {                 console.log('ipc error!!', e);             });     });      ipc.server.start(); }

here client code

var ipc=require('node-ipc');  ipc.config.id   = 'hello'; ipc.config.retry= 1500; ipc.config.silent = true;  setinterval(function() {     ipc.connectto(         'worldserver',         function(){                  console.log("sending something");                 ipc.of.worldserver.emit(                     'sayhello',                     "true"                 );                  ipc.of.worldserver.on(                     'message',                     function(data){                         console.log('i got message server:');                         console.log(data);                     }                 );            }     ); }, 20);


-

Comments

Post a Comment

Popular posts from this blog

serialization - Convert Any type in scala to Array[Byte] and back -

i have following question: i have variable value in program declared value. i want convert value byte array.. how can serialize byte array , back? found examples related other types such double or int, not any. this should need. it's pretty similar how 1 in java. import java.io.{bytearrayinputstream, bytearrayoutputstream, objectinputstream, objectoutputstream} object serialization extends app { def serialise(value: any): array[byte] = { val stream: bytearrayoutputstream = new bytearrayoutputstream() val oos = new objectoutputstream(stream) oos.writeobject(value) oos.close stream.tobytearray } def deserialise(bytes: array[byte]): = { val ois = new objectinputstream(new bytearrayinputstream(bytes)) val value = ois.readobject ois.close value } println(deserialise(serialise("my test"))) println(deserialise(serialise(list(1)))) println(deserialise(serialise(map(1 -> 2)))) println(deserialise(seri
Read more

matplotlib support failed in PyCharm on OSX -

any idea how fix ? how can debug might problem ? not seem : https://youtrack.jetbrains.com/issue/py-15520 i in console: python 2.6.9 (unknown, jul 14 2015, 19:46:31) [gcc 4.2.1 compatible apple llvm 6.0 (clang-600.0.39)] on darwin >>> import matplotlib.pyplot plt matplotlib support failed the backend : >>> import matplotlib >>> print(matplotlib.rcparams['backend']) macosx
Read more

python - Matplotlib: TypeError: 'AxesSubplot' object is not callable -

i new programming please pardon me if rookie mistake. i writing python script have defined functions create subplots of distributions. i have slider widget end user change value of variables(mu , sigma) , see effect on distribution. here's code import numpy np print np.__version__ import scipy print scipy.__version__ scipy.stats import norm, lognorm, uniform import matplotlib print matplotlib.__version__ import matplotlib.pyplot plt matplotlib.widgets import slider, button, radiobuttons, checkbuttons #####calculating mean , standard deviation##### global mu_a1 mu_a1 = 1 global mu_b1 mu_b1 = 10 global mu_c1 mu_c1 = -13 global sigma_a1 sigma_a1 = 0.14 global sigma_b1 sigma_b1 = 1.16 global sigma_c1 sigma_c1 = 2.87 mu_x01 = -11 sigma_x01 = 1.9 #####_____##### #####generating random data##### a1 = 0.75*mu_a1 + (1.25 - 0.75)*sigma_a1*np.random.sample(10000) b1 = 8*mu_b1 + (12 - 8)*sigma_b1*np.random.sample(10000) c1 = -12*mu_c1 + 2*sigma_c1*np.random.sample(10000)
Read more