Can a ZeroMQ ROUTER socket make a spontaneous asynchronous request to a specific DEALER socket?
I'm reading the ZeroMQ Guide and came across the following passage in regards to the ROUTER socket and identities:
An application that uses a
ROUTERsocket to talk to specific peers can convert a logical address to an identity if it has built the necessary hash table. BecauseROUTERsockets only announce the identity of a connection (to a specific peer) when that peer sends a message, you can only really reply to a message, not spontaneously talk to a peer.This is true even if you flip the rules and make the
ROUTERconnect to the peer rather than wait for the peer to connect to theROUTER. However you can force theROUTERsocket to use a logical address in place of its identity. Thezmq_setsockoptreference page calls this setting the socket identity.
According to this passage, "you can only really reply to a message, not spontaneously talk to a peer", meaning a ROUTER can't send a message to a specific DEALER, but the next sentence implied that you can if you force the router socket to use a logical address: "However you can force the ROUTER socket to use a logical address in place of its identity". This part confuses me because they just said that you cant spontaneously send messages from a router to a dealer, but now they claim you can. If you follow this link to the guide, you'll see that after this passage, they say "It works as follows", but the steps they give don't seem to clear up how to send a spontaneous message from a ROUTER to a specific DEALER and return a response back to the original ROUTER.
My question: Is it possible for a single ROUTER socket to send a request to a specific DEALER (Out of many) socket and the DEALER send the result of the request back to the ROUTER? And if it is possible, how can this be done?
Follow up question: If this is not possible, is there a better combination of sockets to approach this?
Below is a crude diagram of my intended design:
Basically, the client send a request to 1 specific server, that server processes the request and returns the result of the request to the client. The client now has that result, and it knows what server it was processed on.
Is it possible for a single
ROUTERsocket to send a request to a specificDEALER(Out of many) socket and theDEALERsend the result of the request back to theROUTER? And if it is possible, how can this be done?
No, this is to the best of my knowledge not possible - it tries a DEALER/ROUTER anti-pattern.
is there a better combination of sockets to approach this?
Yes, this could be possible in a bit wild approach to manually-driven identity-frames in ROUTER/ROUTER.
While one can tweak the ROUTER-side with identity tricks, your problem fails at the DEALER-side, where a fair-queue and round-robin policies destroy your wished-to-have 1:1-relation and the pairing of the JobREQ:ResultREP will fail.
A bit more global view into how these toys work inside :
ZeroMQ archetypes are smart and multi-layered inside, beyond of what you typically work with when calling any of the API methods. Some insight into (simplified, maybe oversimplified) inner work might help in this :
+------------------------------+
| Formal Behavioural Archetype |
| |
| ROUTER |
+------------------------------+
| BEHAVIOUR Management |
+------------------------------+ | |
| Formal Behavioural Archetype | | HWM'd messages Dropped(*)| *unless ZMQ_ROUTER_MANDATORY set
| | | |
| DEALER | | |
+------------------------------+ <===.recv() served in FAIR-QUEUED mode|
| BEHAVIOUR Management | .send()===> served by identityFRAME id|
| on | +------------------------------+
| no peers | | IDENTITY Based Routing Policy| +may preset ZMQ_CONNECT_ROUTING_ID for one next .connect() transport-setup call (ref. API for details)
| or | | <--prepend peer-Id on.recv()| +see setting ZMQ_ROUTING_ID and ZMQ_ROUTING_HANDOVER (ref. API for details)
| all HWM'd in MUTE-STATE !Drop| | -->remove peer-Id on.send()|
.send()===> served in ROUND-ROBIN mode| | +Drop if peer not visible | *unless ZMQ_ROUTER_MANDATORY set
<===.recv() served in FAIR-QUEUED mode| +------------------------------+
+------------------------------+ | QUEUE Management Department |
| QUEUE Management Department :| | |
| ::| | |hwm|
| :::| | | | |...|
|hwm| | | |hwm| | | | |.. |
|...| |hwm| |...| | | |hwm|. |
|.. | |...|hwm|.. | |hwm| |...| |
|. | |.. |...|. | +-:-|------------------|-:-|-:-|
+-:-|--------------|-:-|-:-|:::+ | TRANSPORT Handling Department|
| TRANSPORT Handling Department| |---+ +-------|
|-------+ +-----------| |tcp| | ipc |
| inproc| | ipc | |-:-| |-:---:-|
|-:-----| |-:---:--:::| |.C | |.C |.C |
|.C | | |.C |.C |.B | +-o-|------------------+-o---o-+
+-o-|---+----------+-o---o---O-+ | | |
| | | ^ | | |
| | | | | | +----------------------.connect()->------- ... may be a { ROUTER | DEALER | REQ }-socket
| | | | +----------------------|--------------------------.connect()->------- ..
| | | +-<--.connect()---[ROUTER].02----<--------------------------+
| | | +-<--.connect()---[ROUTER].07--- .....
| | | +-<--.connect()------[REP].41--- ....
| | +--------.connect()->----[REP].18--- ...
| +------------.connect()->-[ROUTER].51--- ..
+-------------------------------.connect()->----[REP].17--- . (+ REP.send() message <=== sent must consist of an empty message part, the delimiter, followed by one or more body parts. )
- ESP8266 is stuck in an infinite socket.accept() loop, i guess?
- Why is this socket null?
- Unable to receive vídeo Stream from tello drone
- Php send 65 Ascii char to socket
- TCP proxy with reading payload
- How can I know what l am reading with Java Sockets?
- How to get local ip address python?
- SO_REUSEADDR option not working when application is trying to bind a port
- Why is INET6_ADDRSTRLEN defined as 46 in C?
- Linux: is there a read or recv from socket with timeout?
- How to pass data from BroadcastReceiver to Activity without in onCreate()
- Read the whole file and send it via sockets
- Why can I successfully connect to a netcat server from the adb shell and not from the Android app?
- How to pass WS connection socket from parent process to child process
- Only part of CSS works when parsed through a socket
- Is there a way to send location of pytorch tensor in gpu memory between docker containers and build them in different containers
- stack smashing detected on function return
- Sending binary data by socket between C# and Js
- Tell whether a text string is an IPv6 address or IPv4 address using standard C sockets API
- How to implement an easy secure socket connection
- How to put Java program online?
- Pass Uint8List from dart to java over a TCPSocket
- Sockets & receiving broadcasts not working when in a MAUI App
- Zombie SSE connections not reported in Chrome Dev Tools
- How to build a raw UDP packet in C++?
- Passing a socket to a function and modifying it, or creating a socket inside the function and returning it
- Why doesn't error occur in UDP socket communication?
- java.net.SocketException: Unexpected end of file from server using Spring's RestTemplate
- Python Raw Socket to Ethernet Interface (Windows)
- Web Socket: IIS WebSocket Protocol feature need to be enabled for Socket.io?