spring - 在 Spring WebFlux react 处理程序中发送 JMS 消息 : is it blocking?

Question

这是响应式(Reactive)处理的正确方法吗？我看到 2 个线程一个响应式(Reactive) nio，直到并包括 flatMap(fareRepo::save) .另一个线程是计算线程，它从发送消息开始一直持续到 ServerResponse.build()。我的问题是这种响应式处理请求的正确方法吗？注意:fareRepo 是响应式(Reactive) couchbase 存储库。
谢谢

return request.bodyToMono(Fare.class).flatMap(fareRepo::save).flatMap(fs -> {
            logger.info("sending message: {}, to queue", fs.getId());
            jmsTemplate.send("fare-request-queue", (session) -> session.createTextMessage(fs.getId()));
            return Mono.just(fs);
        }).flatMap(fi -> ServerResponse.created(URI.create("/fare/" + fi.getId())).build());

Answer 1

我假设您正在使用 Spring Framework 的 JmsTemplate实现，这是阻塞。

没有更多的上下文，我们只能假设您在 react 操作符中间有一个阻塞操作，这会导致您的应用程序出现问题。