待完成任务⏰😅：

项目架构🍏：

项目功能🍎：

项目启动流程🍐：

1.zookeeper启动：bin/zkServer.sh start查看状态：bin/zkServer.sh status关闭：bin/zkServer.sh stop2.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 recommenderlog: bin/kafka-topics.sh --create --zookeeper linux:2181 --replication-factor 1 --partitions 1 --topic log查看topic：bin/kafka-topics.sh --list --zookeeper wan:2181producer：bin/kafka-console-producer.sh --broker-list linux:9092 --topic recommenderconsumer：bin/kafka-console-consumer.sh --bootstrap-server linux:9092 --topic recommender关闭：bin/kafka-server-stop.sh3.MongoDB启动：bin/mongod -config ./data/mongodb.conf访问：bin/mongo停止：bin/mongod -shutdown -config ./data/mongodb.conf4.Redis启动：redis-server ./redis.conf连接：redis-cli停止：redis-cli shutdown5.Spark启动：sbin/start-all.sh关闭：sbin/stop-all.sh6.Flume启动：./bin/flume-ng agent -c ./conf/ -f ./job/ex4.conf -n a1 -Dflume.root.logger=INFO,console7.Azkaban(调度服务)启动：./bin/azkaban-start.sh8.启动后台服务9.启动实时推荐服务OnlineRecommender10.启动KafkaStreaming服务11.启动前端服务npm run servezookeeper >> 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

后端

前端

推荐服务

任务调度