我想通过udp客户端发送大量udp消息，我该如何实现？

Question

我想一次通过udp客户端发送许多udp消息，但是演示只发送一个message.how我能实现吗？

使用演示代码，我只能发送有限数量的消息。我想用while（true）来发送消息，我该如何实现呢？

public static void main（String[]args）{Connection Connection=UdpClient.create（）.host（“localhost”）.port（8080）.handle（（udpInbound，udpOutbound）-

Answer 1

当您想发送多个消息时，您可以使用Flux而不是Mono。与许多sendString（Mono）调用的方法相比，一个sendString（Flux）调用更好。下面的示例使用Flux.interval，这样您就有了每100ms发出消息的无限流。此外，当您有一个无限流时，您必须切换到刷新每个策略

Connection connection =
        UdpClient.create()
                 .host("localhost")
                 .port(8080)
                 .handle((udpInbound, udpOutbound) ->
                         udpOutbound.options(NettyPipeline.SendOptions::flushOnEach)
                                    .sendString(Flux.interval(Duration.ofMillis(100))
                                                    .map(l -> l + "")))
                 .connectNow(Duration.ofSeconds(30));