开发者社区> 问答> 正文

定期从PostgreSQL获取数据并将其发送到ActiveMQ

基本上,我在PostgreSQL中有一个数据表。我想获取所有数据,并将其发送为ActiveMQ消息(表中1行有1条消息)。

但是数据表每5秒自动更新一次。因此,表中每隔5秒就会有一些新数据。

如何在不重复发送已发送数据的情况下发送新数据?而且我认为我必须使用Thread.sleep(5000)使其无休止地循环吗?

展开
收起
游客ufivfoddcd53c 2020-01-04 15:17:07 947 0
1 条回答
写回答
取消 提交回答
  • 为防止消息重复,有一些可能的方法,例如:

    ActiveMQ支持重复消息检测,您可以利用此功能。

    使用字段(布尔)表示该行是否发送。

    关于这5秒钟,您可以休眠或使用调度程序来执行此操作,例如:Spring Scheduler,Quartz

    2020-01-04 15:17:41
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
PostgreSQL 物联网六脉神剑 立即下载
PostgreSQL在哈啰的实践-周飞 立即下载
PostgreSQL高并发数据库应用数据 立即下载

相关镜像