package?com.lyz.storm;

import?org.apache.storm.Config;
import?org.apache.storm.LocalCluster;
import?org.apache.storm.StormSubmitter;
import?org.apache.storm.generated.StormTopology;
import?org.apache.storm.kafka.KafkaSpout;
import?org.apache.storm.kafka.SpoutConfig;
import?org.apache.storm.kafka.ZkHosts;
import?org.apache.storm.topology.TopologyBuilder;

import?com.lyz.storm.bolt.MySplitBolt;
import?com.lyz.storm.bolt.MyWordCountAndPrintBolt;

/**
?*?這個Driver使Kafka、strom、mysql進行串聯起來。
?*
?*?這個代碼執行前需要創建kafka的topic創建代碼如下：
?*?[root@liuyazhuang?kafka]#?bin/kafka-topics.sh?--create?--zookeeper?liuyazhuang1:2181?--replication-factor?1?-partitions?3?--topic?wordCount
?*
?*?接著還要向kafka中傳遞數據，打開一個shell的producer來模擬生產數據
?*?[root@liuyazhuang?kafka]#?bin/kafka-console-producer.sh?--broker-list?liuyazhuang:9092?--topic?wordCount
?*?接著輸入數據
?*
?*?@author?liuyazhuang
?*/
public?class?StormTopologyDriver?{

????public?static?void?main（String[]?args）?throws?Exception?{
????????//1、準備任務信息
????????TopologyBuilder?topologyBuilder?=?new?TopologyBuilder（）;
????????SpoutConfig?spoutConfig?=?new?SpoutConfig（new?ZkHosts（“192.168.209.121:2181“）“wordCount““/wordCount““wordCount“）;
		topologyBuilder.setSpout（“KafkaSpout“new?KafkaSpout（spoutConfig）2）;
????????topologyBuilder.setBolt（“bolt1“new?MySplitBolt（）4）.shuffleGrouping（“KafkaSpout“）;
????????topologyBuilder.setBolt（“bolt2“new?MyWordCountAndPrintBolt（）2）.shuffleGrouping（“bolt1“）;

????????//2、任務提交
????????Config?config?=?new?Config（）;
????????config.setNumWorkers（2）;
????????StormTopology?stormTopology?=?topologyBuilder.createTopology（）;
????????
????????if（args?!=?null?&&?args.length?>?0）{
????????	StormSubmitter.submitTopology（args[0]?config?topologyBuilder.createTopology（））;
????????}else{
????????????//本地模式
????????????LocalCluster?localCluster?=?new?LocalCluster（）;
????????????localCluster.submitTopology（“wordcount“configstormTopology）;
????????}
????????
????}
}

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\
?????文件????????1437??2018-02-24?17:09??storm-kafka-mysql\.classpath
?????文件????????1434??2018-02-24?13:45??storm-kafka-mysql\.project
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\.settings\
?????文件?????????575??2015-07-23?14:04??storm-kafka-mysql\.settings\.jsdtscope
?????文件?????????736??2018-02-24?17:05??storm-kafka-mysql\.settings\org.eclipse.jdt.core.prefs
?????文件??????????90??2015-07-23?14:04??storm-kafka-mysql\.settings\org.eclipse.m2e.core.prefs
?????文件????????1908??2018-02-24?13:45??storm-kafka-mysql\.settings\org.eclipse.wst.common.component
?????文件?????????252??2018-02-24?17:09??storm-kafka-mysql\.settings\org.eclipse.wst.common.project.facet.core.xml
?????文件??????????49??2015-07-23?14:04??storm-kafka-mysql\.settings\org.eclipse.wst.jsdt.ui.superType.container
?????文件???????????6??2015-07-23?14:04??storm-kafka-mysql\.settings\org.eclipse.wst.jsdt.ui.superType.name
?????文件??????????50??2015-07-23?14:04??storm-kafka-mysql\.settings\org.eclipse.wst.validation.prefs
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456363\
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456363\1024\
?????文件?????????116??2018-02-24?15:12??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456363\1024\worker.yaml
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456363\1027\
?????文件?????????116??2018-02-24?15:12??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456363\1027\worker.yaml
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456510\
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456510\1024\
?????文件?????????116??2018-02-24?15:15??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456510\1024\worker.yaml
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456510\1027\
?????文件?????????116??2018-02-24?15:15??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456510\1027\worker.yaml
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456788\
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456788\1024\
?????文件?????????116??2018-02-24?15:19??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456788\1024\worker.yaml
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456788\1027\
?????文件?????????116??2018-02-24?15:19??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456788\1027\worker.yaml
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456930\
?????目錄???????????0??2018-03-04?23:45??storm-kafka-mysql\logs\workers-artifacts\wordcount-1-1519456930\1024\
............此處省略100個文件信息