源码仓库:这里
- 【run】
- 【analysis】
- channel + redis
- analysis.go - 基于日志流量统计
+--------------------------+ +---------------------+
| | | |
| read log line by line | Channel(logChannel) | logConsumer |
| +----------------------->+ |
+--------------------------+ +---------+-----------+
|
|
| Channel(pvChannel uvChannel ...)
|
|
v
+------------------+-----------------------+
| |
| Counter(pvCounter uvCounter ...) |
| |
+------------------+-----------------------+
|
|
| Channel(storageChannel ...)
|
|
v
+-------------------+--------------------------+
| |
| dataSorage(into Redis/Hbase ...) |
| |
+----------------------------------------------+