Spring Асинхронный REST с DeferredResult и Reactor

Это лучшая идея, которую я мог разработать, чтобы получить асинхронность с Reactor в вызове REST для удобства использования: я не удовлетворен ... есть идеи о том, как сделать это лучше?

(полный код здесь для справки)

Интерфейс REST:

@RestController
public class REST_Interface {

    @Autowired
    public EventBus eventBus;

    @RequestMapping("/getGreeting/{name}")
    public DeferredResult<String> getGreeting(@PathVariable String name) {

        DeferredResult<String> result = new DeferredResult<>();

        EventWrapper<String> wrapper = new EventWrapper<>(result, name);
        eventBus.notify("greeting.topic", Event.wrap(wrapper));

        return result;
        }
}

Обертка событий:

public class EventWrapper<T> {
    private DeferredResult<T> deferredResult;
    private T payload;

    public EventWrapper(DeferredResult<T> deferredResult, T payload) {
        this.deferredResult = deferredResult;
        this.payload = payload;
    }
    // Getters & Setters
}

Потребитель событий:

@Consumer
public class EventConsumer {

    @Autowired
    public EventBus eventBus;

    @Selector("greeting.topic")
    public void onTestTopic(Object o) {
        System.out.println("Event receved for Logging " + o.toString());
    }

    @Selector("greeting.topic")
    public void wrappedGreeter(EventWrapper<String> ew) {

        ew.getDeferredResult().setResult("Ciao " + ow.getPayload().toUpperCase());
    }
}

java spring rest reactor project-reactor
person Andrea T    schedule 22.11.2015    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Взгляните на EventBus.sendAndReceive(), он создан именно для таких случаев использования. Пример из http://projectreactor.io/docs/reference/#bus-request-reply :

EventBus bus;

bus.receive($("job.sink"), (Event<String> ev) -> {
  return ev.getData().toUpperCase();
}); 

bus.sendAndReceive(
    "job.sink",
   Event.wrap("Hello World!"),
   s -> System.out.printf("Got %s on thread %s%n", s, Thread.currentThread())
);
person Jan Galinski    schedule 22.11.2015
comment
В Java это выглядит не так красиво. :D В любом случае, этот способ заставит использовать один и тот же метод во всей цепочке событий, так что это больше не будет парадигмой, управляемой событиями, а будет только асинхронной серией вызовов. - person Andrea T; 22.11.2015