ZeroMQ знает, какой из подпрограмм запрашивается от

Question

Я пытаюсь выяснить, есть ли у меня две подпрограммы, вызывающие один и тот же сокет zeromq, если при возврате из socket.recv() в процедуре 1 возвращается. Сокет будет знать, чтобы вернуться в подпрограмма1 (то же самое для рутинных2, ... рутин).

Следовательно ... используя шину обмена сообщениями с семантикой запроса/ответа, каков наилучший образец для подхода к этому в go?

Если это помогает ... подумать о простой схеме пирата и реализовать вызов стиля RPC, установленный в этом шаблоне с помощью zeromq.

Socket; //zeromq socket 
//routine 1 
socket.send(data) // do i need some identifier here for this routine? 
socket.recv() // wait until i get a response from that send 
//routine 2 
socket.send(data) 
socket.recv() 

так что в этом случае я понятия не имею, будет ли возвращаться ответ от обычной1 или обычной2. Как я могу убедиться, что когда я получаю ответ на сокет ... я могу сообщить о правильной функции recv() функции.

Спасибо!

Answer 1

Я не верю, что сокет может быть разделен, одновременно, между потоками с использованием ZeroMQ

Вероятно, что вам нужно сделать какой-то goroutine, что прослушивает запросы, отправляет/получает zmq, а затем отвечает.

, например: (непроверенный код)

type Req struct { 
    Data []byte 
    Reply chan []byte 
} 

go func() { // probably not the zmq api, but you should get the idea here 
    for req := <- requests { 
     socket.send(req.Data) 
     req.Reply <- socket.recv() 
    } 
}