BookRecommenderSystem
1.0.0
1.zookeeper
启动：bin/zkServer.sh start
查看状态：bin/zkServer.sh status
关闭：bin/zkServer.sh stop
2.kafka
启动：
bin/kafka-server-start.sh -daemon ./config/server.properties
创建两个topic:
recommender: bin/kafka-topics.sh --create --zookeeper linux:2181 --replication-factor 1 --partitions 1 --topic recommender
log: bin/kafka-topics.sh --create --zookeeper linux:2181 --replication-factor 1 --partitions 1 --topic log
查看topic：bin/kafka-topics.sh --list --zookeeper wan:2181
producer：bin/kafka-console-producer.sh --broker-list linux:9092 --topic recommender
consumer：bin/kafka-console-consumer.sh --bootstrap-server linux:9092 --topic recommender
关闭：bin/kafka-server-stop.sh
3.MongoDB
启动：bin/mongod -config ./data/mongodb.conf
访问：bin/mongo
停止：bin/mongod -shutdown -config ./data/mongodb.conf
4.Redis
启动：redis-server ./redis.conf
连接：redis-cli
停止：redis-cli shutdown
5.Spark
启动：sbin/start-all.sh
关闭：sbin/stop-all.sh
6.Flume
启动：
./bin/flume-ng agent -c ./conf/ -f ./job/ex4.conf -n a1 -Dflume.root.logger=INFO,console
7.Azkaban(调度服务)
启动：./bin/azkaban-start.sh
8.启动后台服务
9.启动实时推荐服务OnlineRecommender
10.启动KafkaStreaming服务
11.启动前端服务
npm run serve
zookeeper >> kafka启动，创建topic >> kafkaStream启动 >> 实时推荐程序启动 >> 启动flume
├─src
│ ├─main
│ │ ├─java
│ │ │ └─com
│ │ │ └─wan
│ │ │ ├─Annotation
│ │ │ ├─Configuation
│ │ │ ├─Controller
│ │ │ ├─DAO
│ │ │ ├─Interceptor
│ │ │ ├─Listener
│ │ │ ├─POJO
│ │ │ ├─Result
│ │ │ └─Service
│ │ ├─log
│ │ └─resources
│ └─test
│ └─java
└─target < parent >
< groupId >org.springframework.boot</ groupId >
< artifactId >spring-boot-starter-parent</ artifactId >
< version >2.0.4.RELEASE</ version >
< relativePath /> <!-- lookup parent from repository -->
</ parent >
< dependencies >
< dependency >
< groupId >org.springframework.boot</ groupId >
< artifactId >spring-boot-starter-web</ artifactId >
</ dependency >
< dependency >
< groupId >org.springframework.boot</ groupId >
< artifactId >spring-boot-starter-data-mongodb</ artifactId >
</ dependency >
< dependency >
< groupId >org.springframework.boot</ groupId >
< artifactId >spring-boot-starter-data-redis</ artifactId >
</ dependency >
</ dependencies >
< build >
< plugins >
< plugin >
< groupId >org.springframework.boot</ groupId >
< artifactId >spring-boot-maven-plugin</ artifactId >
< configuration >
< fork >true</ fork >
</ configuration >
</ plugin >
</ plugins >
</ build >├─.dist
├─public
└─src
├─assets
│ └─css
├─components
├─plugins
└─router
├─Dataloader
│ └─src
│ ├─main
│ │ ├─resources
│ │ └─scala
│ │ └─com
│ │ └─wan
│ │ └─recommender
│ └─test
│ └─java
├─KafkaStreaming
│ ├─src
│ │ ├─main
│ │ │ ├─java
│ │ │ │ └─com
│ │ │ │ └─wan
│ │ │ │ └─kafkastreaming
│ │ │ └─resources
│ │ └─test
│ │ └─java
│ └─target
│ ├─classes
│ │ └─com
│ │ └─wan
│ │ └─kafkastreaming
│ └─generated-sources
│ └─annotations
├─OfflineRecommender
│ └─src
│ ├─main
│ │ ├─resources
│ │ └─scala
│ │ └─com
│ │ └─wan
│ │ └─offline
│ └─test
│ └─java
├─OnlineRecommender
│ ├─src
│ │ ├─main
│ │ │ ├─resources
│ │ │ └─scala
│ │ │ └─com
│ │ │ └─wan
│ │ │ └─online
│ │ └─test
│ │ └─java
│ └─target
│ ├─classes
│ │ └─com
│ │ └─wan
│ │ └─online
│ └─generated-sources
│ └─annotations
└─StatisticsRecommender
└─src
├─main
│ ├─resources
│ └─scala
│ └─com
│ └─wan
│ └─statistics
└─test
└─java
