一、JDK安装:
1. 下载JDK(版本7):http://download.oracle.com/otn-pub/java/jdk/7u71-b14/jdk-7u71-linux-x64.rpm
2. 安装
sudo rpm -ivh jdk-7u71-linux-x64.rpm
sudo vi /etc/profile
export JAVA_HOME=/usr/java/jdk1.7.0_71 export PATH=$JAVA_HOME/bin:$PATH export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
source /etc/profile
二、Zookeeper安装
1. 下载并解压安装Zookeeper:http://zookeeper.apache.org/releases.html
2. Zookeeper集群部署:
根据Zookeeper集群节点情况,在conf目录下创建Zookeeper配置文件zoo.cfg(示例如下)
tickTime=2000 initLimit=10 syncLimit=5 dataDir=/opt/zookeeper-3.4.6/data clientPort=2181 server.1=ip1:2888:3888 server.2=ip2:2888:3888 server.3=ip3:2888:3888
三、storm 0.9.3安装
1. 下载安装包:http://www.apache.org/dyn/closer.cgi/storm/apache-storm-0.9.3/apache-storm-0.9.3.tar.gz
2. 解压缩安装包到安装目录
3. 修改conf目录下的配置文件storm.yaml
storm.yaml示例
storm.zookeeper.servers: - "zk-host1" - "zk-host2" - "zk-host3" storm.zookeeper.port: 2181 storm.zookeeper.root: "/storm-0.9.3" storm.local.dir: "/opt/apache-storm-0.9.3/storm-local" storm.cluster.mode: distributed storm.messaging.netty.server_worker_threads: 1 storm.messaging.netty.client_worker_threads: 1 storm.messaging.transport: "backtype.storm.messaging.netty.Context" storm.messaging.netty.buffer_size: 52428800 storm.messaging.netty.max_retries: 10 storm.messaging.netty.min_wait_ms: 5000 storm.messaging.netty.max_wait_ms: 10000 logviewer.port: 80 logviewer.appender.name: "A1" nimbus.host: "host-ip1" worker.childopts: "-Xmx1024m -Xms1024m -Xmn500m -XX:+UseConcMarkSweepGC -XX:+UseParNewGC -XX:+UseConcMarkSweepGC -XX:NewSize=128m -XX:CMSInitiatingOccupancyFraction=70 -XX:-CMSConcurrentMTEnabled -Djava.net.preferIPv4Stack=true" supervisor.slots.ports: - 6700 - 6701 - 6702 topology.debug: false topology.executor.receive.buffer.size: 16384 topology.executor.send.buffer.size: 16384
注:如果与其他storm集群共用zk,请确认不同的集群使用各自不同的“storm.zookeeper.root”设置,默认为:"/storm"
4. 启动
在nimbus机器执行(cd $STORM_HOME)
bin/storm nimbus >/dev/null 2>&1 & bin/storm ui >/dev/null 2>&1 &
在supervisor机器执行(cd $STORM_HOME):
bin/storm supervisor> /dev/null 2>&1 & bin/storm logviewer > /dev/null 2>&1 &
相关推荐
Apache Storm(apache-storm-2.3.0.tar.gz) 是一个免费的开源分布式实时计算系统。Apache Storm 可以轻松可靠地处理无限制的数据流,实时处理就像 Hadoop 进行批处理一样。Apache Storm 很简单,可以与任何编程语言...
Apache Storm(apache-storm-2.3.0-src.tar.gz 源码) 是一个免费的开源分布式实时计算系统。Apache Storm 可以轻松可靠地处理无限制的数据流,实时处理就像 Hadoop 进行批处理一样。Apache Storm 很简单,可以与...
实时计算:Apache Storm:ApacheStorm实时机器学习应用.docx
主分支: ##包裹包战 mvn clean package -DskipTests=true -Dwarcp ./target/storm-ui.war $TOMCAT_HOME/webapps/包装罐 mvn clean package -DskipTests=truecp ./target/storm-ui-*.jar $STORM_HOME/external/...
文件名: apache-storm-2.4.0.tar.gz.zip 这是 Apache Storm 2.4.0 的安装包,Storm 是一个免费开源...这个安装包包含了所有你需要安装和运行 Apache Storm 2.4.0 的文件。请确保在下载后按照官方文档进行安装和配置。
Apache Storm 是一个强大的开源分布式实时计算系统,它允许开发者处理无界数据流,提供低延迟且高吞吐量的数据处理能力。与Hadoop等批处理系统不同,Storm专注于实时处理,能够在数据产生的瞬间进行分析和处理,从而...
Apache Storm(apache-storm-2.3.0.zip) 是一个免费的开源分布式实时计算系统。Apache Storm 可以轻松可靠地处理无限制的数据流,实时处理就像 Hadoop 进行批处理一样。Apache Storm 很简单,可以与任何编程语言...
Apache Storm(apache-storm-2.3.0-src.zip 源码) 是一个免费的开源分布式实时计算系统。Apache Storm 可以轻松可靠地处理无限制的数据流,实时处理就像 Hadoop 进行批处理一样。Apache Storm 很简单,可以与任何...
在标签中,"storm 安装包" 暗示了这个文件的用途,即它是 Apache Storm 的安装或部署资源,用户可以通过解压并按照特定步骤安装来在自己的环境中使用 Storm。 压缩包子文件的文件名称 "apache-storm-2.4.0" 暂时...
在标题中提到的 "apache-storm-1.0.2.tar.gz" 是 Apache Storm 的特定版本,即1.0.2,以 tar.gz 形式打包,这种格式常见于 Linux 系统,方便用户下载、解压和安装。 1. **Apache Storm 简介**: Apache Storm 是一...
Apache Storm是一个分布式实时计算系统,它允许用户定义复杂的流处理逻辑,可以连续处理无界数据流,具有高容错性和可扩展性。源码分析对于理解其内部工作原理、优化性能以及开发自定义组件至关重要。Apache Storm ...
在安装和部署Apache Storm 2.1.0时,你需要解压此压缩包,然后配置相关环境变量,包括STORM_HOME、JAVA_HOME等。之后,你可以通过Nimbus节点启动和管理拓扑,或者通过Supervisor节点运行任务。Storm还支持本地模式,...
实时计算:Apache Storm:ApacheStorm开发环境搭建.docx
安装和部署Storm时,用户需要将解压后的目录复制到合适的位置,并根据自己的环境配置conf目录下的配置文件。然后,通过bin目录下的脚本启动Nimbus(集群协调器)、Supervisor(节点管理器)和其他服务。开发人员可以...
实时计算:Apache Storm:ApacheStorm架构与组件详解.docx
实时计算:Apache Storm:ApacheStorm实时分析案例研究.docx
实时计算:Apache Storm:ApacheStorm的高级编程技巧.docx
实时计算:Apache Storm:ApacheStorm基本概念与术语.docx
实时计算:Apache Storm:ApacheStorm数据流模型解析.docx