一种计数方法及计数系统

本发明实施例公开了一种计数方法及计数系统，用于快速完成计数与存储功能，并实现消费速度的动态扩容与收缩。本发明实施例方法包括：计数系统根据kafka或RocketMQ获取消费数据；判断预置的阻塞队列是否被填充满；若阻塞队列被填充满，则将消费数据发送至临时文件中；根据第一异步客户端以及阻塞队列中的消费数据的类型，采用异步的方式将第一消费数据写入重申redis中，得到第一计数；通过***监听临时文件中的数据消费程度；根据数据消费程度动态调整***中线程的线程个数；根据第二异步客户端以及临时文件中的消费数据的类型，采用异步的方式将第二消费数据写入redis中，得到第二计数；根据第一计数以及第二计数确定目标计数。