Прелесть AKKA в унификации взаимодействия отдельных частей, которые, при необходимости, можно разнести на разные машины.
Стандартные, общепринятые подходы - вызовы функций, создание экземпляров класса и управление ими хорошо работают в пределах одной машины.
Но с масштабируемостью (разнесение на разные машины) беда.
Предпринималось множество попыток решить проблему, привести к общепринятому виду ...
CORBA например. Но идеология CORBA, сделать так чтобы вызов функции, либо создание объекта выглядело одинаково вне зависимости от того локально это происходит либо удаленно, скрывая детали происходящего, потерпела крах и не получила широкого распространения и поддержки.
Но попытки масштабироваться за счёт построения распределенных приложений является д движением в правильном направлении.
Теоретическая база AKKA, как один из способов распределения задач, существовала давно.
Нужна была только грамотная реализация.
В отличии от CORBA, AKKA не пытается ничего скрывать от своего пользователя и даже на локальном компьютере ведет себя как распределенное приложение, слегка проигрывая в производительности и эффективности обычным приложениям с прямым вызовом.
Но в момент когда потребуется распределить нагрузку на несколько компов, в AKKA достаточно при старте просто подсунуть информацию о новой сетевой конфигурации...
Один из фундаментальных компонентов распределенных систем - протокол обмена. По умолчанию AKKA использует стандартную JAVA сериализацию, которая мягко говоря не эффективна.
И разработчики AKKA предоставляют API, написать использовать свой сериализатор путем расширения базового класса.
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
public class MyOwnSerializer extends JSerializer {
// This is whether "fromBinary" requires a "clazz" or not
@Override public boolean includeManifest() {
return false;
}
// Pick a unique identifier for your Serializer,
// you've got a couple of billions to choose from,
// 0 - 40 is reserved by Akka itself
@Override public int identifier() {
return 1234567;
}
// "toBinary" serializes the given object to an Array of Bytes
@Override public byte[] toBinary(Object obj) {
// Put the code that serializes the object here
//#...
return new byte[0];
//#...
}
// "fromBinary" deserializes the given array,
// using the type hint (if any, see "includeManifest" above)
@Override public Object fromBinaryJava(byte[] bytes,
Class<?> clazz) {
// Put your code that deserializes here
//#...
return null;
//#...
}
}
и при старте AKKA указав каким
сериалайзером в каких случаях пользоваться
одним из наиболее
популярных является Kryo-based serializers
Но если захочется реально высокой производительности и минимального трафика, то https://github.com/cheblin/BlackBox]
BlackBox будет покруче.
