当前位置 博文首页 > 大风起兮云飞扬:Flink--持久层和Flink进行集成使用

    大风起兮云飞扬:Flink--持久层和Flink进行集成使用

    作者:[db:作者] 时间:2021-08-07 22:07

    1、场景

    ?采用Flink对实时数据操作, 比如更新或者一些特定的操作等;然后将数据保存;

    保存的操作有原生jdbc连接;? jpa或者Mybatis,Hibernate等;

    2、解决

    思路A:

    ?1 启动Spring项目,然后自动注入一些service或者dao;

    ?2 Flink程序监听Spring项目是否启动完毕,启动完毕则启动Flink程序;

    ? ? ?结果:经过测试,Flink的程序是独立的,因为它是本地环境进行启动,JVM跟它单独分配空间执行;所以它与Spring这两个程序是独立的;Flink程序不能获取到Spring管理的实例;?

    思路B:Flink启动并单独加载配置,例如hibernate,mybatis,原生jdbc的连接等;在Flink的进程中去启动配置获取连接等;

    cs
    下一篇:没有了