Reactor TcpServer 丢弃传入连接

Question

拒绝/丢弃与 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()