You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 依辰 <43...@qq.com> on 2020/01/10 03:12:21 UTC
关于flink集群中调用dubbo服务的咨询
Hi All,
目前我这里有个需求是想通过flink集群，消费mq消息，然后调用发送push的dubbo服务，实现push分发的功能。
网上关于flink接入spring框架的资料没有找到太多，更别提dubbo服务调用相关的了(也可能是我查询资料的方式有限)。
期望哪位有经验的朋友能够给予指点，我自己其实已经实现了一个测试demo，但还是期望能有更多相关资料作为参考，主要是担心资源消耗和性能、安全方面会发生问题，因为本身也是刚接触flink，了解有限。
方便的话可以提供一些实例代码或资料链接。
感谢flink社区的各位朋友
ps:下图是当前的实现方式，总觉得太简陋了，还缺少close时对spring资源的释放操作
Re: 关于flink集群中调用dubbo服务的咨询
Posted by LakeShen <sh...@gmail.com>.
Flink 任务可以调 Dubbo ，dubbo 相关初始化可以在 你的 main 方法中初始化，然后具体接口的初始化，
在你的函数中的 open 方法中进行初始化，你自己需要处理好 Dubbo 相关异常，比如超时异常。 Dubbo 的话，
会对任务处理的吞吐量有一定影响，毕竟从请求 Dubbo 到 返回数据，会消耗一定时间。
祝好，
沈磊
Leonard Xu <xb...@gmail.com> 于2020年1月10日周五 上午11:50写道：
> Hi, 依辰
>
> 对dubbo不太熟，你邮件里的图片挂了，可以通过图床工具发送下图片链接。
>
> Best,
> Leonard
>
> > 在 2020年1月10日，11:12，依辰 <43...@qq.com> 写道：
> >
> > Hi All,
> > 目前我这里有个需求是想通过flink集群，消费mq消息，然后调用发送push的dubbo服务，实现push分发的功能。
> > 网上关于flink接入spring框架的资料没有找到太多，更别提dubbo服务调用相关的了(也可能是我查询资料的方式有限)。
> >
> 期望哪位有经验的朋友能够给予指点，我自己其实已经实现了一个测试demo，但还是期望能有更多相关资料作为参考，主要是担心资源消耗和性能、安全方面会发生问题，因为本身也是刚接触flink，了解有限。
> > 方便的话可以提供一些实例代码或资料链接。
> >
> 感谢flink社区的各位朋友
> >
> > ps:下图是当前的实现方式，总觉得太简陋了，还缺少close时对spring资源的释放操作
> >
> >
>
>
Re: 关于flink集群中调用dubbo服务的咨询
Posted by Leonard Xu <xb...@gmail.com>.
Hi, 依辰
对dubbo不太熟，你邮件里的图片挂了，可以通过图床工具发送下图片链接。
Best,
Leonard
> 在 2020年1月10日，11:12，依辰 <43...@qq.com> 写道：
>
> Hi All,
> 目前我这里有个需求是想通过flink集群，消费mq消息，然后调用发送push的dubbo服务，实现push分发的功能。
> 网上关于flink接入spring框架的资料没有找到太多，更别提dubbo服务调用相关的了(也可能是我查询资料的方式有限)。
> 期望哪位有经验的朋友能够给予指点，我自己其实已经实现了一个测试demo，但还是期望能有更多相关资料作为参考，主要是担心资源消耗和性能、安全方面会发生问题，因为本身也是刚接触flink，了解有限。
> 方便的话可以提供一些实例代码或资料链接。
> 感谢flink社区的各位朋友
>
> ps:下图是当前的实现方式，总觉得太简陋了，还缺少close时对spring资源的释放操作
>
>