提交 Fire-N-Forget 请求

Question

在 Spring Boot 应用程序中，我有以下工作代码用于在 Rest 控制器中提交请求-响应请求：

@GetMapping("/request-response")
public ResponseEntity<Mono<Message>> requestResponseCtr() throws InterruptedException {

    Mono<Message> message = this.rsocketRequesterMono.flatMap(
            requester -> requester.route("request-response")
                    .data(new Message(...))
                    .retrieveMono(Message.class)
                );
    log.info("\nResponse was: {}", message);

    return ResponseEntity.of(Optional.of(message));
}

根据我对the RSocket Java document 的理解，我需要将 retriveMono(...) 替换为 send() 以提交 fire-n-forget 请求（在文档的第 12 页）。以下代码应该可以工作。

@GetMapping("fire-and-forget")
public ResponseEntity<Mono<Void>> fireAndForget() throws InterruptedException {
    log.info("\nFire-And-Forget...");

    this.rsocketRequesterMono.flatMap(
            requester -> requester.route("fire-and-forget")
                    .data(new Message(...))
                    .send()
    );
    return ResponseEntity.of(Optional.of(Mono.empty()));
}

但是，它不起作用。在 TCP 首次亮相工具上，它没有任何流量。

提交fire-n-forget的正确方法是什么？

Answer 1

这个电话

this.rsocketRequesterMono.flatMap(
            requester -> requester.route("fire-and-forget")
                    .data(new Message(...))
                    .send()
    );

没有做任何事情，因为没有人订阅它。

你可能需要

ResponseEntity.of(Optional.of(this.rsocketRequesterMono.flatMap(
            requester -> requester.route("fire-and-forget")
                    .data(new Message(...))
                    .send()
    )));