Reactor TcpServer 丢弃传入连接

Question

deny/drop 到 Reactor TcpServer 的传入连接的正确方法是什么？

我目前有：

TcpServer.create()
  .doOnConnection {
     if (notAllowed(it.address()) {
        throw IllegalStateException("Connection from ${it.address()} denied")
     }
  }
  .handle(...)
  .bindNow()

它似乎在工作，它成功地断开了来自我的 notAllowed 列表中的远程地址的连接。但是每次它都会将堆栈跟踪打印到控制台，并且通常看起来不太好。

拒绝某些与 TcpServer 的连接的正确方法是什么？

Answer 1

我建议你不要抛出 IllegalStateException，只需调用 Connection#dispose

TcpServer.create()
         .doOnConnection {
             if (notAllowed(it.address()) {
                 it.dispose()
             }
         }
         .handle(...)
         .bindNow()

Reactor TcpServer 丢弃传入连接

Reactor TcpServer drop incoming connection

java

spring

project-reactor

reactor-netty