返回响应或错误的Reactor Eventbus示例

Question

首先，我对非同步处理领域还很陌生。在我当前的项目中，我们使用SpringBoot和ProjectReactor，特别是Eventbus，来执行一些异步处理。我想使用eventbus也会使我们的系统更具可扩展性。

到目前为止，EventBus的使用还相当有限，我们在EventBus使用者中进行一些处理，而该使用者不返回任何内容。配置和示例处理器如下所示：

//配置文件

@SpringBootApplication
public class Application implements CommandLineRunner {

@Autowired
private EventBus eventBus;

@Autowired
private BatchProcessor batchProcessor;

@Override
public void run(String... arg0) throws Exception {
    eventBus.on("batchProcessor", batchProcessor);

}
}

//消费者

@Service
public class BatchProcesspr implements Consumer<Event<Request>> {

@Override
    public void accept(Event<Request> event) {
      // processing goes here
 }

到目前为止，对于具有无效返回类型的接受方法来说，这是可以接受的。但是，现在我有一个场景，我想从处理器方法返回一个响应，或者如果在处理过程中发生错误，需要抛出一个适当的异常，在这两种情况下，响应/异常需要返回到调用点。

这可以用Reactor来完成吗？如果是，请提供一个简单的例子。我读过Promise，但找不到类似的例子。

Answer 1

你试过发送和接收吗？http://projectreactor.io/ext/docs/reference/#bus-请求答复

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())
); 

您可以轻松地在呼叫者端注册另一个消费者，当服务响应时会收到通知。