做网站什么什么,市北区小型网页设计培训,太原百度网站快速优化,手机版wordpress在storm中使用实时保存会对性能带来很大的考验#xff0c;所以在很多场景中还是使用定时保存#xff1b;而且storm自带了定时功能#xff0c;使用方式如下#xff1a; 首先在topo中的config中定义一个通信时间#xff0c;定义方式如下#xff1a; conf.put(Config.TOPOLO…在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{//做正常的操作}
