用户行为数据收集

1. Play ! 作为web服务器，使用RESTful 规范编写接口（客户端事先埋点，然后调用接口上传数据）
2. Play ！接口接受到的记录(json形式)经过处理后，先保存到 concurrentQueue中
3. Play! 启动后，start一个Akka schedulable actor.他每隔一段时间，让子actor去poll queue中的数据
4. 调用flume的封装的rpc，将数据发送到指定的端口。
5. Flume source端接收数据，按照配置重定向数据,sink到console.

a1.channels = c1
a1.sources = r1
a1.sinks = k1

a1.channels.c1.type = memory

a1.sources.r1.channels = c1
a1.sources.r1.type = avro

a1.sources.r1.bind = 0.0.0.0 
a1.sources.r1.port = 41414

a1.sinks.k1.channel = c1
a1.sinks.k1.type = logger 

 1.Play! 运行 
 2.Flume 运行

 bin/flume-ng agent --conf conf --conf-file example.conf --name a1 -Dflume.root.logger=INFO,console