实时即未来，大数据项目车联网之创建Flink实时计算子工程【二】

写在前面

车联网项目全新升级

更全 8-》21+篇
更细 -》 图文并茂、部分代码首次披露
更新 -》Flink车联网项目贴近企业开发

售后更有保障：

凡购买本专栏的读者，可加我好友获取车联网大数据资料

文章持续更新不止21篇，保障更新完整。前期49.9元，后期满50人恢复原价99元

创建Flink实时计算子工程

1 在原工程下创建实时分析子模块

总工程结构设计

创建StreamingAnalysis工程

设置打包类型为：jar

2 导入实时分析子模块pom依赖

略

l 工程包目录

3 配置实时分析子模块资源文件

conf.properties

# mysql configuration
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://node03:3306/vehicle_networking?characterEncoding=utf8&useSSL=false
jdbc.user=root
jdbc.password=123456
jdbc.dataSource.size=10

# hdfsUri
hdfsUri=hdfs://node01:8020

#ZK configuration
zookeeper.clientPort=2181
zookeeper.quorum=node01,node02,node03

# kafka configuration
kafka.topic=vehicledata
bootstrap.servers=node01:9092,node02:9092,node03:9092

# mongoDB configuration
mongo.host=node03
mongo.port=27017
mongo.userName=itcast
mongo.password=itcast
mongo.source=itcast

# redis configuration
redis.host=node03
redis.port=6379
redis.password=null
redis.database=0
redis.session.timeout=1000
redis.key.timeout=900

# vehinfo match sleep millionseconds
vehinfo.millionseconds=18000000
ruleinfo.millionseconds=100000
elerules.millionseconds=300000
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

logback.xml

注意log4j的jar包冲突问题

<configuration>
    
    
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
        
        <encoder>
            <pattern>%date %level [%thread] %logger{10} [%file:%line] %msg%npattern>
        encoder>
    appender>
    
    <logger name="com.john.logging.b" level="INFO" additivity="false">
        <appender-ref ref="STDOUT" />
    logger>

    
    <appender name="FILE" class="ch.qos.logback.core.FileAppender">
        <file>debug.logfile>
        <encoder>
            <pattern>%date %level [%thread] %logger{10} [%file:%line] %msg%npattern>
        encoder>
    appender>

    
    <root level="DEBUG">
        <appender-ref ref="STDOUT" />
        <appender-ref ref="FILE" />
    root>
configuration>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30