ZeroMQ Broker中Dealer Socket的IP访问限制及来源IP获取问题

核心问题说明 #

JeroMQ的Dealer Socket默认触发的ZMQ_EVENT_ACCEPTED事件返回的是本地绑定地址，而非发起连接的远端IP，这是导致你无法直接获取连接来源的原因。

具体实现方案 #

1. 结合事件与系统API获取远端IP #

当监听到连接建立事件时，通过事件携带的文件描述符（fd），借助Java的底层套接字操作获取远端IP，代码示例如下：

// 事件监听线程逻辑
@Override
public void run() {
    ZMQ.Socket dealerSocket = ...; // 你的Dealer Socket实例
    ZMQ.Poller poller = ZMQ.context().poller(1);
    poller.register(dealerSocket, ZMQ.Poller.POLLIN);
    
    while (!Thread.currentThread().isInterrupted()) {
        if (poller.poll(1000) > 0) {
            ZMQ.Event event = ZMQ.Event.recv(dealerSocket);
            if (event.getEvent() == ZMQ.EVENT_ACCEPTED) {
                int fd = event.getFd();
                try {
                    // 通过反射关联文件描述符到SocketChannel
                    FileDescriptor fdObj = new FileDescriptor();
                    Field fdField = FileDescriptor.class.getDeclaredField("fd");
                    fdField.setAccessible(true);
                    fdField.set(fdObj, fd);

                    SocketChannel channel = SocketChannel.open();
                    channel.socket().setFileDescriptor(fdObj);
                    InetSocketAddress remoteAddr = (InetSocketAddress) channel.socket().getRemoteSocketAddress();
                    String remoteIp = remoteAddr.getAddress().getHostAddress();
                    System.out.println("连接来源IP: " + remoteIp);

                    // 执行IP范围校验，不符合则关闭连接
                    if (!isIpAllowed(remoteIp)) {
                        channel.close();
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

// 自定义IP校验方法
private boolean isIpAllowed(String ip) {
    // 示例：仅允许192.168.1.x段的IP
    return ip.startsWith("192.168.1.");
}

2. 替代方案：改用Router Socket连接服务端 #

如果Dealer的IP限制实现难度高，可以将连接服务端的Socket替换为Router。Router Socket会在消息中携带远端身份标识，且能更直接地获取连接的远端IP，但需要同步调整服务端的通信逻辑以适配Router的交互模式。

注意事项 #

• 反射操作FileDescriptor属于平台相关逻辑，Windows系统可能需要调整实现方式，或借助junixsocket等跨平台库处理。
• 关闭非法连接时需确保Socket资源正确释放，避免内存泄漏。
• 不同版本的JeroMQ事件API可能存在差异，建议核对当前使用版本的官方文档。

内容的提问来源于stack exchange，提问作者Y34x4t3