如何持久化在Flux的特定步骤创建的对象，并且之后不再需要？

Question

我正在创建一个对象员工，我还想创建另一个对象Event，它充当员工创建的日志。但是，我这样做的方式不会持久化Event。

    @Transactional
    public Mono<Employee> createEmployee(String name) {

        return Mono.fromCallable(() -> {
            Employee employee = new Employee();
            employee.setName(name);
            return employee;
        })
        .flatMap(employee -> {
            return employeeRepository.save(employee);
        })
        .doOnNext(employee -> {
            Event event = new Event();
            event.setDetail("Created employee : " + employee.getName());

            eventRepository
                .save(event)
                // .subscribe() // that didn't help
                ;
        });
    }

存储 库：

@Repository
public interface EmployeeRepository extends ReactiveCrudRepository<Employee, UUID> {
}

@Repository
public interface EventRepository extends ReactiveCrudRepository<Event, UUID> {
}

将保存员工，但不保存事件。我不确定这应该如何编码。

Answer 1

这应该可行:

@Transactional
public Mono<Employee> createEmployee(String name) {

    return Mono.fromCallable(() -> {
        Employee employee = new Employee();
        employee.setName(name);
        return employee;
    })
    .flatMap(employee -> {
        return employeeRepository.save(employee);
    })
    .doOnNext(employee -> {
        Event event = new Event();
        event.setDetail("Created employee : " + employee.getName());

        eventRepository
            .save(event)
            .block() // that didn't help
            ;
    });
}

Answer 2

如果您在doOnNext中有一个反应性处理，它将永远不会运行。所以，这取决于你来订阅。但我认为最好的办法是使用@Artem Bilan的解决方案。

Answer 3

相反，像这样：

 .flatMap(employee -> {
        return employeeRepository.save(employee);
    })
 .flatMap(employee -> {
        Event event = new Event();
        event.setDetail("Created employee : " + employee.getName());

        eventRepository
            .save(event)
            .thenReturn(employee);
    })

因此，通过这种方式，您可以在保存第一个 flatMap（） 后获得一个新的员工，将其传播到下游的下一个 flatMap（），调用 .save（事件） 以返回其 Mono，但随后您将该 Mono 替换为基于员工变量的新单一。

这样，一切都将在正确的时间以正确的顺序被订阅。