小编min*_*t3r的帖子

我想将 Hikari 池配置为在应用程序启动时而不是在发出第一次查询时急切地初始化。

截至目前，spring initializr 项目显示在第一次查询时提供了 hikari 池。

重现问题 - 使用 web、jdbc 和 mysql 依赖项创建 spring initializr 项目。Hikari 池仅在向控制器发出 GET 请求后创建

应用程序属性

spring.datasource.url=
spring.datasource.driver-class-name=
spring.datasource.username=
spring.datasource.password=
logging.level.com.zaxxer.hikari.HikariConfig=DEBUG
spring.datasource.hikari.maximum-pool-size=100
spring.datasource.hikari.minimum-idle=10
spring.datasource.hikari.connection-init-sql=SELECT 1

控制器

@RestController
public class DemoController {

    @Autowired
    private JdbcTemplate template;

    @GetMapping(value="/request")
    public String testHikariEagerInitialization() {

        template.execute("SELECT COUNT(1) FROM trade");

        return "Hikari Pool created now!";
    }

}

应用程序启动时的日志

 :: Spring Boot ::        (v2.1.6.RELEASE)

2019-07-09 08:36:02.074  INFO 37884 --- [           main] com.example.demo.DemoApplication         : Starting DemoApplication on  with PID 37884 ()
2019-07-09 …

我正在尝试实现从 BlockingQueue 创建的 reactor Flux 但不确定哪个运算符最适合我的用例？

我正在创建一个流式 REST 端点，其中响应是 Flux，它需要不断地从 BlockingQueue 发出消息作为对 GET REST 调用的响应。

我已经尝试过论坛和文档，并且只能找到从可迭代集合或反应数据源启动的 Flux，但没有来自任何 BlockingQueue 的示例。