13518219792
本地模式运行
本地模式类似storm集群是一个进程，用来编写和测试topology。在本地模式上运行topology类似在一个集群上运行topology。创建一个本地集群：
import backtype.storm.LocalCluster;
LocalCluster cluster = new LocalCluster();
提交集群使用submitTopology，
杀死集群使用killTopology
关闭一个本地集群使用cluster.shutdown();
本地模式下的公共配置：
Config.TOPOLOGY_MAX_TASK_PARALLELISM
Config.TOPOLOGY_DEBUG:
在华容等地区，都构建了全面的区域性战略布局，加强发展的系统性、市场前瞻性、产品创新能力，以专注、极致的服务理念，为客户提供网站设计制作、成都网站制作 网站设计制作按需定制网站,公司网站建设,企业网站建设,成都品牌网站建设,全网整合营销推广,成都外贸网站建设,华容网站建设费用合理。
生产集群运行
一、步骤
1、定义topology，若用java语言，使用TopologyBuilder来定义
2、使用StormSubmitter来提交topology到集群中，所需参数需要topology名字，topology的参数配置，topology本身
例：
Config conf = new Config();
conf.setNumWorkers(20);
conf.setMaxSpoutPending(5000);
StormSubmitter.submitTopology("mytopology", conf, topology);
3、创建jar包使用storm 客户端命令，jar包包含你的所有的代码
4、提交topology，为jar包指定参数
storm jar path/to/allmycode.jar org.me.MyTopology arg1 arg2 arg3
实例：
1 public static void main(String[] args) throws Exception {
2 TopologyBuilder builder = new TopologyBuilder();
3 builder.setSpout("random", new RandomWordSpout(), 2);
4 builder.setBolt("transfer", new TransferBolt(), 4).shuffleGrouping("random");
5 builder.setBolt("writer", new WriterBolt(), 4).fieldsGrouping("transfer", new Fields("word"));
6 Config conf = new Config();
7 conf.setNumWorkers(4);// 设置启动4个Worker
8 conf.setNumAckers(1); // 设置一个ack线程
9 conf.setDebug(true); // 设置打印所有发送的消息及系统消息
10 StormSubmitter.submitTopology("test", conf, builder.createTopology());
11 }
二、公共配置
Config.TOPOLOGY_WORKERS ：设置执行topology的worker的数量
Config.TOPOLOGY_ACKER_EXECUTORS：
Config.TOPOLOGY_MAX_SPOUT_PENDING
Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS:默认是30s
Config.TOPOLOGY_SERIALIZATIONS
三、杀死topology
storm kill stormname
四、更新一个正在运行的topology
杀死一个正在运行的topology，提交一个新的topology，计划使用storm swap命令
五、监控topology使用Storm UI或者集群上的工作日志
