storm的集群表面上看和hadoop的集群非常像。但是在Hadoop上面你运行的是MapReduce的Job, 而在Storm上面你运行的是Topology。
它们是非常不一样的 — 一个关键的区别是: 一个MapReduce Job最终会结束, 而一个Topology运永远运行(除非你显式的杀掉他)。

        Config conf = new Config();

        //设置work的数量
conf.setNumWorkers(2); //设置Excutor的数量
TopologyBuilder topologyBuilder = new TopologyBuilder();
topologyBuilder.setBolt("blue-spout", new BlueSpot(), 2);
topologyBuilder.setBolt("green-bolt", new GreenBolt(), 2).setNumTasks(4).shuffleGrouping("blue-spout");
topologyBuilder.setBolt("yellow-bolt", new YellowBolt(), 6).shuffleGrouping("green-bolt");

 命令行重新设置进程和线程个数

//Reconfigure the topology "test" to use 5 worker processes
//the spout "blue-spout to use 3 executors and the bolt "yellow-bolt" to use 10 executors." storm rebalance test -n 5 -e blue-spout=3 -e yellow-bolt=10

参考链接

1 storm 原理简介及单机版安装指南  https://my.oschina.net/leejun2005/blog/147607?from=20130804#OSC_h2_1

2 入门源码            https://github.com/nathanmarz/storm-starter

最新文章

  1. [恶趣味]搞了下局域网内的arp网络欺骗
  2. Junity测试最大子数列和的Java程序
  3. 数据库添加数据II及SQL语句错误
  4. c/c++ 数字转成字符串, 字符串转成数字
  5. 无需图片,使用CSS3实现圆角按钮[转]
  6. 搬瓦工vps搭建vpn
  7. centos6.5 64位 openvpn安装配置
  8. 使用Xshell生成key,避免password登录linux
  9. HTC Vive 叠影器无法创建设备
  10. InfluxDB介绍
  11. android-基础编程-ViewPager
  12. java 连接数组
  13. Nestjs 使用mongodb
  14. Day03(黑客成长日记)
  15. Objective C, post 请求
  16. Netty核心概念(10)之内存管理
  17. Yii2.0 技巧总结
  18. 解决 ORA-12514: TNS: 监听程序当前无法识别连接描述符中请求的服务
  19. [转]NLog 自定义字段 写入 oracle
  20. ubuntu 执行Python脚本出现: /usr/bin/env: ‘python\r’: No such file or directory

热门文章

  1. Web页面性能优化(YSlow)
  2. Sql server用QQ邮箱发送邮件
  3. vue-router路由器的使用
  4. PHP逐行读取数据
  5. appium server日志分析
  6. ptyhon从入门到放弃之操作系统基础
  7. curl类封装
  8. 【转】Matlab使用过程中内存不足问题的总结
  9. Kotlin学习记录3
  10. java调用ffmpeg命令行推流遇到的问题