新增会员数计算的 Storm 实时流程挺不错的，适合用在需要大规模实时数据的场景。流程分为多个组件，其中NewMemberParseBolt负责过滤异常数据，解析出所需字段并发射Tuple；NewMemberSpout从 MQ 中读取数据，发射Tuple；通过NewMemberSum2RedisBolt来计算总的新增会员数，并把数据存入 Redis。每分钟定时发射结果的功能由NewMemberSumBolt实现，数据最终会被写入 MySQL 或 MQ，形成一个完整的实时链。整体来说，这个架构适合你在流式数据计算中使用，操作也灵活哦。

如果你正在用 Storm 类似的实时数据流，还是蛮推荐这个方案的。可以你高效计算新增会员数，并保持系统的高效性。需要注意的是，在大数据量的情况下，适当的优化 Redis 存取速度会让你体验更好。