Как настроить рукопожатие веб-сокета и / или добавить фильтр?

Мне нужно как-то проверять запросы веб-сокетов.

Есть ли способ добиться этого с помощью spring webflux с реактором-netty?

  • Spring-boot 2.0.5. Выпуск
  • Реактор-netty 0.7.9. Выпуск

person smoomrik    schedule 17.09.2018    source источник


Ответы (1)


Эти версии содержат ограниченные возможности для настройки чего-либо с помощью websocket. Единственный способ, который я нашел, - это расширить HandshakeWebSoketService:

public class CustomHandshakeWebSocketService extends HandshakeWebSocketService {

  public CustomHandshakeWebSocketService(
      RequestUpgradeStrategy upgradeStrategy
  ) {
    super(upgradeStrategy);
  }

  @Override
  public Mono<Void> handleRequest(
      ServerWebExchange exchange,
      WebSocketHandler handler
  ) {
    ServerHttpRequest request = exchange.getRequest();
    if ( //do some validation and if valid delegate to chain) {

      return super.handleRequest(exchange, handler);
    }
    // If not valid, return error
    return Mono
        .error(new ResponseStatusException(HttpStatus.BAD_REQUEST, "Invalid request"));
  }
}

Затем мы должны зарегистрировать эту настраиваемую службу:

@Bean
public WebSocketHandlerAdapter handlerAdapter() {
  return new WebSocketHandlerAdapter(webSocketService());
}

@Bean
public WebSocketService webSocketService() {
 ReactorNettyRequestUpgradeStrategy strategy = new ReactorNettyRequestUpgradeStrategy();
    return new CustomHandshakeWebSocketService(strategy);
}
person smoomrik    schedule 25.09.2018