JStorm是一个类似于Hadoop MapReduce的系统，用户按照指定的接口实现一个任务，然后将这个任务交给JStorm系统，JStorm将这个任务跑起来，并按7*24小时运行。如果中间一个worker发生了意外故障，调度器立即分配一个新的worke

要统计出来当前最新的实时的热数据是哪些，我们就得将商品详情页访问的请求对应的流量，日志，实时上报到kafka中。然后将数据从mysql中查询出来，写入缓存中，进行缓存的预热，多个服务实例，分布式的并行的去做，基于zk分布式锁做了协调了，分布式并行缓存的预热

下面分别启动ZooKeeper、Nimbus、UI、supervisor、logviewer. 节点node2和node3启动supervisor，按照配置，每启动一个supervisor就有了4个slots. 分发配置storm.yaml文件给其他节点

　　　　启动、停止自己管理的worker进程。　　　　不管在哪个bolt中出现问题，都会回到spout再次走流程，但是有问题，这个情况可以忽略。　　　　client--->消息队列--->strom--->结果源。　　　　　　　　i++;

U代表spout创建的tuple id.也就是tuple创建时和ack时都要XOR一次，当所有component都处理完时，结果值是0.最后一个bolt没有下游bolt时为0.

本文翻译自《Getting Started With Storm》译者：吴京润 编辑：郭蕾 方腾飞。由于本人是持学习的目的翻译本书，对Storm的了解并不丰富，许多专用术语翻译难免不准确，如有谬误还请读者朋友们不吝指正。本书共分为八个章节和三个附录：第一

storm的配置、eclipse里maven的配置以及创建项目部分省略。

前一篇文章 JStorm：概念与编程模型 介绍了JStorm的基本概念以及编程模型方面的知识，本篇主要介绍自己对JStorm的任务调度方面的认识，主要从三个方面介绍：。Worker是task的容器， 同一个worker只会执行同一个topology相关的t

JStorm2.1.1集群的安装和使用。Storm是一个免费开源、分布式、高容错的实时计算系统，而JStorm是阿里巴巴开源的基于Storm采用Java重写的一套分布式实时流计算框架，在性能和支持的集群规模上做了较大优化。在服务器A和服务器B上：。#pro

Storm是一个免费开源、分布式、高容错的实时计算系统。Nimbus ：Storm集群的Master节点，负责分发用户代码，指派给具体的Supervisor节点上的Worker节点，去运行Topology对应的组件的Task。ZooKeeper ：用来协调

Storm的所有的状态信息都是保存在Zookeeper里面，nimbus通过在zookeeper上面写状态信息来分配任务，supervisor，task通过从zookeeper中读状态来领取任务，同时supervisor, task也会定义发送心跳信息到z

找到：network.negotiate-auth.trusted-uris 修改值，写入要访问的连接地址，协议+域名例如我的http://master

Flink-Storm 是 Flink 官方提供的用于 Flink 兼容 Storm 程序 beta 工具，并且在 Release 1.8 之后去掉相关代码。本文主要讲述 58 实时计算平台如何优化 Flink-Storm 以及基于 Flink-Storm

5、简化map reduce的开发， hive

　　安装Storm之前首先保证之前安装的Zookeeper服务正常运行，包括配置hosts映射，主机名修改，防火墙都已经设置完好。　　部分需要依赖Python，红帽系列Linux默认Python版本是2.6.6，可以满足要求；Linux可以安装多个版本Py

Storm是支持自定义分组的，本篇文章就是探究Storm如何编写一个自定义分组器，以及对Storm分组器如何分组数据的理解。从上面的代码可以看出，该自定义分组会把数据归并到第一个Task<code>Arrays.asList;</code

Workers : 在一个节点上可以运行一个或多个独立的JVM 进程。但一般默认每个executor只执行一个task。一个worker可以包含一个或多个executor, 每个component 至少对应于一个executor, 所以可以说executo

storm.id运行中拓扑的id,由storm name和一个唯一随机数组成。nimbus.childopts通过storm-deploy项目部署时指定给nimbus进程的jvm选项。nimbus.reassign当发现task失败时nimbus是否重新分

1，怎么了解jstorm，这个答案没什么固定的，但是我个人比较喜欢去看官方的文档，如果官方的文档实在找不到了，再去baidu，baidu不到那就只能google了，如果还是找不到。。至少从流水两个字，我想到了管道，其实个人理解jstorm的流水线很像是管道

1. storm集群启动后，nimbus进程、supervisor进程，分别向zookeeper进行注册