Mule 3.7 с Kyro предлагает повышение производительности на 77%

В настоящее время Mule использует обычную сериализацию Java для хранения объектов в файлах или для репликации их через кластер Mule. Это накладывает ограничения на:

• Типы объектов, которые мы можем хранить: они должны реализовывать интерфейс Serializable и обеспечивать надлежащие конструкторы. Кроме того, этого недостаточно для того, чтобы класс был Serializable, должны быть также все его составные объекты.
• Производительность : Сериализатор Java далеко не самый быстрый в городе.

Если вы часто пользуетесь пакетным модулем , то вы уже знаете, что в пакетном режиме мы уже решили эту проблему, используя платформу Kryo , которая позволяет сериализовать более широкий диапазон объектов с большей скоростью, чем по умолчанию в Java. Однако до выпуска Mule 3.7.0 возможности Kryo не были включены в пакетный модуль. Что если вы хотите использовать его в постоянном ObjectStore? А как насчет распределенной очереди виртуальных машин? Более того: почему я не могу выбрать сериализацию с использованием какой-либо инфраструктуры, которую я выберу? Мы решили эти вопросы в Mule 3.7.0:

• Создание Serialization API , чтобы позволить любому разработчику Java внести свой вклад и использовать свой собственный сериализатор.
• Мы создали реализацию этого Serialization API на основе Kryo, которая поставляется с дистрибутивом EE и может быть легко настроена.

API сериализации

Мы взялись за это с нуля, начав с создания API-интерфейса сериализации, который отделяет Mule и его расширения от фактического используемого механизма сериализации, а также позволяет пользователям настраивать, какой механизм они хотят использовать, и даже предоставлять свой собственный.

Мул полагается на сериализацию каждый раз, когда:

• Вы читаете / пишете из постоянного ObjectStore.
• Вы читаете / пишете из постоянной очереди VM или JMS.
• Объект распространяется через кластер Мул.
• Вы читаете / пишете объект из файла.

Изменение механизма сериализации, используемого для таких задач, может значительно улучшить функциональность и производительность.

API сериализации в основном определяется следующим интерфейсом:

/*
 * Copyright (c) MuleSoft, Inc.  All rights reserved.  http://www.mulesoft.com
 * The software in this package is published under the terms of the CPAL v1.0
 * license, a copy of which has been included with this distribution in the
 * LICENSE.txt file.
 */
package org.mule.api.serialization;

import org.mule.util.store.DeserializationPostInitialisable;

import java.io.InputStream;
import java.io.OutputStream;
import java.io.Serializable;

/**
 * Defines a component capable to serialize/deserialize objects into/from an array of
 * {@link byte}s. Unlike usual serializing components, this one doesn't enforce the
 * serialized object to implement {@link Serializable}. However, some implementations
 * might require that condition and throw {@link IllegalArgumentException} if not
 * met.
 * <p/>
 * Implementations are also responsible for the correct initialization of classes
 * implementing the {@link DeserializationPostInitialisable}
 * interface.
 * <p/>
 * <p/>
 * Unexpected behavior can result of deserializing objects that were generated with
 * a different implementation of {@link ObjectSerializer}.
 * <p/>
 * Implementations are required to be thread-safe
 *
 * @since 3.7.0
 */
public interface ObjectSerializer
{

    /**
     * Serializes the given object into a an array of {@link byte}s
     *
     * @param object the object to be serialized. Might be <code>null</code>
     * @return an array of {@link byte}
     * @throws SerializationException in case of unexpected exception
     */
    byte[] serialize(Object object) throws SerializationException;

    /**
     * Serializes the given object and writes the result into {@code out}
     *
     * @param object the object to be serialized. Might be <code>null</code>
     * @param out    an {@link OutputStream} where the result will be written
     * @return an array of {@link byte}
     * @throws SerializationException in case of unexpected exception
     */
    void serialize(Object object, OutputStream out) throws SerializationException;

    /**
     * Deserializes the given bytes. Unexpected behavior can result of deserializing
     * a byte[] that was generated with another implementation.
     * <p/>
     * If the obtained object implements {@link DeserializationPostInitialisable}
     * then this serializer will be responsible for properly initializing
     * the object before returning it.
     * <p/>
     * Implementation will choose the {@link java.lang.ClassLoader}
     * to use for deserialization.
     *
     * @param bytes an array of byte that an original object was serialized into
     * @return the deserialized object
     * @throws IllegalArgumentException if {@code bytes} is {@code null}
     * @throws SerializationException   in case of unexpected exception
     */
    <T> T deserialize(byte[] bytes) throws SerializationException;

    /**
     * Deserializes the given bytes.
     * <p/>
     * If the obtained object implements {@link DeserializationPostInitialisable}
     * then this serializer will be responsible for properly initializing
     * the object before returning it.
     *
     * @param bytes       an array of byte that an original object was serialized into
     * @param classLoader the {@link java.lang.ClassLoader} to deserialize with
     * @return the deserialized object
     * @throws IllegalArgumentException if {@code bytes} is {@code null}
     * @throws SerializationException   in case of unexpected exception
     */
    <T> T deserialize(byte[] bytes, ClassLoader classLoader) throws SerializationException;

    /**
     * Deserializes the given stream of bytes.
     * <p/>
     * Implementation will choose the {@link java.lang.ClassLoader}
     * to use for deserialization.
     * <p/>
     * Even if deserialization fails, this method will close the
     * {@code inputStream}
     * <p/>
     * If the obtained object implements {@link DeserializationPostInitialisable}
     * then this serializer will be responsible for properly initializing
     * the object before returning it.
     *
     * @param inputStream a stream of bytes that an original object was serialized into
     * @return the deserialized object
     * @throws IllegalArgumentException if {@code inputStream} is {@code null}
     * @throws SerializationException   in case of unexpected exception
     */
    <T> T deserialize(InputStream inputStream) throws SerializationException;

    /**
     * Deserializes the given stream of bytes.
     * <p/>
     * Even if deserialization fails, this method will close the
     * {@code inputStream}
     * <p/>
     * If the obtained object implements {@link DeserializationPostInitialisable}
     * then this serializer will be responsible for properly initializing
     * the object before returning it.
     *
     * @param inputStream a stream of bytes that an original object was serialized into
     * @param classLoader the {@link java.lang.ClassLoader} to deserialize with
     * @return the deserialized object
     * @throws IllegalArgumentException if {@code inputStream} is {@code null}
     * @throws SerializationException   in case of unexpected exception
     */
    <T> T deserialize(InputStream inputStream, ClassLoader classLoader) throws SerializationException;
}

<mule>
  <spring:beans>
      <spring:bean id="customSerializer" class="com.my.CustomSerializer" />
  </spring:beans>

  <configuration defaultObjectSerializer-ref="customSerializer"/>
</mule>

public class MyClass {

  @Inject
  @DefaultObjectSerializer
  private ObjectSerializer objectSerializer;

}

public class MyClass {

  @Inject
  @Named("mySerializer")
  private ObjectSerializer objectSerializer;
}

// returns the default object serializer
muleContext.getObjectSerializer();

<mule>
  <kryo:serializer name="kryo" />
  <configuration defaultObjectSerializer-ref="kryo" />
</mule>

<!-- default option, equivalent to simply not setting any compressionMode -->
<kryo:serializer name="noCompression" compressionMode="NONE"/>

<kryo:serializer name="deflate" compressionMode="DEFLATE"/>

<kryo:serializer name="gzip" compressionMode="GZIP"/>