flink 项目实战案例之电商订单实时分析业务介绍

flink 项目实战案例之电商订单实时同步业务介绍

第一部分: flink 入门demo

配置一个maven项目
编写一个flink程序

1.1 配置一个maven项目

<dependencies>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-java</artifactId>
        <version>${flink.version}</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-streaming-java_2.11</artifactId>
        <version>${flink.version}</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-clients_2.11</artifactId>
        <version>${flink.version}</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-connector-wikiedits_2.11</artifactId>
        <version>${flink.version}</version>
    </dependency>
</dependencies>
--------------------- 

 

第二部分: flink项目实战

上个月项目组用flink 做了一个大数据的项目, 主要功能就是实现电商订单分析
数据量每秒钟有5万的大小.

基本上这个思路拿到任何处理订单的场景都可以使用. 

开发环境为: Flink1.6.1 , Hadoop2.6.0, Hbase1.0.0, Hive1.1.0

这个项目中主要有几大功能:

第一部分为: flink分析网站的PV,UV.以及用户的访问状态.
这个用的是MR

第二部分: flink分析网站频道的新鲜度

第三部分: flink 分析用户浏览地区分布

第四部分: flink 用户网络分析

第五部分: flink batch 实现产品成交订单分析

第六部分: flink table 订单分析

这几个功能都是用 hadoop  hbase, hive sqoop ,spring cloud 组合构建的.非常适合大数据开发者入门实战.
现在大数据业务基本是flink天下. 

现在把项目源码分享给大家,项目重要的部分录制了视频. 用了2天时间整理源码,希望得到大家的支持.
打赏链接