Можно ли избежать сериализации при использовании шины событий Vert.x «локально» (java, single jvm)?

Мой случай:

  • одиночная JVM
  • Только Java (не обязательно быть полиглотом)
  • Я не хочу оплачивать сериализацию, чтобы опубликовать неизменяемое событие на шине (публикация ссылки на объект java будет работать).

Я понимаю, что сфера применения шины событий vert.x намного шире, чем мой вариант использования.

Я имел в виду поведение, похожее на akka: когда вы переходите к распределенному, вы должны обеспечить сериализацию для своих сообщений, если вы остаетесь, локальные ссылки передаются.

Есть ли что-нибудь, что позволило бы мне сделать это в Vert.x?


java vert.x event-bus
person white-surf-style-five    schedule 17.07.2018    source источник
comment
отправлять идентификаторы объектов вместо самих объектов по шине событий   -  person injecteer    schedule 17.07.2018
comment
это могло сработать. Однако я бы избегал этого, поскольку это означало бы, что я разделяю состояние между издателем и потребителем ... что означало бы, зачем вообще нужна шина?   -  person white-surf-style-five    schedule 17.07.2018
comment
в вашем случае я также не вижу реальной выгоды от использования шины событий. Вы можете легко использовать некоторые внутрипроцессные сообщения Java   -  person injecteer    schedule 17.07.2018
comment
кстати, в том shared state, который вы упомянули, вам все равно придется использовать сериализацию   -  person injecteer    schedule 17.07.2018
comment
Фактически, я хочу использовать некоторые внутрипроцессные сообщения, а также использовать семантику диспетчеризации цикла событий Vert.X. Что касается сериализации и общего состояния: я не вижу связи: почему совместное использование ссылки java связано с сериализацией?   -  person white-surf-style-five    schedule 17.07.2018

Ответы (1)


arrow_upward
8
arrow_downward

В Vert.x такая оптимизация уже есть. При отправке в ту же JVM объекты не будут сериализованы или десериализованы.

Вы можете увидеть фактический код здесь: https://github.com/eclipse/vert.x/blob/master/src/main/java/io/vertx/core/eventbus/impl/EventBusImpl.java#L372

Когда вы реализуете свой MessageCodec, у вас фактически есть два метода: decodeFromWire() и transform(). Реализовать преобразование можно только самым наивным подходом:

@Override
public Object transform(Object o) {
   return o;
}
person Alexey Soshin    schedule 17.07.2018