公开 @Asynchronous 函数的当前进度以在视图中使用

Question

在我的 JEE6-App（在 Glassfish 3.0.1 上运行）中，我有一个 EmailEJB，它必须发送大量邮件。邮件是异步发送的，因此它使用新的 EJB3.1 @Asynchronous 进行注释，让它在单独的线程中运行。现在我希望用户了解该方法的当前状态：已经发送了多少封邮件？

异步发送邮件工作正常，但我不知道如何让外部可以访问进度。看来我这样做的方法是完全错误的，但不知何故它必须是可能的（也许是另一种方法）。这就是我的 EmailEJB 目前的样子（它是一种伪代码，但解释了我想要的内容）：

@Stateful
public class EmailEJB {

  @Asynchronous
  public Future<Integer> sendMails() {
    for (int i=0; i<mails.size; i++) {
      sendMail(mails[i])
      // i want to return the progress without returning ;)
      return new AsyncResult<Integer>(i)
    }
  }
}

//Just for the completeness... from outside, i'm accessing the progress like this:
Future<Integer> progress = emailEJB.sendEmails();
Integer currentvalue = progress.get();

如何在异步函数中返回当前进度，而不用返回取消它？如何向用户显示函数内循环的进度？我需要另一个异步方法吗？有什么提示吗？

Answer 1

没有人吗？好的，这是我的解决方案。我不确定这是否是一个很大的解决方法，或者只是完成此任务的一种方法。

由于 @Asynchronous 方法无法访问 Session 上下文，因此也没有 Session Bean（至少我不知道如何，我总是遇到 ConcurrentModificationErrors 或类似的错误），我创建了一个 Singleton ProgressEJB，其中包含一个 HashMap：

@Singleton @LocalBean @Startup
public class ProgressEJB {
  private HashMap<String, Integer> progressMap = new HashMap<String, Integer>
  // getters and setters
}

此 hashmap 应该映射 SessionId （字符串）到整数值（进度 0->100）。因此，用户会话与进度相关联。
在我的 EmailEJB 中，我注入了这个 ProgressEJB，并且在我的 @Asynchronous 方法中，每次发送电子邮件时我都会增加该值：

@Stateful @LocalBean
public class EmailEJB {
@Inject
private ProgressEJB progress;
// Mail-Settings
...
@Asynchronous
public void sendEmails(user:User, message:Message, sessionId:String) {
  progress.progressMap.put(sessionId, 0);
  for (int i=0; i<mails.size; i++) {
    sendMail(mails[i])
    progress.getProgressMap().put(sessionId, (i / mails.size) * 100)
  }
  progress.getProgressMap().remove(sessionId);
}

sessionId 来自我的托管（焊接）Bean，在调用该函数时：

@SessionScoped
@Named
public class EmailManager {
  @Inject 
  private ProgressEJB progress;
  @Inject
  private FacesContext facesContext;

  private String sessionId;

  @PostConstruct
  private void setSessionId() {
    this.sessionId = ((HttpSession)facesContext.getExternalContext().getSession(false)).getId();
  }

  public Integer getProgress() {
    if (progress.getProgressMap().get(sessionId) == null)
      return 100;
    else 
      return progress.getProgressMap().get(sessionId);
  }
}

现在我可以使用 Ajax 轮询从我的 JSF 视图中访问 EmailManager 的进度，告诉用户已经发送了多少邮件。刚刚与 2 个用户进行了测试，似乎有效。

Answer 2

我在这里也只看到一个@Singleton 解决方案。
但这意味着需要 Housekeeping in ProgressEJB。例如，需要付出一些努力来从哈希图中删除旧会话。

Answer 3

另一种解决方案描述于
有什么方法可以知道EJB 异步进程的进度？

此解决方案不需要 Stateful Bean。

@Stateless
public class EmailEJB {
    // Mail-Settings
    ...
    @Asynchronous
    public void sendEmails(User user, Message message, WorkContext context) {
      progress.progressMap.put(sessionId, 0);
      for (int i=0; i<mails.size; i++) {
        sendMail(mails[i])
        context.setProgress((i / mails.size) * 100)
      }
      context.setRunning(false);
    }
}

保存进度的 Context-Object。

public class WorkContext {
    //volatile is important!
    private volatile Integer progress = 0;
    private volatile boolean running = false;    
    // getters & setters
}

使用方法非常简单。

@SessionScoped
@Named
public class EmailManager {
  @Inject 
  private EmailEJB emailEJB;
  private WorkContext workContext;

  public void doStuff() {
        workContext = new WorkContext();
        emailEJB.sendEmails(user, message, workContext)
  }

  public Integer getProgress() {
        return workContext.getProgress();
  }
  ....
}