[zeromq-dev] Distributed application with REQ REPLY sockets

Justin Azoff justin.azoff at gmail.com
Mon Aug 13 19:01:48 CEST 2018


On Mon, Aug 13, 2018 at 12:23 PM Patrick <preedy73 at gmail.com> wrote:
>
> It’s a 10Gbit network.
>
> Each of the 50 interfaces (one per node) is sending 150Mbytes while it is receiving 150Mbytes of data.

Ah, I think I see what you are doing now.. you sort of have a mini
bittorrent type of file distribution going on.

When each node sends its data to the 100 destinations, are you doing this:

sockets = [list of 100 req sockets]

for s in sockets:
    s.send(piece)
    ok = s.recv()

or this:

for s in sockets:
    s.send(piece)
for s in sockets:
    ok = s.recv()

The 2nd method would perform a lot better.

-- 
- Justin


More information about the zeromq-dev mailing list