storm安装

Zookeeper:提供一致性

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

py2.7

配置环境变量

jdk6

配置环境变量

maven

​​http://maven.apache.org/download.cgi​​ 配置环境变量

storm-net-adapter-2.0.7

​​https://github.com/ziyunhx/storm-net-adapter​​​ ​​https://github.com/ziyunhx/storm-net-adapter/releases​​

apache-storm1.2.1

​​https://www.apache.org/dyn/closer.lua/storm/apache-storm-1.2.2/apache-storm-1.2.2.zip​​​ storm集群搭建​​javascript:void(0)​​

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

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

启动

1. 启动zookeeper zkServer
2. strom nimbus
3. strom supervisor
4. 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)集群环境搭建

​​javascript:void(0)​​

​​javascript:void(0)​​

Storm基本概念

​​javascript:void(0)​​

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
则是用于执行前的预处理

1. ISpout
2. IBolt

storm jar a.jar storm.starter.WordCountTopologyCsharp wordcount