104-storm 整合 kafka之保存MySQL数据库(3/3)

本篇文章主要介绍了"104-storm 整合 kafka之保存MySQL数据库"，主要涉及到Exception,zookeeper方面的内容，对于MySql感兴趣的同学可以参考一下： 整合KafkaStorm，消息通过各种方式进入到Kafka消息中间件，比如通过使用Flume来收集的日志数据，然后暂由Kafka中的路由暂存，然后在由实时计算程...

if (m.find()) {
     url = m.group(1);
     usetime = m.group(2);
     currentTime = m.group(3);
     System.out.println(url + "->" + usetime + "->" + currentTime);

     MyDbUtils.update(MyDbUtils.INSERT_LOG, url, usetime,
               MyDateUtils.formatDate2(new Date(Long.parseLong(currentTime))));
}

（4）统计指标

--统计每个url平均响应时间
SELECT
  topdomain,
  ROUND(AVG(usetime) / 1000, 2) avg_use_time
FROM
  log_info
GROUP BY topdomain;

以上就介绍了104-storm 整合 kafka之保存MySQL数据库，包括了Exception,zookeeper方面的内容，希望对MySql有兴趣的朋友有所帮助。

本文网址链接：http://www.codes51.com/article/detail_187461_3.html