PyZMQ:拒绝许可

Question

代码：

import zmq
from multiprocessing import Process
import time

def server():
    port = '5556'
    context = zmq.Context()
    socket = context.socket(zmq.PAIR)
    socket.bind('tcp://*:%s' % port)

    for i in range(10):
        socket.send('server to client')
        msg = socket.recv()
        print msg
        time.sleep(1)

def client():
    port = '5556'
    context = zmq.Context()
    socket = context.socket(zmq.PAIR)
    socket.bind('tcp://127.0.0.1:%s' % port)

    for i in range(10):
        msg = socket.recv()
        print msg
        socket.send('msg to server')
        time.sleep(1)

if __name__ == '__main__':
    Process(target=server, args=()).start()
    Process(target=client, args=()).start() 

错误：

Process Process-2:
Traceback (most recent call last):
File "C:\Python27\lib\multiprocessing\process.py", line 258, in _bootstrap
self.run()
File "C:\Python27\lib\multiprocessing\process.py", line 114, in run
self._target(*self._args, **self._kwargs)
File "C:\...\zmqtest.py", line 21, in client
socket.bind('tcp://127.0.0.1:%s' % port)
File "socket.pyx", line 444, in zmq.backend.cython.socket.Socket.bind (zmq\backend\cython\socket.c:4076)
File "checkrc.pxd", line 21, in zmq.backend.cython.checkrc._check_rc (zmq\backend\cython\socket.c:6032)
ZMQError: Permission denied

它能为服务器启动进程1吗？为什么有不同的许可？

尝试学习ZMQ，但无法获得它们的任何简单示例来运行这一点。有什么地方可以打开ZMQ的权限吗？找不到关于这件事的文件

Answer 1

您只能在一侧(服务器)上使用.bind。在客户机上，您必须使用.connect，尽管我得到的是“已在使用的地址”错误，而不是拒绝权限。

尝试更改它，以便客户端连接并查看它是否适合您：

import zmq
from multiprocessing import Process
import time

def server():
    port = '5556'
    context = zmq.Context()
    socket = context.socket(zmq.PAIR)
    socket.bind('tcp://*:%s' % port)

    for i in range(10):
        socket.send('server to client')
        msg = socket.recv()
        print msg
        time.sleep(1)

def client():
    port = '5556'
    context = zmq.Context()
    socket = context.socket(zmq.PAIR)
    socket.connect('tcp://127.0.0.1:%s' % port)

    for i in range(10):
        msg = socket.recv()
        print msg
        socket.send('msg to server')
        time.sleep(1)

if __name__ == '__main__':
    Process(target=server, args=()).start()
    Process(target=client, args=()).start()