这个其实用Java做有点难为人了，数据处理应该用spark框架做