Не могу получить привязки Python ZeroMQ для получения сообщений через IPC

Я пытаюсь установить PUB / SUB через IPC. Если я изменил приведенный ниже код так, что подписчик привязывается к «tcp: // *: 5000», а издатель подключается к «tcp: // localhost: 5000», он работает, но я не могу заставить его работать через IPC. Что я делаю не так?

subscriber.py

import zmq, json

def main():
    context = zmq.Context()
    subscriber = context.socket(zmq.SUB)
    subscriber.bind("ipc://test")
    subscriber.setsockopt(zmq.SUBSCRIBE, '')
    while True:
        print subscriber.recv()

if __name__ == "__main__":
    main()

publisher.py

import zmq, json, time

def main():
    context = zmq.Context()
    publisher = context.socket(zmq.PUB)
    publisher.connect("ipc://test")
    while True:
        publisher.send( "hello world" )
        time.sleep( 1 )

if __name__ == "__main__":
    main()
21
задан Kit Sunde 20 February 2011 в 22:25
поделиться