开发者社区> 问答> 正文

关于flink集群中调用dubbo服务的咨询

i All,

    目前我这里有个需求是想通过flink集群,消费mq消息,然后调用发送push的dubbo服务,实现push分发的功能。

    网上关于flink接入spring框架的资料没有找到太多,更别提dubbo服务调用相关的了(也可能是我查询资料的方式有限)。

    期望哪位有经验的朋友能够给予指点,我自己其实已经实现了一个测试demo,但还是期望能有更多相关资料作为参考,主要是担心资源消耗和性能、安全方面会发生问题,因为本身也是刚接触flink,了解有限。

    方便的话可以提供一些实例代码或资料链接。

                                                                                      感谢flink社区的各位朋友*来自志愿者整理的flink邮件归档

展开
收起
船长的小螺号 2021-12-03 10:09:15 1717 0
1 条回答
写回答
取消 提交回答
  • Flink 任务可以调 Dubbo ,dubbo 相关初始化可以在 你的 main 方法中初始化,然后具体接口的初始化,

    在你的函数中的 open 方法中进行初始化,你自己需要处理好 Dubbo 相关异常,比如超时异常。 Dubbo 的话,

    会对任务处理的吞吐量有一定影响,毕竟从请求 Dubbo 到 返回数据,会消耗一定时间。*来自志愿者整理的FLINK邮件归档

    2021-12-03 10:37:55
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载