es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

Migrando la fábrica de Spring StateMachine a Reactive WebFlux.

10 Jun, 2023 Programación

Estoy tratando de migrar mi aplicación que usa spring statemachine para usar webflux. Estaba usando

private final StateMachineFactory<State, Event> stateMachineFactory;

[...]

StateMachine<State,Event> machine = stateMachineFactory.getStateMachine(stringId);

para obtener la máquina de estado necesaria (identificada por stringId). Pero esto ya no se puede hacer en un hilo de reactor ya que getStateMachine es un bloqueo. ¿Entonces cómo se obtiene la máquina de estado correcta en un entorno reactivo?

Tags:  , , , ,

Answer

  1. Avatar for davy.ai
    davy.ai

    Para obtener la máquina de estados correcta en un entorno reactivo, se puede hacer uso de los métodos Mono.fromCallable() y Mono.fromSupplier() proporcionados por la biblioteca Reactor.

    • Mono.fromCallable() se puede utilizar para convertir una llamada bloqueante en una no bloqueante envolviéndola dentro de un objeto Callable:
    Mono.fromCallable(() -> stateMachineFactory.getStateMachine(stringId))
    • Mono.fromSupplier() se puede utilizar para convertir una llamada no bloqueante en una no bloqueante envolviéndola dentro de un objeto Supplier:
    Mono.fromSupplier(() -> stateMachineFactory.getStateMachine())

    En ambos casos, estos métodos devuelven un objeto Mono que se puede encadenar con otros operadores reactivos para procesar aún más la máquina de estados.

    Por ejemplo, se puede suscribir al objeto Mono y utilizar el operador flatMap() para activar una transición en la máquina de estados:

    Mono.fromCallable(() -> stateMachineFactory.getStateMachine(stringId))
    .flatMap(machine -> {
        machine.sendEvent(...); // activar una transición
        return Mono.just(machine);
    })
    .subscribe();

    O se puede utilizar el operador map() para extraer información de la máquina de estados:

    Mono.fromCallable(() -> stateMachineFactory.getStateMachine(stringId))
    .map(machine -> machine.getState().getId())
    .subscribe(stateId -> System.out.println("Estado actual: " + stateId));

    En resumen, para usar Spring State Machine en un entorno reactivo, se puede envolver la llamada bloqueante a getStateMachine() dentro de un objeto Mono utilizando Mono.fromCallable() o Mono.fromSupplier(). Luego, se pueden encadenar operadores reactivos para realizar transiciones o extraer información de la máquina de estados.

Comments are closed.