# SparkStreamingDemand

**Repository Path**: sawa0725/spark-streaming-demand

## Basic Information

- **Project Name**: SparkStreamingDemand
- **Description**: 完整的sparkStreaming项目开发代码记录
- **Primary Language**: Scala
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2023-09-10
- **Last Updated**: 2023-09-17

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# SparkStreamingDemand

#### 开发流程
开发过程中的整体记录在CSDN博客有做记录
https://blog.csdn.net/qq_40607631/category_12435847.html

#### 介绍
完整的sparkStreaming项目开发代码记录

#### 软件架构
productApp 负责生成页面点击日志，实时分发数据到kafka

consumerApp 负责实时从kafka消费数据

采用三层架构开发模式
application--应用层，应用的起始

common--部分类抽象出来的一部分，共通类，多个类的共同代码

controller--控制层，主体流程控制

service --服务层，计算逻辑

dao--持久层主要负责对数据的读取，跟文件、数据库等打交道

util--工具类，在哪儿都能用（字符串判断等）

bean：实体类

流程图：
![输入图片说明](src/%E9%A1%B9%E7%9B%AE%E6%B5%81%E7%A8%8B%E5%9B%BE.png)

#### 安装教程

1.  xxxx
2.  xxxx
3.  xxxx

#### 使用说明

1.  xxxx
2.  xxxx
3.  xxxx

#### 参与贡献

1.  Fork 本仓库
2.  新建 Feat_xxx 分支
3.  提交代码
4.  新建 Pull Request