java - 为什么 jeromq 使用 setReuseAddress(true) ?

标签 java sockets zeromq jeromq

我是 Zeromq 的新手,对套接字没有那么丰富的经验。

ZeroMQ 套接字是否应该只允许一个套接字将 (bind()) 到一个端口?

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

最佳答案

The jeromq implementation allows more than one

不,没有。在 TCP 套接字上设置重用地址只能解决常见的开发问题,即当与应用程序的先前实例的连接仍处于 TIME_WAIT 状态时,无法绑定(bind)监听套接字。它不允许端口的两个实例处于 LISTEN 状态。

关于java - 为什么 jeromq 使用 setReuseAddress(true) ?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/22312101/

相关文章:

java - 如何将 Map<String,String> 编码为 Base64 字符串?

java - 为什么 StandardOpenOption.CREATE_NEW 不创建要在 Java 中读取的文件?

sockets - ZMQ套接字-满足所有请求时断开连接

c++ - 在 Linux 上链接 Zeromq 库的 Makefile 问题

python - 如何在 ZMQ 中使用序列化发送图像和数据字符串?

java - 我的 psvm 类不运行其他类和方法

java - 将 Java 应用程序(Azure 函数应用程序)从 GRADLE 2.x 迁移到运行时 3.x

c# - TCP 发送简单的洪水控制和同步 - P2P 网络摄像头

linux - 像 select() 或 poll() 这样的系统调用在幕后是如何工作的?

php - websocket报错413,如何处理?