Was ist zmq.ROUTER und zmq.HÄNDLER in python zeromq?

HÄNDLER und ROUTER sind sockets, die einfache Skalierung von REQ /REP Paare.

In der direkten Kommunikation, REQ und REP sprechen blockieren Weise.

ROUTER - Annahme von Anfragen - von REQ Seite

Einem router ist in der Lage, Anfragen akzeptiert, fügt einen Umschlag mit Informationen über das anforderungsempfänger, und macht diese neue Nachricht zur weiteren Verarbeitung durch zusammenschalten code). Wenn die Antwort kommt zurück (in einem Umschlag), kann es passieren die Antwort zurück an den anforderungsempfänger.

HÄNDLER - Gespräche, um Mitarbeiter - auf REP Seite

Händler kümmert sich um Arbeitnehmer. Beachten Sie, dass, um die ganze Lösung nutzbar, die Arbeiter haben eine Verbindung zu dem Händler, nicht die andere Weise herum.

HÄNDLER auch erlaubt eine nicht-blockierende Verbindung mit REP.

Einige Verbindungs-code übergibt einen Antrag in einem Briefumschlag an die HÄNDLER. Der Händler verwaltet die Verteilung von solchen Anforderungen werden Arbeitnehmer (ohne Umschlag), und später antwortet der Verbindungstür code (wieder in einem Umschlag).

Verbindungstür code

Eine Verbindungstür code-mischen von Nachrichten zwischen ROUTER und HÄNDLER sockets.

Die einfachste version ist hier: http://zguide.zeromq.org/py:rrbroker

# Simple request-reply broker
#
# Author: Lev Givon <lev(at)columbia(dot)edu>

import zmq

# Prepare our context and sockets
context = zmq.Context()
frontend = context.socket(zmq.ROUTER)
backend = context.socket(zmq.DEALER)
frontend.bind("tcp://*:5559")
backend.bind("tcp://*:5560")

# Initialize poll set
poller = zmq.Poller()
poller.register(frontend, zmq.POLLIN)
poller.register(backend, zmq.POLLIN)

# Switch messages between sockets
while True:
  socks = dict(poller.poll())

  if socks.get(frontend) == zmq.POLLIN:
    message = frontend.recv_multipart()
    backend.send_multipart(message)

  if socks.get(backend) == zmq.POLLIN:
    message = backend.recv_multipart()
    frontend.send_multipart(message)