1

使用 spring boot webflux,我正在尝试 Blockhound 进行一个非常简单的阻塞调用,但它似乎没有检测到它。

        <dependency>
            <groupId>io.projectreactor.tools</groupId>
            <artifactId>blockhound</artifactId>
            <version>1.0.6.RELEASE</version>
        </dependency>

在主要方法中:

public static void main(String[] args) {
    BlockHound.install();
    SpringApplication.run(MyApplication.class, args);
  }

我的阻塞端点:

    @GetMapping("/block")
    public Mono<String> block() {
        String a = Mono.just("block").block();
        return Mono.just(a);
    }

任何想法?

编辑:

当我在端点中使用 UUID.randomUUID() 时,我收到与 randomUUID() 使用的阻塞 FileInputStream#readBytes 相关的错误。所以我想我的安装很好

4

1 回答 1

4

这里没有什么问题,你只是遇到了一个角落案例。

Mono.just()是一种相当特殊Mono方式而不是一种方式(这就是为什么我对它在这么多简单的“入门”样式示例中的使用感到绝望,但我离题了)——因为你实际上只是将一个值包装在一个虚拟的发布者中,它永远不需要阻塞来返回它的值,即使你调用了 block 方法。方法名称可能暗示您正在阻塞,但您可以从源代码中轻松验证它只是返回一个 value。因此没有发生阻塞操作,因此 Blockhound 没有什么可抱怨的。

如果您要在组合中添加另一个运算符,即使它没有实际效果:

String a = Mono.just("block").cache().block();

...然后你会看到 Blockhound 开始抱怨,因为你不再直接使用MonoJust.

Blockhound 正在做它应该在这里做的事情,问题是你(非常可以理解)期待某些东西会阻止它不会。

于 2021-07-10T21:13:01.143 回答