时间戳

首页 > 解决方案 > 带有 WebClient 的 Cron 调度程序

java - 带有 WebClient 的 Cron 调度程序

问题描述

我正在使用弹簧靴。我正在尝试将数据从一个数据库发送到另一个。首先，我通过发出 get 请求从第一个数据库中获取数据并通过 Web 客户端应用 post 将数据发送到另一个数据库来做到这一点。有效！但是，当我尝试使用带有 @Scheduled 注释的 cron 调度程序来执行此操作时，它不会将数据发布到数据库中。即使该功能工作正常，因为我尝试通过该功能打印东西，但 WebClient 没有发布数据（也检查了数据，这很好）。

Cron 类是：

@Component
public class NodeCronScheduler {
    
    
    @Autowired
    GraphService graphService;

    @Scheduled(cron = "*/10 * * * * *")
    public void createAllNodesFiveSeconds()
    {
        graphService.saveAlltoGraph("Product");
    }

}

saveAlltoGraph 函数从 Product 表中取出所有的元组，然后向图数据库的 api 发送 post 请求，从而从元组中生成节点。

这是功能：

public Mono<Statements> saveAlltoGraph(String label) {
        JpaRepository currentRepository = repositoryService.getRepository(label);
        List<Model> allModels = currentRepository.findAll();
        Statements statements = statementService.createAllNodes(allModels, label);
        //System.out.println(statements);
        return webClientService.sendStatement(statements);
    }

首先，标签“Product”用于获取与该表相关的 JpaRepository。然后我们在列表中获取该表的所有元组，并据此创建对象（我们可以使用序列化程序来获取 JSON）。

这是 sendStatement 函数：

public Mono<Statements> sendStatement(Statements statements){
        System.out.println(statements);
        return webClient.post().uri("http://localhost:7474/db/data/transaction/commit")
                .body(Mono.just(statements), Statements.class).retrieve().bodyToMono(Statements.class);
    }

当我们使用获取请求映射调用此 saveAlltoGraph 时，一切正常，但不使用调度程序。

标签： javaspringapirestwebclient

解决方案

我尝试添加 .block() 和 .subscribe() 。事情开始与 cron 调度程序一起工作。

推荐阅读