我需要每天处理大量用户列表，以便根据某些情况向他们发送电子邮件和SMS通知。我为此使用Java EE批处理模型。我的Job xml如下：

<step id="sendNotification">
    <chunk item-count="10" retry-limit="3">
        <reader ref="myItemReader"></reader>
        <processor ref="myItemProcessor"></processor>
        <writer ref="myItemWriter"></writer>
        <retryable-exception-classes>
            <include class="java.lang.IllegalArgumentException"/>
        </retryable-exception-classes>
    </chunk>
</step>

MyItemReader的onOpen方法从数据库中读取所有用户，而readItem（）使用列表迭代器一次读取一个用户。在myItemProcessor中，实际的电子邮件通知发送给用户，然后将用户保留在该块的myItemWriter类中的数据库中。

@Named
public class MyItemReader extends AbstractItemReader {

    private Iterator<User> iterator = null;
    private User lastUser;

    @Inject
    private MyService service;

    @Override
    public void open(Serializable checkpoint) throws Exception {
        super.open(checkpoint);

        List<User> users = service.getUsers();
        iterator = users.iterator();

        if(checkpoint != null) {
            User checkpointUser = (User) checkpoint;
            System.out.println("Checkpoint Found: " + checkpointUser.getUserId());
            while(iterator.hasNext() && !iterator.next().getUserId().equals(checkpointUser.getUserId())) {
                System.out.println("skipping already read users ... ");
            }
        }
    }

    @Override
    public Object readItem() throws Exception {

        User user=null;

        if(iterator.hasNext()) {
            user = iterator.next();
            lastUser = user;
        }
        return user;
    }

    @Override
    public Serializable checkpointInfo() throws Exception {
        return lastUser;
    }
}

我的问题是检查点存储了在上一个块中执行的最后一条记录。如果我的下一个10个用户中有一个大块，并且第5个用户的myItemProcessor中引发了异常，则在重试时将执行整个块，并再次处理所有10个用户。我不希望将通知再次发送给已处理的用户。

有办法解决吗？应该如何有效地做到这一点？

任何帮助将不胜感激。谢谢。