Как использовать транспорты inproc и ipc Zeromq? ⇐ Python

[Anonymous]

Я новичок в ZERMQ. ZeroMQ имеет транспорты TCP, INPROC и IPC. Я ищу примеры использования Python и inproc в Winx64 и Python 2.7, которые также можно использовать для Linux.

Кроме того, я искал методы транспортировки UDP и не нашел примеров.

Единственный пример, который я нашел, это

import zmq
import zhelpers

context = zmq.Context()

sink = context.socket(zmq.ROUTER)
sink.bind("inproc://example")

# First allow 0MQ to set the identity
anonymous = context.socket(zmq.XREQ)
anonymous.connect("inproc://example")
anonymous.send("XREP uses a generated UUID")
zhelpers.dump(sink)

# Then set the identity ourself
identified = context.socket(zmq.XREQ)
identified.setsockopt(zmq.IDENTITY, "Hello")
identified.connect("inproc://example")
identified.send("XREP socket uses REQ's socket identity")
zhelpers.dump(sink)


Я имею в виду вариант использования: UDP как распространение информации. Тестирование Push/Pull с использованием TCP выполняется быстрее или будет быстрее.

Вот тестовый пример>..............

Сервер:

import zmq
import time

context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("inproc://example2")

while True:
# Wait for next request from client
message = socket.recv()
print "Received request: ", message

# Do some 'work'
time.sleep (1) # Do some 'work'

# Send reply back to client
socket.send("World")


Клиент:

import zmq

context = zmq.Context()

# Socket to talk to server
print "Connecting to hello world server..."
socket = context.socket(zmq.REQ)
socket.connect ("inproc://example2")

# Do 10 requests, waiting each time for a response
for request in range (1,10):
print "Sending request ", request,"..."
socket.send ("Hello")

# Get the reply.
message = socket.recv()
print "Received reply ", request, "[", message, "]"


Сообщение об ошибке:

socket.connect ("inproc://example2")
File "socket.pyx", line 547, in zmq.core.socket.Socket.connect (zmq\core\socket.c:5347)
zmq.core.error.ZMQError: Connection refused


Подробнее здесь: https://stackoverflow.com/questions/849 ... transports