1 ，你 1 分钟收到 2000 条数据
2 ，你需要进行分类，每个分类有不同的处理方式，转成不同的报文
3 ，上游一次只能接收一条数据
4 ，上游处理数据很慢

问题，
1 ，在线率是什么
2 ，处理任务的程序是指你写的这个程序么，为什么要一直重启

根据现有信息，整理的方案如下
1 ，下游客户端给你提供数据，你直接入库
2 ，你的程序直接去数据库获取，一次性获取一条
3 ，按照分类业务，处理成固定的报文，推送给上游，
4 ，如果上游上次未处理完成，你的程序不要做新的推送数据处理，继续等待。