public interface Processor {

    Email handleEmail(Email email, int nextpos, ArrayList<Processor> processors);

}

public static class Email {

    //处理结果

    String result = "";

}

public static class EmailChain {

    private int pos;

    private ArrayList<Processor> processors;

    public Email email;

    public EmailChain(int pos, Email email, ArrayList<Processor> processors) {

        this.pos = pos;

        this.processors = processors;

        this.email = email;

    }

    //核心方法 每个链条结有一个proceed方法，这个方法决定要不要去链接下一个链条结

    public Email proceed(Email email) {

        if (pos < processors.size()) {

            //如果当前的位置不是最后一个链条结 则获取当前链条结所拥有的处理器

            Processor processor = processors.get(pos);

            //如果能够捕获到处理器，就使用处理器对email进行处理

            Email resultEmail = processor.handleEmail(email, pos + 1, processors);

            return resultEmail;

        } else {

            //否则直接返回 不做处理

            return email;

        }

    }

}

public static class Processor1 implements Processor {

    @Override

    public Email handleEmail(Email email, int nextpos, ArrayList<Processor> processors) {

        //当前处理器可以继续将email交给下一个环扣 等待下一个环扣的反馈，也可以选择拦截处理结果

        // 在这个处理器中，处理器选择优先处理，处理完成后再交接给下一个链条结

        email.result = email.result + " 添加重要性标签";

        EmailChain next = new EmailChain(nextpos, email, processors);

        email = next.proceed(email);

        return email;

    }

}

public static class Processor2 implements Processor {

    @Override

    public Email handleEmail(Email email, int nextpos, ArrayList<Processor> processors) {

        //当前处理器可以继续将email交给下一个环扣 等待下一个环扣的反馈，也可以选择拦截处理结果

        // 在这个处理器中，处理器选择将处理权限优先交给下一个链条结处理，等待返回后自己再处理

        EmailChain next = new EmailChain(nextpos, email, processors);

        email = next.proceed(email);

        email.result = email.result + " 移入指定文件夹" ;

        return email;

    }

}

public static class Processor3 implements Processor {

    @Override

    public Email handleEmail(Email email, int nextpos, ArrayList<Processor> processors) {

        //当前处理器可以继续将email交给下一个环扣 等待下一个环扣的反馈，也可以选择拦截处理结果

        // 在这个处理器中，处理器选择优先处理，处理完成后再交接给下一个链条结

        email.result = email.result + " 添加提醒";

        EmailChain next = new EmailChain(nextpos, email, processors);

        email = next.proceed(email);

        return email;

    }

}

public static void main(String[] args) {

    //定义链式结构及其对应的处理器

    ArrayList<Processor> processors = new ArrayList<>();

    processors.add(new Processor1());

    processors.add(new Processor2());

    processors.add(new Processor3());

    //初始的邮件数据

    Email email = new Email();

    //整个任务 抽象成链条中一个链条结，每个结点中有一个处理器， 环环相扣行成一条链条 链条有多长，其实是由处理器的数量决定的

    //在开始建立这个链条的时候，我们从链条的顶端开始新建链条结 第一个结点的位置就是0

    EmailChain chain = new EmailChain(0, email, processors);

    //邮件服务器 只需要关注从离他最近的第一个环扣中得到处理后的信息

    Email resultEmail = chain.proceed(email);

    System.out.println("finalResult = " + resultEmail.result);

}