如何使用IBM BlueSocket在多网络接口监听SSDP响应

要让SSDP发现覆盖所有子网，核心是遍历所有活跃网络接口，并在每个接口上独立发送SSDP搜索请求、监听组播响应。以下是具体实现步骤和代码：

1. 获取所有活跃的IPv4网络接口 #

首先枚举系统中所有处于UP状态、非回环的IPv4接口，获取它们的IP地址。通过BSD的getifaddrs API实现：

import Foundation
import BlueSocket

func getActiveIPv4Interfaces() -> [String] {
    var interfaces = [String]()
    var ifaddr: UnsafeMutablePointer<ifaddrs>?
    
    guard getifaddrs(&ifaddr) == 0 else { return interfaces }
    defer { freeifaddrs(ifaddr) }
    
    var ptr = ifaddr
    while ptr != nil {
        let flags = Int32(ptr!.pointee.ifa_flags)
        // 过滤：UP状态、非回环、IPv4地址
        if (flags & IFF_UP) != 0 && (flags & IFF_LOOPBACK) == 0 {
            let family = ptr!.pointee.ifa_addr.pointee.sa_family
            if family == UInt8(AF_INET) {
                var addr = ptr!.pointee.ifa_addr.pointee.withMemoryRebound(to: sockaddr_in.self, capacity: 1) { $0.pointee }
                var ipBuffer = [CChar](repeating: 0, count: Int(INET_ADDRSTRLEN))
                inet_ntop(AF_INET, &addr.sin_addr, &ipBuffer, socklen_t(INET_ADDRSTRLEN))
                if let ip = String(validatingUTF8: ipBuffer) {
                    interfaces.append(ip)
                }
            }
        }
        ptr = ptr!.pointee.ifa_next
    }
    return interfaces
}

2. 针对每个接口发起SSDP搜索 #

SSDP的M-SEARCH请求需要从每个接口的IP发送，同时绑定到该接口监听响应。BlueSocket的Socket类支持绑定到指定IP，为每个接口创建独立的Socket实例：

func discoverNASOnAllInterfaces() {
    let ssdpMulticastIP = "239.255.255.250"
    let ssdpPort = 1900
    let mSearchRequest = """
    M-SEARCH * HTTP/1.1
    HOST: \(ssdpMulticastIP):\(ssdpPort)
    MAN: "ssdp:discover"
    MX: 3
    ST: urn:schemas-upnp-org:device:NAS:1
    
    """
    
    let interfaces = getActiveIPv4Interfaces()
    let queue = DispatchQueue(label: "SSDPDiscovery", attributes: .concurrent)
    
    for interfaceIP in interfaces {
        queue.async {
            do {
                // 创建UDP Socket
                let socket = try Socket.create(family: .inet, type: .datagram, proto: .udp)
                defer { socket.close() }
                
                // 绑定到当前接口的IP和随机端口（用于接收响应）
                try socket.bind(to: interfaceIP, port: 0)
                // 允许地址复用，避免端口占用问题
                try socket.setOption(Socket.SocketOptionLevel.socket, name: .reuseAddress, value: 1)
                try socket.setOption(Socket.SocketOptionLevel.socket, name: .reusePort, value: 1)
                
                // 设置超时，避免无限等待
                try socket.readTimeout = 5.0
                
                // 发送M-SEARCH请求到组播地址
                let data = mSearchRequest.data(using: .utf8)!
                try socket.write(from: data, to: Socket.createAddress(for: ssdpMulticastIP, port: ssdpPort)!)
                
                // 监听响应
                var buffer = Data(capacity: 4096)
                repeat {
                    let bytesRead = try socket.read(into: &buffer)
                    if bytesRead > 0 {
                        if let response = String(data: buffer, encoding: .utf8) {
                            print("Received from interface \(interfaceIP):\n\(response)")
                            // 此处可解析响应中的NAS设备信息
                        }
                        buffer.removeAll()
                    }
                } while true
            } catch {
                // 超时或其他错误，结束当前接口的监听
                print("Interface \(interfaceIP) discovery error: \(error)")
            }
        }
    }
}

关键说明 #

• 绑定到指定接口：通过socket.bind(to: interfaceIP, port: 0)强制Socket使用当前接口的IP发送和接收数据，避免系统自动选择默认接口。
• 组播发送：SSDP的M-SEARCH请求发送到固定组播地址239.255.255.250:1900，每个接口发送一次，确保子网内的NAS能收到请求。
• 并发处理：用并发队列处理多个接口的发现任务，避免阻塞主线程。
• 超时设置：给Socket设置readTimeout，防止单个接口的监听无限阻塞。

额外优化 #

• 如果需要处理IPv6接口，只需修改getActiveIPv4Interfaces函数，添加AF_INET6的过滤逻辑。
• 可以统一收集所有接口的响应，去重后返回给上层调用。

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