.net - ZeroMQ PUSH/PULL and lost message -

-

i'm making use of zeromq .net , got stuck trying fix weird issue. i've got socket of type push , 1 of type pull on tcp. when client disconnects, server still able to send message (note no flags passed socket.send method) gets lots before starting block , waiting client reconnect , delivering messages try send afterwards.

how can avoid losing message (or in worst case test if client connected , if not send dummy message can afford losing)?

thanks in advance!

edit: further testing reveals if wait 1 second after sending first message after disconnection client, second 1 block, if don't wait @ can send many messages want , they'll lost. that's quite confusing...

the zeromq documentation notes problem push/pull setups , suggests following pattern: addition of rep/req setup provide node coordination when you're expecting fixed number of subscribers. however, if not able know number of subscribers in advance, should consider changing protocol more resilient these conditions.

synchronized publisher in c (from zguide)

// //  synchronized publisher // #include "zhelpers.h"  //  we wait for 10 subscribers #define subscribers_expected  10  int main (void)  {     s_version_assert (2, 1);     void *context = zmq_init (1);      //  socket to talk to clients     void *publisher = zmq_socket (context, zmq_pub);     zmq_bind (publisher, "tcp://*:5561");      //  socket to receive signals     void *syncservice = zmq_socket (context, zmq_rep);     zmq_bind (syncservice, "tcp://*:5562");      //  get synchronization from subscribers     int subscribers = 0;     while (subscribers < subscribers_expected) {         //  - wait for synchronization request         char *string = s_recv (syncservice);         free (string);         //  - send synchronization reply         s_send (syncservice, "");         subscribers++;     }     //  now broadcast exactly 1m updates followed by end     int update_nbr;     for (update_nbr = 0; update_nbr < 1000000; update_nbr++)         s_send (publisher, "rhubarb");      s_send (publisher, "end");      zmq_close (publisher);     zmq_close (syncservice);     zmq_term (context);     return 0; }

Comments

Post a Comment

Popular posts from this blog

linux - Mailx and Gmail nss config dir -

-
i trying send mail linux command line using mailx command. can send local domain no problem want set mail send gmail account receive mail sent gmail account. after configuring mail.rc so: account gmail { set smtp=smtps://smtp.gmail.com:587 set smtp-auth=login set smtp-auth-user=username@gmail.com set smtp-auth-password=password set ssl-verify=ignore } i error: resolving host smtp.gmail.com . . . done. connecting 74.125.25.109 . . . connected. missing "nss-config-dir" variable. "/home/username/dead.letter" 11/354 . . . message not sent. after looking "nss-config-dir" here , located certn.db , keyn.db files , added mail.rc so: account gmail { set smtp=smtps://smtp.gmail.com:587 set smtp-auth=login set smtp-auth-user=username@gmail.com set smtp-auth-password=password set ssl-verify=ignore set nss-config-dir=/home/user/.mozilla/firefox/location.default } now when try send mail using command: echo "sent gmail account" | mailx -v -a
Read more

c# - Is it possible to remove an existing registration from Autofac container builder? -

-
something along lines: builder.registertype<mytype>().as<itype>(); builder.registertype<mytype2>().as<itype>(); builder.deregistertype<mytype>().as<itype>() var container = builder.build(); var types = container.resolve<ienumerable<itype>>(); assert.istrue(types.count == 1); assert.istrue(types[0].gettype == typeof(mytype2)); scenario: go through bunch of assemblies , go register types want make sure have 1 implementation of given type. need before create container. track on own nice if autofac me bit. this cannot done directly using containerbuilder , unless start on new one. mind you, having first built container should able construct new container filtering away unwanted types , reusing registrations first container. this: ... var container = builder.build(); builder = new containerbuilder(); var components = container.componentregistry.registrations .where(cr => cr.activator.limittype != typ
Read more

php - Mysql PK and FK char(36) vs int(10) -

-
i have read mysql can handle indexes , searches better if tables keys integers rather char(36) uuid's. is worth converting int(10)? note: use 1 server , have have plans use multiple databases concurrently therefore removing 1 of big reasons using uuid. our tables innodb if makes difference. thanks in advance. usually rdbms can handle integer keys pk more efficient, other datatypes. reason how build index column, yes: long dont require string (or other typed) keys, should use integers. however: char(36) , int(10) far away being equal, because int(10) much smaller, char(36). dont know, if require many different keys, should keep in mind. update, complete last paragraph: int(10) 32-bit, char(36) 36 - ^byte^ (= 288-bit). not mean, int consumes less space, means, char(36) has 4 times more different keys.
Read more