我有一个带阅读器/处理器/写入器的 spring 批次 . 哪作得很好 . 新的要求是处理器应该只处理1或2个消息,并根据服务器中的负载休眠1或2秒(我的项目处理器调用第三方API发送一些数据,第三方调用不应该是连续的) .

我已经实现了chunk监听器,但我无法识别如何读取消息/ item-process调用,chunklistener“readcount”返回以增量方式处理的消息数 .

paramChunkContext.getStepContext().getStepExecution().getReadCount() //chunkcontext

我想到的一个选择是划分chunkcount / 2并基于返回(如果返回为0 - 休眠1秒) . 然后

thread.sleep(1000) //

还有其他更好的方法来执行此操作吗?上面的过程是一个肮脏的工作 .