如何解决有关UdpServer和ConnectableFlux的建议
这就是我想使用Reactor-Netty UdpServer完成的事情。
- 在所有接口上侦听传入的UDP的IPv4和IPv4 包
- 一旦收到传入数据包,请将其发送给ConnectableFlux的所有订户
我正在工作#1,正在接收数据包。我只是不知道如何构建一个可接收数据包并通知用户的ConnectableFlux。
我想在我的“服务器”类上使用一个外部方法,该方法具有类似setvbuf
这是我正在使用的服务器代码。我认为我需要在int
方法中进行逻辑操作。.但是我不是很肯定。
谢谢..
getPacketStream().subscribe(packet -> "DO SOMETHING WITH PACKET")
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。