对于感兴趣的人来说，这是一个碎片.我可以在Flux Launcher上实现，而不是在reactor-netty UDP类上实现.
私有身份验证ssdp _ IP=' 239.255.255.250 '；
私有staticfinalintssdp _ port=1900；
私有身份识别时间表=5000；
字符串请求=new string (example )；
byte [ ] receivedata=new byte [ 1024 ]；
request.getBytes ().length，inetaddress.getbyname )、SSDP_PORT )；
flux响应=flux.create (emitter-{
try (数据分组套接字=newdatagramsocket () ) )。
socket.setsotimeout；
socket.send (发送包；
while (真)。
socket.receive(receivepacket )；
emitter.next (接收包. get data (；
}
} catch (套接字时间表操作单元) )。
emitter.complete (；
}catch(ioexceptione ) {
Emitter.error(e；
}
() )
. map (映射器-新字符串(接收包. get data (，0，接收包. getlength ) ) )