在storm中使用實時保存會對性能帶來很大的考驗，所以在很多場景中還是使用定時保存；而且storm自帶了定時功能，使用方式如下：

首先在topo中的config中定義一個通信時間，定義方式如下：

conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 60);

設置這個屬性以后，就會每隔60秒發送一次心跳信息到所有的bolt中，也就是每隔60秒在所有的bolt中都會收到心跳tuple，所以在bolt中的execute方法中可以這樣處理：

if (tuple.getSourceComponent().equals(Constants.SYSTEM_COMPONENT_ID)&& tuple.getSourceStreamId().equals(Constants.SYSTEM_TICK_STREAM_ID)) {//保存緩存的列表信息，并清空}}else{//做正常的操作}

總結

以上是生活随笔為你收集整理的在storm中使用定时保存的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。