Loading... <p>storm有两种操作模式: 本地模式和远程模式。</p> <p>本地模式:你可以在你的本地机器上开发测试你的topology, 一切都在你的本地机器上模拟出来; </p> <p>远端模式:你提交的topology会在一个集群的机器上执行。</p> <p>本文以Twitter Storm官方Wiki为基础,详细描述如何快速搭建一个Storm集群,其中,项目实践中遇到的问题及经验总结,在相应章节以“注意事项”的形式给出。</p> <p class="headline-1 bk-sidecatalog-title"><span style="line-height: 36px;font-size: 22px"><strong>1. Strom集群组件</strong></span></p> <p> Storm集群中包含两类节点:主控节点(Master Node)和工作节点(Work Node)。其分别对应的角色如下:</p> <p>1. 主控节点(Master Node)上运行一个被称为Nimbus的后台程序,它负责在Storm集群内分发代码,分配任务给工作机器,并且负责监控集群运行状态。Nimbus的作用类似于Hadoop中JobTracker的角色。</p> <p>2. 每个工作节点(Work Node)上运行一个被称为Supervisor的后台程序。Supervisor负责监听从Nimbus分配给它执行的任务,据此启动或停止执行任务的工作进程。每一个工作进程执行一个Topology的子集;一个运行中的Topology由分布在不同工作节点上的多个工作进程组成。</p> <p><img src="//cto.wang/usr/uploads/2016/07/20160703155945-42.png" title="1428120774505085.png" alt="1.png" /> </p> <p><span style="padding: 0px">Storm集群组件</span></p> <p>Nimbus和Supervisor节点之间所有的协调工作是通过Zookeeper集群来实现的。此外,Nimbus和Supervisor进程都是快速失败(fail-fast)和无状态(stateless)的;Storm集群所有的状态要么在Zookeeper集群中,要么存储在本地磁盘上。这意味着你可以用kill -9来杀死Nimbus和Supervisor进程,它们在重启后可以继续工作。这个设计使得Storm集群拥有不可思议的稳定性。</p> <p class="headline-1 bk-sidecatalog-title"><span style="line-height: 36px;font-size: 22px"><strong>2. Strom集群安装</strong></span></p> <p>这一章节将详细描述如何搭建一个Storm集群。下面是接下来需要依次完成的安装步骤:</p> <p>1. 搭建Zookeeper集群;</p> <p>2. 安装Storm依赖库;</p> <p>3. 下载并解压Storm发布版本;</p> <p>4. 修改storm.yaml配置文件;</p> <p>5. 启动Storm各个后台进程。</p> <h3>2.1 安装java</h3> <p>安装java:<br />一、安装<br />创建安装目录,在/usr/java下建立安装路径,并将文件考到该路径下: <br /># mkdir /usr/java<br />1、 jdk-6u13-linux-i586.bin 这个是自解压的文件,在linux上安装如下: <br /># chmod 755 jdk-6u13-linux-i586.bin <br /># ./ jdk-6u13-linux-i586.bin (注意,这个步骤一定要在 jdk-6u13-linux-i586.bin所在目录下)<br />在按提示输入yes后,jdk被解压。<br /> 出现一行字:Do you aggree to the above license terms? [yes or no]<br /> 安装程序在问您是否愿意遵守刚才看过的许可协议。当然要同意了,输入"y" 或 "yes" 回车。</p> <p>二、配置<br /> #vi /etc/profile<br /> 在里面添加如下内容</p> <pre class="brush:python;toolbar:false">export JAVA_HOME=/usr/java/jdk1.6.0_13 export JAVA_BIN=/usr/java/jdk1.6.0_13/bin export PATH=$PATH:$JAVA_HOME/bin export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar export JAVA_HOME JAVA_BIN PATH CLASSPATH</pre> <p>让/etc/profile文件修改后立即生效 ,可以使用如下命令:<br /> # . /etc/profile<br />注意: . 和 /etc/profile 有空格. <br /> <br />重启测试<br /> java -version<br /> 屏幕输出:</p> <pre class="brush:python;toolbar:false">java version "jdk1.6.0_02" Java(TM) 2 Runtime Environment, Standard Edition (build jdk1.6.0_02) Java HotSpot(TM) Client VM (build jdk1.6.0_02, mixed mode)</pre> <p>问题:<br />1)安装jdk,而不是jre啊,jre没有javac</p> <pre class="brush:python;toolbar:false">如果使用yum install java 安装,没有安装javac的。</pre> <p>2)安装java的版本和javac版本要一致。否则执行jar包的时候会报错找不到main函数:</p> <pre class="brush:python;toolbar:false">Exception in thread "main" java.lang.UnsupportedClassVersionError</pre> <h3>2.1 搭建Zookeeper集群</h3> <p>Storm使用Zookeeper协调集群,由于Zookeeper并不用于消息传递,所以Storm给Zookeeper带来的压力相当低。大多数情况下,单个节点的Zookeeper集群足够胜任,不过为了确保故障恢复或者部署大规模Storm集群,可能需要更大规模节点的Zookeeper集群(对于Zookeeper集群的话,官方推荐的最小节点数为3个)。在Zookeeper集群的每台机器上完成以下安装部署步骤:</p> <p>1. 根据Zookeeper集群的负载情况,合理设置Java堆大小,尽可能避免发生swap,导致Zookeeper性能下降。保守起见,4GB内存的机器可以为Zookeeper分配3GB最大堆空间。</p> <p>2. 下载后解压安装Zookeeper包,官方下载链接为http://hadoop.apache.org/zookeeper/releases.html。</p> <p>3. 根据Zookeeper集群节点情况,在conf目录下创建Zookeeper配置文件zoo.cfg:</p> <pre class="brush:python;toolbar:false">tickTime=2000 dataDir=/var/zookeeper/ clientPort=2181 initLimit=5 syncLimit=2 server.1=zoo1:2888:3888 server.2=zoo2:2888:3888 server.3=zoo3:2888:3888</pre> <p>其中,dataDir指定Zookeeper的数据文件目录;其中server.id=host:port:port,id是为每个Zookeeper节点的编号,保存在dataDir目录下的myid文件中,zoo1~zoo3表示各个Zookeeper节点的hostname,第一个port是用于连接leader的端口,第二个port是用于leader选举的端口。</p> <p>4. 在dataDir目录下创建myid文件,文件中只包含一行,且内容为该节点对应的server.id中的id编号。</p> <p>5. 启动Zookeeper服务:</p> <pre class="brush:python;toolbar:false">java -cp zookeeper.jar:lib/log4j-1.2.15.jar:conf \ org.apache.zooke eper.server.quorum.QuorumPeerMain zoo.cfg</pre> <p> </p> <p>或者</p> <pre class="brush:python;toolbar:false">bin/zkServer.sh start</pre> <p>输入jps命令查看进程:namenode上显示为(本次为单机配置):19361 QuorumPeerMain21691 Jps其中,QuorumPeerMain是zookeeper进程,启动正常。3、查看状态:zookeeper-3.4.3/bin/zkServer.sh statusJMX enabled by defaultUsing config: /home/hadooptest/zookeeper-3.4.3/bin/../conf/zoo.cfgMode: standalone</p> <p></p> <p>6. 通过Zookeeper客户端测试服务是否可用:</p> <pre class="brush:python;toolbar:false">java -cp zookeeper.jar:src/java/lib/log4j-1.2.15.jar:conf:src/java/lib/jline-0.9.94.jar \ org.apache.zookeeper.ZooKeeperMain -server 127.0.0.1:2181</pre> <p>或者</p> <pre class="brush:python;toolbar:false">bin/zkCli.sh -server 127.0.0.1:2181</pre> <p><span style="font-family: Arial">7、停止zookeeper进程:zookeeper-3.4.3/bin/zkServer.sh stop</span></p> <p><span style="padding: 0px">注意事项:</span></p> </p> <pre class="brush:python;toolbar:false">由于Zookeeper是快速失败(fail-fast)的,且遇到任何错误情况,进程均会退出,因此,最好能通过监控程序将Zookeeper管理起来,保证 Zookeeper退出后能被自动重启。详情参考这里。 Zookeeper运行过程中会在dataDir目录下生成很多日志和快照文件,而Zookeeper运行进程并不负责定期清理合并这些文件,导致占用大量磁 盘空间,因此,需要通过cron等方式定期清除没用的日志和快照文件。详情参考这里。具体命令格式如下:java -cp zookeeper.jar:log4j.jar:conf org.apache.zookeeper.server.PurgeTxnLog <dataDir> <snapDir> -n <count></pre> <p>2.2 安装Storm依赖库</p> <p>接下来,需要在Nimbus和Supervisor机器上安装Storm的依赖库,具体如下:</p> <p>1. ZeroMQ 2.1.7 – 请勿使用2.1.10版本,因为该版本的一些严重bug会导致Storm集群运行时出现奇怪的问题。少数用户在2.1.7版本会遇到”IllegalArgumentException”的异常,此时降为2.1.4版本可修复这一问题。</p> <p>2. JZMQ</p> <p>3. Java 6 </p> <p>4. Python 2.6.6</p> <p>5. unzip</p> <p>以上依赖库的版本是经过Storm测试的,Storm并不能保证在其他版本的Java或Python库下可运行。</p> <h4>2.2.1 安装ZMQ 2.1.7</h4> <p>下载后编译安装ZMQ:</p> </p> <pre class="brush:python;toolbar:false">wget http://download.zeromq.org/zeromq-2.1.7.tar.gz tar -xzf zeromq-2.1.7.tar.gz cd zeromq-2.1.7 ./configure make sudo make install</pre> <p>注意事项:</p> <pre class="brush:python;toolbar:false">如果安装过程报错uuid找不到,则通过如下的包安装uuid库: sudo yum install e2fsprogsl -b current sudo yum install e2fsprogs-devel -b current</pre> <p>2.2.2 安装JZMQ</p> <p>下载后编译安装JZMQ:</p> <pre class="brush:python;toolbar:false">git clone https://github.com/nathanmarz/jzmq.git cd jzmq ./autogen. sh ./configure make sudo make install</pre> <p>为了保证JZMQ正常工作,可能需要完成以下配置:</p> <ol start="1" class=" list-paddingleft-2"> <li> <p>正确设置 JAVA_HOME环境变量</p> </li> <li> <p>安装Java开发包</p> </li> <li> <p>升级autoconf</p> </li> <li> <p>如果你是Mac OSX,参考这里</p> </li> </ol> <p><span style="padding: 0px">注意事项:</span></p> <pre class="brush:python;toolbar:false">如果运行 ./configure 命令出现问题,参考这里。</pre> <p>2.2.3 安装Java 6</p> <p> (上面已经提到安装了)</p> <h4>2.2.4 安装Python2.6.6</h4> <ol class=" list-paddingleft-2"> <li> <p>下载Python2.6.6:</p> </li> <li> <pre class="brush:python;toolbar:false">wget http://www.python.org/ftp/python/2.6.6/Python-2.6.6.tar.bz</pre> </li> </ol> <p>2. 编译安装Python2.6.6:</p> <pre class="brush:python;toolbar:false">tar –jxvf Python-2.6.6.tar.bz2 cd Python-2.6.6 ./configure make make install</pre> <p>3. 测试Python2.6.6:</p> </p> <pre class="brush:python;toolbar:false">python -V Python 2.6.6</pre> <p>2.2.5 安装unzip</p> <ol class=" list-paddingleft-2"> <li> <p>如果使用RedHat系列Linux系统,执行以下命令安装unzip:</p> </li> <li> <pre class="brush:python;toolbar:false">apt-get install unzip</pre> </li> </ol> <p>2. 如果使用Debian系列Linux系统,执行以下命令安装unzip:</p> <pre class="brush:python;toolbar:false">yum install unzip</pre> <p>2.3 下载并解压Storm发布版本</p> <p>下一步,需要在Nimbus和Supervisor机器上安装Storm发行版本。</p> <ol class=" list-paddingleft-2"> <li> <p>下载Storm发行版本,推荐使用Storm0.8.1:<span style="font-family: sans-serif;font-size: 16px"></span></p> </li> <li> <pre class="brush:python;toolbar:false">wget https://github.com/downloads/nathanmarz/storm/storm-0.8.1.zip</pre> </li> </ol> <p>2. 解压到安装目录下:</p> <pre class="brush:python;toolbar:false">unzip storm-0.8.1.zip</pre> <p>2.4 修改storm.yaml配置文件</p> <p>Storm发行版本解压目录下有一个conf/storm.yaml文件,用于配置Storm。默认配置在这里可以查看。conf/storm.yaml中的配置选项将覆盖defaults.yaml中的默认配置。以下配置选项是必须在conf/storm.yaml中进行配置的:</p> <p>1) <span style="padding: 0px">storm.zookeeper.servers</span>: Storm集群使用的Zookeeper集群地址,其格式如下:</p> <pre class="brush:python;toolbar:false">storm.zookeeper.servers: - “111.222.333.444″ - “555.666.777.888″</pre> <p>如果Zookeeper集群使用的不是默认端口,那么还需要<span style="padding: 0px">storm.zookeeper.port选项</span>。</p> <p>2) <span style="padding: 0px">storm.local.dir</span>: Nimbus和Supervisor进程用于存储少量状态,如jars、confs等的本地磁盘目录,需要提前创建该目录并给以足够的访问权限。然后在storm.yaml中配置该目录,如:</p> <pre class="brush:python;toolbar:false">storm.local.dir: "/home/admin/storm/workdir"</pre> <p>3) <span style="padding: 0px">java.library.path</span>: Storm使用的本地库(ZMQ和JZMQ)加载路径,默认为”/usr/local/lib:/opt/local/lib:/usr/lib”,一般来说ZMQ和JZMQ默认安装在/usr/local/lib 下,因此不需要配置即可。</p> <p>4) <span style="padding: 0px">nimbus.host</span>: Storm集群Nimbus机器地址,各个Supervisor工作节点需要知道哪个机器是Nimbus,以便下载Topologies的jars、confs等文件,如:</p> <pre class="brush:python;toolbar:false">nimbus.host: "111.222.333.444"</pre> <p>5) <span style="padding: 0px">supervisor.slots.ports</span>: 对于每个Supervisor工作节点,需要配置该工作节点可以运行的worker数量。每个worker占用一个单独的端口用于接收消息,该配置选项即用于定义哪些端口是可被worker使用的。默认情况下,每个节点上可运行4个workers,分别在6700、6701、6702和6703端口,如:</p> <pre class="brush:python;toolbar:false">supervisor.slots.ports: - 6700 - 6701 - 6702 - 6703</pre> <p>这个脚本文件写的不咋地,所以在配置时一定注意在每一项的开始时要加空格,冒号后也必须要加空格,否则storm就不认识这个配置文件了,切记切记。</p> <h3>2.5 启动Storm各个后台进程</h3> <p>最后一步,启动Storm的所有后台进程。和Zookeeper一样,Storm也是快速失败(fail-fast)的系统,这样Storm才能在任意时刻被停止,并且当进程重启后被正确地恢复执行。这也是为什么Storm不在进程内保存状态的原因,即使Nimbus或Supervisors被重启,运行中的Topologies不会受到影响。</p> <p>以下是启动Storm各个后台进程的方式:</p> <ol class=" list-paddingleft-2"> <li> <p><span style="padding: 0px">Nimbus</span>: 在Storm主控节点上运行”bin/storm nimbus >/dev/null 2>&1 &”启动Nimbus后台程序,并放到后台执行;</p> </li> <li> <p><span style="padding: 0px">Supervisor</span>: 在Storm各个工作节点上运行”bin/storm supervisor >/dev/null 2>&1 &”启动Supervisor后台程序,并放到后台执行;</p> </li> <li> <p><span style="padding: 0px">UI</span>: 在Storm主控节点上运行”bin/storm ui >/dev/null 2>&1 &”启动UI后台程序,并放到后台执行,启动后可以通过http://{nimbus host}:8080观察集群的worker资源使用情况、Topologies的运行状态等信息。</p> </li> </ol> <p><span style="padding: 0px">注意事项:</span></p> <pre class="brush:python;toolbar:false">启动Storm后台进程时,需要对conf/storm.yaml配置文件中设置的storm.local.dir目录具有写权限。 Storm后台进程被启动后,将在Storm安装部署目录下的logs/子目录下生成各个进程的日志文件。 经测试,Storm UI必须和Storm Nimbus部署在同一台机器上,否则UI无法正常工作,因为UI进程会检查本机是否存在Nimbus链接。 为了方便使用,可以将bin/storm加入到系统环境变量中。</pre> <p>至此,Storm集群已经部署、配置完毕,可以向集群提交拓扑运行了。</p> <p class="headline-1 bk-sidecatalog-title"><span style="line-height: 36px;font-size: 22px"><strong>3. 安装storm出现的问题</strong></span></p> <p></p> <p>1、 修复/lib/ld-linux.so.2: bad ELF interpreter: No such file or directory问题<br /> 在64系统里执行32位程序如果出现/lib/ld-linux.so.2: <br /> bad ELF interpreter: No such file or directory,安装下glic即可<br />sudo yum install glibc.i686<br /><span style="font-family: Arial;line-height: 26px">*</span><span style="font-family: Arial;line-height: 26px">注意在安装uuid-dev的时候不同系统安装的名称不一样,使用centeros的同学需要安装yum install libuuid-devel,ubuntu的同学可以直接安装uuid-dev : apt-get install uuid-dev</span></p> <p>2、安装 安装ZMQ 2.1.7<br /> ./autogen.sh <br />1)、configure: error: cannot link with -luuid, install uuid-dev.<br />yum install uuid uuid-devel <br />安装后还是错误。<br />解决办法 :<br />libuuid is part of the util-linux-ng package since version 2.15.1 and is available from <br /> ftp://ftp.kernel.org/pub/linux/utils/util-linux/v2.21/util-linux-2.21.1.tar.gz <br />安装了 util-linux-2.21.1.tar.gz 后, 就OK了。</p> <p>2)、./autogen.sh 安装缺少libtool:<br /> yum install libtool<br /> <br /> 3、安装 jzmq :</p> <p>1)configure 前 <br />export CPPFLAGS=-I/usr/local/zeromq-2.1.7/include/<br />export LDFLAGS=-L/usr/local/zeromq-2.1.7/lib/<br />否则报:configure: error: cannot find zmq.h</p> <p>2)报错<br />configure: error: cannot link with -lzmq</p> <p>指定CC路径就好了:<br />./configure CC=/usr/bin/gcc</p> <p>4、error while loading shared libraries: libz.so.1: <br />cannot open shared object file: No such file or directory<br />sudo yum install zlib.i686 </p> <p>5、启动zookeeper找不到主机: 在这个例子里面 主机名是T214.joy.cc,在 /etc/sysconfig/network定义的主机名,我们需要</p> <p>使用加入到hosts文件></p> <p>192.168.1.214 T214.joy.cc</p> <p>2013-07-09 13:59:20 supervisor [ERROR] Error on initialization of server mk-supervisor<br />java.net.UnknownHostException: T214.joy.cc: T214.joy.cc<br /> at java.net.InetAddress.getLocalHost(InetAddress.java:1454)<br /> at backtype.storm.util$local_hostname.invoke(util.clj:153)<br /> at backtype.storm.daemon.supervisor$supervisor_data.invoke(supervisor.clj:180)<br /> at backtype.storm.daemon.supervisor$fn__4733$exec_fn__1207__auto____4734.invoke(supervisor.clj:324)<br /> at clojure.lang.AFn.applyToHelper(AFn.java:167)<br /> at clojure.lang.AFn.applyTo(AFn.java:151)<br /> at clojure.core$apply.invoke(core.clj:601)<br /> at backtype.storm.daemon.supervisor$fn__4733$mk_supervisor__4758.doInvoke(supervisor.clj:320)<br /> at clojure.lang.RestFn.invoke(RestFn.java:436)<br /> at backtype.storm.daemon.supervisor$_launch.invoke(supervisor.clj:467)<br /> at backtype.storm.daemon.supervisor$_main.invoke(supervisor.clj:494)<br /> at clojure.lang.AFn.applyToHelper(AFn.java:159)<br /> at clojure.lang.AFn.applyTo(AFn.java:151)<br /> at backtype.storm.daemon.supervisor.main(Unknown Source)<br />2013-07-09 13:59:20 util [INFO] Halting process: ("Error on initialization")</p> <p>6、防火墙的问题:</p> <p>hadoop集群环境(linux系统)中最好关闭防火墙,不然会出现很多问题,例如namenode找不到datanode等。</p> <p>如果不关闭防火墙,客户端使用API操作HDFS以及ZooKeeper,可能就会出现下面常见的两种异常:</p> <p>1.使用API操作HDFS时会出现异常:java.net.NoRouteToHostException: No route to host</p> <p>2.使用API操作ZK时会出现异常:org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for xxxx</p> <p> </p> <p>解决方法:</p> <p>查看防火墙是否开启:</p> <p>service iptables status</p> <p>使用root权限登陆后,输入关闭防火墙命令,每个运行hadoop和zk的都要关(两条命令任选一个):</p> <p>/etc/init.d/iptables stop</p> <p>service iptables stop</p> <p></p> <p></p> <p>25489 supervisor<br />25537 Jps<br />19035 QuorumPeerMain<br />[root@T206 logs]# </p> <p>[root@T214 storm-0.8.1]# jps<br />8084 nimbus<br />8060 core<br />21615 ZooKeeperMain<br />21586 QuorumPeerMain<br />8216 Jps<br />[root@T214 storm-0.8.1]# </p> <p class="headline-1 bk-sidecatalog-title"><span style="line-height: 36px;font-size: 22px"><strong>4. 向集群提交任务</strong></span></p> <p><span style="line-height: 18px"> </span>Github里有一个例子叫做storm_starter,我们可以用它来做测试。</p> <p>按照http://github.com/nathanmarz/storm-starter,执行这个程序需要用lein,我们用eclipse代替lein。打包后进行上传。</p> <p>使用maven或lein解决storm-starter的包依赖问题,但是由于GFW原因,可能有些依赖包无法获取。故这里采用eclipse自导入包的方法来编译storm-starter.</p> <p>1)下载twitter4j :twitter4j-2.2.6.zip和storm-starter-master.zip</p> <p></p> <p>2) 追加源文件storm-start/src/jvm/storm<br /> 使用eclipse建立java project。追加twitter4j和storm的jar文件。<br /> File-> New -> Java Project ->随便取个名字-> Next -> Libraries -> add External JARs…-> 追加twitter4j和storm的jar文件(</p> <p> /path/to/twitter4j/lib/*.jar</p> <p> /path/to/storm/lib/*.jar</p> <p> /path/to/storm/storm-{version}.jar)</p> <p></p> <p> -> Finsh</p> <p> 或者可以在建java 项目完成后添加twitter4j和storm的jar文件:</p> <p> 项目名-> 右键->properties->java build path->Libraries -> add External JARs->追加twitter4j和storm的jar文件</p> <p></p> <p> 导入storm-start<br /> File -> Import -> General -> File System -> Next -> Browse(From directory) -> /path/to/storm-start/src/jvm/storm -> Browse(Info floder) -> xxx -> src -> OK -> “storm” 和 “Create top-level folder”前打勾 -> Finish</p> <p></p> <p>3) 追加源文件storm-start/multilang/resources(python 文件word count用)<br /> File -> Import -> General -> File System -> Next -> Browse(From directory) -> /path/to/storm-start/multilang/resources -> Browse(Info floder) -> xxx -> OK -> check “resources” and “Create top-level folder” -> Finish<br />2个源文件都追加好之后,eclipse左边显示如下图:</p> <p><img src="//cto.wang/usr/uploads/2016/07/20160703155945-83.jpg" title="1428121929473366.jpg" alt="1.jpg" /></p> <p>如果使用的是storm-0.8.1,下面这行代码会报错,下载0.8.2版本即可解决</p> <pre class="brush:python;toolbar:false">import backtype.storm.task.IMetricsContext;</pre> <p>如果下面这行报错,说明没有commons-collections.jar包,下载地址:http://commons.apache.org/proper/commons-collections/download_collections.cgi</p> <pre class="brush:python;toolbar:false">import org.apache.commons.collections.buffer.CircularFifoBuffer;</pre> <p>最下载稳定包:commons-collections-3.2.1-bin,解压后追加commons-collections-3.2.1.jar文件就ok:</p> <p></p> <p> 项目名-> 右键->properties->java build path->Libraries -> add External JARs->commons-collections-3.2.1.jar</p> <p></p> <p></p> <p>4) JAR export<br /> File -> Export -> JAR -> JAR file -> 取消 “.classpath” ,“.project” 和 “<.settings” ->的勾 browse -> path/to/export/name.jar -> Finish (忽视 warnings)</p> <p>可能会报错说PrintSampleStream和TwitterSampleSpout这两个类找不到,将这两个类的注释取消掉即可。<br /><img src="//cto.wang/usr/uploads/2016/07/20160703155945-65.jpg" title="1428122025110473.jpg" alt="1.jpg" /></p> <h1>Storm-starter<span style="font-family: 宋体">本地运行</span></h1> <p><span style="font-family: 宋体">这里我们测试</span>Storm-starter<span style="font-family: 宋体">项目的</span>wordCount<span style="font-family: 宋体">,依然用我们打包好的storm-test.jar 。通过阅读源码我们可以知道,WordCountTopology在编写的时候如果在命令后不加参数,则是一个本地模式的WordCount,而如果有一个参数,也就是集群上的计算拓扑(Topology)名,它就会是一个在集群上跑的计算拓扑。。这里我们首先介绍本地运行</span></p> <pre class="brush:bash;toolbar:false"># storm jar storm-test.jar storm.starter.WordCountTopology</pre> <p>如果出现下面的文字,说明运行成功了;</p> <pre class="brush:bash;toolbar:false"># storm jar storm-test.jar storm.starter.WordCountTopology13973 [Thread-34] INFO backtype.storm.daemon.executor - Processing received message source: spout:10, stream: default, id: {}, [snow white and the seven dwarfs]13974 [Thread-32] INFO backtype.storm.daemon.task - Emitting: split default ["snow"]13974 [Thread-26] INFO backtype.storm.daemon.executor - Processing received message source: spout:8, stream: default, id: {}, [an apple a day keeps the doctor away]13975 [Thread-32] INFO backtype.storm.daemon.task - Emitting: split default ["white"]13976 [Thread-28] INFO backtype.storm.daemon.task - Emitting: split default ["a"]13976 [Thread-22] INFO backtype.storm.daemon.executor - Processing received message source: split:6, stream: default, id: {}, ["a"]13976 [Thread-22] INFO backtype.storm.daemon.task - Emitting: count default [a, 34]13977 [Thread-32] INFO backtype.storm.daemon.task - Emitting: split default ["and"]13977 [Thread-22] INFO backtype.storm.daemon.executor - Processing received message source: split:7, stream: default, id: {}, ["and"]13977 [Thread-22] INFO backtype.storm.daemon.task - Emitting: count default [and, 64]13978 [Thread-28] INFO backtype.storm.daemon.task - Emitting: split default ["day"]13978 [Thread-20] INFO backtype.storm.daemon.executor - Processing received message source: split:6, stream: default, id: {}, ["day"]13978 [Thread-20] INFO backtype.storm.daemon.task - Emitting: count default [day, 34]13979 [Thread-32] INFO backtype.storm.daemon.task - Emitting: split default ["the"]13979 [Thread-20] INFO backtype.storm.daemon.executor - Processing received message source: split:7, stream: default, id: {}, ["the"]13979 [Thread-20] INFO backtype.storm.daemon.task - Emitting: count default [the, 134]13917 [Thread-17] INFO backtype.storm.util - Async loop interrupted!13985 [Thread-32] INFO backtype.storm.daemon.task - Emitting: split default ["seven"]13986 [Thread-28] INFO backtype.storm.daemon.task - Emitting: split default ["keeps"]13988 [Thread-28] INFO backtype.storm.daemon.task - Emitting: split default ["the"]13988 [Thread-20] INFO backtype.storm.daemon.executor - Processing received message source: split:6, stream: default, id: {}, ["the"]13988 [Thread-20] INFO backtype.storm.daemon.task - Emitting: count default [the, 135]13989 [Thread-32] INFO backtype.storm.daemon.task - Emitting: split default ["dwarfs"]13989 [Thread-22] INFO backtype.storm.daemon.executor - Processing received message source: split:7, stream: default, id: {}, ["dwarfs"]13989 [Thread-22] INFO backtype.storm.daemon.task - Emitting: count default [dwarfs, 29]13990 [Thread-28] INFO backtype.storm.daemon.task - Emitting: split default ["doctor"] 13991 [Thread-28] INFO backtype.storm.daemon.task - Emitting: split default ["away"]</pre> <p>问题:</p> <pre class="brush:bash;toolbar:false">运行bin/storm jar storm-test.jar storm.starter.WordCountTopology报错: Exception in thread "main" java.lang.UnsupportedClassVersionError: Filter(Unsupported major.minor version 50.0).</pre> <p>解决:</p> <p>1)可能是java的版本和javac不一致。</p> <p>java -version和javac -version看看版本是否一致</p> <p>解决的方法在PATH 最前面加上 $JAVA_HOME:$PATH</p> <p><span style="line-height: 21px"></span></p> <pre class="brush:bash;toolbar:false">vi /etc/profile JAVA_HOME=/usr/java/jdk1.6.0_13/CLASSPATH=.:$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/dt.jar:PATH=$JAVA_HOME/bin:$PATH:$HOME/bin</pre> <p>2)解决Unsupported major.minor version 51.0错误</p> <p>这个因为你的eclipse使用java 1.7JDK编译class文件(导出的storm-test.jar),而安装storm的机器上安装的JDK是1.6</p> <p>解决:打开eclipse中项目上的属性—java compiler–选择一个合适的版本后重新编译即可。</p> <p>具体步骤</p> <p>解决:项目——>右键——>属性——>Java Compiler——>Compiler Compliance Level——>选择你使用的JDK版本-(1.6)—–>应用。</p> <h1>向集群提交任务</h1> <ol class=" list-paddingleft-2"> <li> <p>启动Storm Topology:其中,allmycode.jar是包含Topology实现代码的jar包,org.me.MyTopology的main方法是Topology的入口,arg1、arg2和arg3为org.me.MyTopology执行时需要传入的参数。</p> </li> </ol> <pre class="brush:bash;toolbar:false">storm jar allmycode.jar org.me.MyTopology arg1 arg2 arg3</pre> <p>2. 停止Storm Topology:</p> <pre class="brush:python;toolbar:false">storm kill {toponame}</pre> <p>其中,{toponame}为Topology提交到Storm集群时指定的Topology任务名称。</p> <h2>3.4 参考资料</h2> <p>https://github.com/nathanmarz/storm/</p> <p>https://github.com/nathanmarz/storm/wiki</p> <p>https://github.com/nathanmarz/storm/wiki/Setting-up-development-environment</p> <p>https://github.com/nathanmarz/storm-starter/</p> <p>Twitter Storm下载中文镜像<br />Twitter Storm: 配置开发环境</p> <p>Storm集群安装部署步骤【详细版】</p> <p>centos的twitter storm安装和storm-start的本地运行</p> <p>Storm 环境配置及Storm starter运行</p> <p>Storm环境部署</p> <p></p> <p>此文通过亲身体验和总结网上资料</p> 最后修改:2021 年 12 月 10 日 10 : 53 AM © 允许规范转载 赞赏 如果觉得我的文章对你有用,请随意赞赏 赞赏作者 支付宝微信