Comment créer un socket "unique" dans zeromq?

Question

J'expérimente avec un simple modèle d'acteur dans haskell, où chaque acteur:

• est un fil haskell
• a une prise PULL ZeroMQ sur laquelle il reçoit des messages

Certains acteurs sont "bien connus", ont des durées de vie indéfinies, et ont donc leur socket lié à un port bien connu. Les autres acteurs sont de courte durée et transitoires, et nécessitent donc un port libre aléatoire qui leur est affecté.

J'étais pas au courant de la capacité de zmq3 à permettre la liaison à un port éphémère, comme décrit ici: http://api.zeromq.org/3-2:zmq-tcp

Par conséquent, pour les acteurs transitoires J'ai actuellement un code qui tente de se lier à un port libre dans une fourchette donnée. Cela fonctionne comme destiné, mais met en évidence un comportement zmq qui me cause problèmes: Si un acteur temporaire ferme son port et se termine, et un nouvel acteur transitoire commence, il est susceptible de se lier au même port de l'ancien . Dans ce cas, tous les messages subséquents ou placés en file d'attente pour l'ancien acteur seront reçus par le nouveau .

Comment puis-je éviter cela?

Si je dois mes prises d'acteurs transitoires en utilisant le caractère générique pour obtenir un système affecté port éphémère, ce que je vois encore potentiellement ce problème?

Comment puis-je générer un nouveau socket PULL unique avec le transport TCP qui est garanti distinct des autres?

Answer 1

En général, vous utilisez bind() uniquement pour les acteurs stables et «bien connus», et vous utilisez connect() pour les acteurs temporaires. Cela semble un peu bizarre si vous avez besoin du numéro de port pour les acteurs transitoires. En outre, vous devriez peut-être ajouter quelque chose à votre protocole afin que les acteurs transitoires qui s'en vont le sachent, afin que l'autre camp ne continue pas à leur envoyer des messages (qui sont ensuite reçus par un nouveau transitoire). acteur lié au même port que l'ancien).

Je pense que les ports éphémères assignés par le système essaient généralement de ne pas réutiliser les ports immédiatement, ce qui résoudrait probablement aussi certains de vos problèmes.