25
私はアッカの俳優や先物を学ぶためにしようとしているが、http://akka.io でドキュメントを読み、http://doc.akka.io/docs/akka/2.0.2/intro/getting-started-first-java.html を行った後、私はまだ理解していくつかの問題を抱えています。私はPi の価値を計算すると思うが、多くの人が関係することができるものだが、私はそうではない）。私は少しの周りを検索している しかし、私に合った例は見つかりませんでした。そのため、私は現実のコードをいくつか取り上げてここに投げ込んで、Akkaでこれをどうやって行うのかの例としてそれを交換すると考えました。 [OK]をアッカの俳優や先物：理解の例による
ので、ここで私達は行く：
は、私は私のelasticsearchインスタンスに私のDBとインデックス、そこからいくつかのデータを取る必要があるのJava PLAY2アプリケーションを持っています。
私はDBを呼び出し、会場のIDを取得します。
次に、リストを分割して、いくつかの呼び出し可能なインデックスタスクを作成します。
その後、私は各タスクが割り当てられたidの会場をdbで収集するすべてのタスクを呼び出します。
各会場ではelasticsearchインスタンスにインデックスを付けて検索可能にします。
完了。
Application.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."));
}
}
VenueTask：
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;
}
}
だから、そこのあなたのAkkaの人々はナッツに行く！できるだけ多くのことをしてください。使用することができるクールな先物機能や、このようなことを学ぶために使用できる他の知識/コードを提案してください。
これは大きな質問ですが、codereview.stackexchange.comでうまくいくかもしれません –