阿卡演员与未来：以身作则

我试图学习阿卡演员和未来，但在阅读了 http://akka.io 的文档并做了 http://doc.akka.io/docs/akka/2.0.2/intro/getting-started-first-java.html 之后，我仍然在理解方面遇到了一些问题。我想计算Pi的值是很多人也可以联系到的事情，但不是我=）。我搜索了一下，但没有找到任何适合我的例子。因此，我想我会把我的一些现实生活中的代码扔在这里，并用它交换一个如何使用Akka做到这一点的例子。

好的，我们开始吧：

我有一个java play2应用程序，我需要从我的数据库中获取一些数据，并在我的elasticsearch实例中对其进行索引。

1. 我打电话给DB并获取场地的ID。

2. 然后，我将列表拆分并创建几个可调用的索引任务。

3. 之后，我调用所有任务，其中每个任务从数据库中收集分配的ID的场所。

4. 对于每个场所，将其索引到 elasticsearch 实例并使其可搜索。

5. 做。

应用.java：

public class Application extends Controller {

  private static final int VENUE_BATCH = 1000;
  private static int size;

  public static Result index() {

      List<Long> venueIds = DbService.getAllVenueIds();
      size = venueIds.size();
      Logger.info("Will index " + size + " items in total.");
      ExecutorService service = Executors.newFixedThreadPool(getRuntime().availableProcessors());
      int startIx = 0;
      Collection<Callable<Object>> indexTasks = new ArrayList<Callable<Object>>();
      do {
          int endIx = Math.min(startIx + VENUE_BATCH, size);
          List<Long> subList = venueIds.subList(startIx, endIx);
          VenueIndexTask indexTask = new VenueIndexTask(subList);
          indexTasks.add(indexTask);
      } while ((startIx += VENUE_BATCH) < size);

      Logger.info("Invoking all tasks!");
      try {
          service.invokeAll(indexTasks);
      } catch (InterruptedException e) {
          e.printStackTrace();
      }

      return ok(index.render("Done indexing."));
  } 
}

地点任务：

public class VenueIndexTask implements Callable<Object> {

    private List<Long> idSubList;

    public VenueIndexTask(List<Long> idSubList){
        this.idSubList = idSubList;
        Logger.debug("Creating task which will index " + idSubList.size() + " items. " +
                "Range: " + rangeAsString() + ".");
    }

    @Override
    public Object call() throws Exception {
        List<Venue> venues = DbService.getVenuesForIds(idSubList);
        Logger.debug("Doing some indexing: "+venues.size());

        for(Venue venue : venues) {
            venue.index();
        }
        return null;
    }
    private String rangeAsString() {
        return "[" + idSubList.get(0) + "-" + idSubList.get(idSubList.size() - 1) + "]";
    }
}

场地：

@IndexType(name = "venue")
public class Venue extends Index {

    private String name;

    // Find method static for request
    public static Finder<Venue> find = new Finder<Venue>(Venue.class);

    public Venue() {
    }

    public Venue(String id, String name) {
        super.id = id;
        this.name = name;
    }

    @Override
    public Map toIndex() {
        HashMap map = new HashMap();
        map.put("id", super.id);
        map.put("name", name);
        return map;
    }

    @Override
    public Indexable fromIndex(Map map) {
        if (map == null) {
            return this;
        }
        this.name = (String) map.get("name");
        return this;
    }
}

所以你们所有阿卡人都疯了！请尽可能多地做，提出可以使用的很酷的未来功能，或者我可以用来学习这些东西的任何其他知识/代码。