互联网实时计算的方法和系统

摘要

本发明公开了一种互联网实时计算的方法和系统。根据用户在网站上的操作，前端服务器生成指定格式的消息日志并发送所生成的指定格式的消息日志；中心消息日志收发处理单元接收前端服务器发送的消息日志，并根据消息日志的属性，分发消息日志到后端的相应的实时计算模型单元中；实时计算模型单元对接收到的消息日志进行预定的计算，得出实时热点内容排行榜、活跃用户、垃圾消息、非法消息等结果，把计算结果放在内存或者磁盘中，或将结果作为API供其他程序调用。本发明的互联网实时计算的方法和系统没有延时性，能第一时间反应出当前应用的热点，方案包括了数据收集、数据分发、数据分析建模、结果存储以及对外服务，是一个完整的解决方案。

主权项

一种互联网实时计算方法，包括：根据用户在网站上的操作，前端服务器生成指定格式的消息日志并发送所生成的指定格式的消息日志；中心消息日志收发处理单元接收所述前端服务器发送的消息日志，并根据消息日志的属性，分发消息日志到后端的相应的实时计算模型单元中；所述实时计算模型单元对接收到的消息日志进行预定的计算，把计算结果放在内存或者磁盘中，或将结果作为API供其他程序调用。