我刚接触zeromq,对套接字没有太多经验。
ZeroMQ套接字是否应该只允许一个套接字绑定()到一个端口?
jeromq实现允许多个;pyzmq不允许。谁是对的?
jeromq ZMQ.Socket.bind()函数最终归结为:
https://github.com/zeromq/jeromq/blob/master/src/main/java/zmq/TcpListener.java#L141
// Set address to listen on.
public int set_address(final String addr_) {
address.resolve(addr_, options.ipv4only > 0 ? true : false);
try {
handle = ServerSocketChannel.open();
handle.configureBlocking(false);
handle.socket().setReuseAddress(true);
handle.socket().bind(address.address(), options.backlog);
if (address.getPort()==0)
address.updatePort(handle.socket().getLocalPort());
} catch (IOException e) {
close ();
return ZError.EADDRINUSE;
}
endpoint = address.toString();
socket.event_listening(endpoint, handle);
return 0;
}Python:
C:\tmp\jeromq\jeromq-0.3.2\target>python
Python 2.7.5 |Anaconda 1.9.1 (64-bit)| (default, May 31 2013, 10:45:37) [MSC v.1
500 64 bit (AMD64)] on win32
Type "help", "copyright", "credits" or "license" for more information.
>>> import zmq
>>> ctx=zmq.Context()
>>> s=ctx.socket(zmq.PUB)
>>> s.bind_to_random_port('tcp://127.0.0.1')
56356
>>> s2=ctx.socket(zmq.PUB)
>>> s2.bind('tcp://127.0.0.1:56356')
Traceback (most recent call last):
File "<stdin>", line 1, in <module>
File "socket.pyx", line 465, in zmq.core.socket.Socket.bind (zmq\core\socket.c
:4749)
zmq.core.error.ZMQError: Address in use发布于 2014-03-11 06:44:43
jeromq实现允许多个
在TCP上设置reuse-address只是修复了一个常见的开发问题,即当存在到应用程序的前一个实例的连接仍然处于TIME_WAIT状态时,侦听socket无法被绑定。它不允许端口的两个实例处于侦听状态。
https://stackoverflow.com/questions/22312101
复制相似问题