[zeromq-dev] Distributed application with REQ REPLY sockets

Patrick preedy73 at gmail.com
Mon Aug 13 20:50:03 CEST 2018


Since I’m using the REQ REPLY sockets it is behaving like the first method - both send and recv within one loop. 

How can I use zmq to achieve the behavior in the 2nd method? I’m assuming it can’t be done using the REQ REPLY sockets I have in place. 

>> On Aug 13, 2018, at 1:01 PM, Justin Azoff <justin.azoff at gmail.com> wrote:
>> 
>> 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
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> https://lists.zeromq.org/mailman/listinfo/zeromq-dev


More information about the zeromq-dev mailing list