系统架构
2022-04-17 15:32:22 6 举报
登录查看完整内容
系统总体架构
作者其他创作
大纲/内容
1、Source:exec，监听生成数据2、Channel:MemoryChannel3、Sink：KafkaSink
1、HBaseUtil（建表，预分区等）2、HBaseDAO（保存数据的规则）3、消费数据到HBase存储
六、Web（前端展示）
五、MapReduce（分析业务指标）
一、生产数据（produceLog）
三、Kafka（消息队列）
使用SpringBoot+ECharts将MySQL中存储的数据展示到前端页面
二、Flume（exec-kafka）
1、随机生成电话号（主被叫）2、随机生成通话建立时间3、随机生成通话时长（30min内）4、随机生成通话内容（考研方面信息）5、生成日志写入文件，2条/s
1、从HBase读取数据2、Mapper分析6个维度指标3、Reducer聚合6个维度指标4、自定义OutPut将数据写入MySQL
1、控制台消费者测试2、IDEA消费者直接打印数据
四、Hbase（消费数据存储）
0 条评论
回复 删除
下一页
