storm安装

Zookeeper:提供一致性

http://blog.tnidea.com/deploy-storm-environment.html 解压程序包，拷贝 conf 下 zoo_sample.cfg 为 zoo.cfg，修改相关配置配置环境变量 Windows 环境下直接执行 binzkServer.cmd；Linux 下执行 bin/zkServer.sh start

py2.7

配置环境变量

jdk6

配置环境变量

注意空格问题，行前一个空格，【-】后一个空格，冒号后一个空格

storm.zookeeper.servers:
     - "127.0.0.1"
#     - "server2"

 storm.zookeeper.port: 3181  

 storm.local.dir: "D:\apache-storm-1.2.1\localStorm"  

# 
 nimbus.seeds: ["127.0.0.1"]
 
 supervisor.slots.ports:  
    - 6700  
    - 6701  
    - 6702  
    - 6703  
    
 storm.health.check.dir: "healthchecks"  
  
 storm.health.check.timeout.ms: 5000

启动

启动zookeeper zkServer
strom nimbus
strom supervisor
storm ui

搭建dotNet开发Storm拓扑的环境

http://blog.tnidea.com/deploy-storm-environment.html

使用Csharp创建你的第一个Storm拓扑（wordcount）

http://blog.tnidea.com/you-first-csharp-storm-topology.html

创建Maven项目打包提交wordcount到Storm集群

http://blog.tnidea.com/deploy-wordcount-topology.html

dotNET使用DRPC远程调用运行在Storm上的Topology

http://blog.tnidea.com/dot-net-drpc-storm.html

使用DRPC调用dotNET开发的Storm Topology

http://blog.tnidea.com/call-dot-net-drpc-program.html

Storm(1.2.1)集群环境搭建

https://blog.csdn.net/qingkangxu/article/details/79513697

Storm基本概念

https://www.cnblogs.com/200911/p/5002240.html

storm官方示例项目 storm-starter

git clone git://github.com/apache/storm.git && cd storm/examples/storm-starter

安装topology

storm jar firststorm.jar org.apache.storm.firststorm.FirstStorm

安装

Install-Package Storm.Net.Adapter namespace:Storm

接口

IBasicBolt和IBolt的区别仅仅在于后者需要自己处理
何时向Storm发送Ack或Fail，IBasicBolt则不需要关
心这些，如果你的Execute没有抛出异常的话，总会
在最后向Storm发送Ack，否则则发送Fail。Prepare
则是用于执行前的预处理

ISpout
IBolt

storm jar a.jar storm.starter.WordCountTopologyCsharp wordcount