zeromq

0열

1답변

nn_send를 실행 한 후 nn_socket은 Req/Rep 모드에서 다음 데이터 조각을 즉시 전송하지 못하도록합니다.

Windows에서 CentOS로 데이터 조각을 전송하기 위해 nanomsg를 사용하고 있습니다. 현재로서는 Req/Rep 모드를 사용하고 있습니다. CentOS는 Req 요청을 보내고 "Windows"는 Rep으로 응답합니다. 괜찮아 보인다. 하지만 응답 한 데이터 조각에는 여러 가지 구조체가 혼합되어 있습니다. 여러 데이터 프레임을 따르는 데이터 헤드.

0열

1답변

zmq round robin lost message PUSH/PULL

하나의 클라이언트에서 두 명의 작업자에게 10 개의 메시지를 보내려고합니다. PUSH/PULL 패턴을 사용합니다. python pull.py Received message n°1 Received message n°4 Received message n°7 노동자 2 : 나는 2 python push.py message n°0 message n°1

0열

1답변

이상한 오류를주는 zmq로 뒤틀림

나는 zmq로 뒤틀린 것을 사용하고 있습니다. 여기 응용 프로그램의 개요입니다 : 두 개의 트위스트 인스턴스가 두 시스템에서 실행하고 나는 메시지 전달을 위해 zmq(txZmq)을 사용하고 있습니다. systemA은 처리 할 작업을 systemB으로 제출하고 작업이 완료되면 systemA (일부 imp 이유로)에 통지해야합니다. 그래서 두 시스템에서 나는

2열

2답변

ZeroMQ REQ/REP가 여러 클라이언트를 어떻게 처리합니까?

필자는 IPC 용 ZeroMQ를 사용하기 시작했고 간단한 에코 클라이언트/서버를 만들었고 나는 한 가지 사실에 놀랐다. 다음은 C++ 코드입니다 (zmq.hpp 및 zmq_addon.hpp 사용). 서버 : zmq::context_t context(1); zmq::socket_t socket(context, ZMQ_REP); socket.bind("ip

1열

1답변

IPC는 Linux에서 메시지 순서를 보장합니까?

ZeroMQ ipc를 사용하여 패킷 누락에 대한 정보를 기록하는 모니터를 만들어야합니다. 실제로 LINX, TIPS 프로토콜이 있기 때문에 모든 것을 이해하지 못합니다. 당신은 저를 설명하고 주 질문에 답할 수 있습니까?

2열

1답변

ZeroMQ req-rep가 C++과 Python 사이에 빈 응답을 제공하는 이유는 무엇입니까?

저는 파이썬 클라이언트와 C++ 기반 서버 사이에서 ZeroMQ를 사용하여 브리지를 시도하고 있지만 정확한 응답을 서버에서 클라이언트로 반환하는 데 어려움을 겪고 있습니다. 파이썬 클라이언트는 다음과 같습니다는 C++ 서버는 다음과 같습니다 import zmq import time # Socket to talk to server context = z

0열

2답변

ZMQ PULL 소켓에서 데이터를 가져옵니다. 계산을 동기화하는 방법?

나는 여러 작업자에게 PULL/PUSH를 사용하여 데이터를 보내는 생산자가 있습니다. 모든 작업자는 계산 작업을 수행하기 전에 모든 데이터를 수신해야합니다. 나는 ... A는 "이동"그러나 PUSH 소켓으로, 이동은 데이터 스트림이 끝나기 전에 수신 비 차단하고 보내는 PUB/SUB 소켓을 사용 보낸 사람을 동기화를 시도 : context = zmq.Con

0열

1답변

ZeroMQ는 : 많은에 게시받을 replys을 나는 ZeroMQ 패턴에 대해 배우고 어떤 순서

에, 나는 다음과 같은 구현해야합니다 NodeJS가 많은 파이썬 스레드에게 메시지를 보낼 것이다, 그러나 '아무튼 동 기적으로 응답을 기다릴 필요가 없습니다. 은 임의의 순서로 올 수 있습니다.. 나는 publish/subscribe 패턴이 그것을 한 가지 방법으로 해결한다는 것을 안다 : 그것은 많은 사람들에게 보낼 수 있지만 파이썬 노동자는 어떻게 대답

3열

1답변

C++ ZeroMQ 가입자가 데이터를받지 못하는 이유는 무엇입니까?

내 (파이썬) 발행인 : (GTest에서 실행) import zmq import time context = zmq.Context() socket = context.socket(zmq.PUB) connectStr = "tcp://*:%d" % 5563 socket.bind(connectStr) messageNum = 0 while True:

2열

1답변

각 프레임/메시지에 새로운 바이트 배열을 생성하지 않도록 사용자 정의 버퍼에서 수신하는 NetMQ API는 무엇입니까?

나는 다음과 같은 코드가 있습니다 byte[] frameBytes = new byte[123]; while (!isCancellationRequested) { socket.ReceiveFrameBytes(frameBytes); MyData data = new MyData(); data.Deserialize(frameBytes)