Wie serialisiere ich ein Lambda?

Wie kann ich ein Lambda elegant serialisieren?

Der folgende Code löst beispielsweise a aus NotSerializableException. Wie kann ich das Problem beheben, ohne eine SerializableRunnable"Dummy" -Schnittstelle zu erstellen?

public static void main(String[] args) throws Exception {
    File file = Files.createTempFile("lambda", "ser").toFile();
    try (ObjectOutput oo = new ObjectOutputStream(new FileOutputStream(file))) {
        Runnable r = () -> System.out.println("Can I be serialized?");
        oo.writeObject(r);
    }

    try (ObjectInput oi = new ObjectInputStream(new FileInputStream(file))) {
        Runnable  r = (Runnable) oi.readObject();
        r.run();
    }
}

Java 8 bietet die Möglichkeit, ein Objekt durch Hinzufügen mehrerer Grenzen in einen Schnittpunkt von Typen umzuwandeln . Bei der Serialisierung ist es daher möglich zu schreiben:

Runnable r = (Runnable & Serializable)() -> System.out.println("Serializable!");

Und das Lambda wird automatisch serialisierbar.

Die gleiche Konstruktion kann für Methodenreferenzen verwendet werden. Zum Beispiel dieser Code:

import java.io.Serializable;

public class Test {
    static Object bar(String s) {
        return "make serializable";
    }

    void m () {
        SAM s1 = (SAM & Serializable) Test::bar;
        SAM s2 = (SAM & Serializable) t -> "make serializable";
    }

    interface SAM {
        Object action(String s);
    }
}

definiert einen Lambda-Ausdruck und eine Methodenreferenz mit einem serialisierbaren Zieltyp.

Sehr hässliche Besetzung. Ich bevorzuge es, eine serialisierbare Erweiterung für die von mir verwendete Funktionsschnittstelle zu definieren

Beispielsweise:

interface SerializableFunction<T,R> extends Function<T,R>, Serializable {}
interface SerializableConsumer<T> extends Consumer<T>, Serializable {}

dann kann die Methode, die das Lambda akzeptiert, als solche definiert werden:

private void someFunction(SerializableFunction<String, Object> function) {
   ...
}

Wenn Sie die Funktion aufrufen, können Sie Ihr Lambda ohne hässliche Besetzung übergeben:

someFunction(arg -> doXYZ(arg));

Falls jemand beim Erstellen des Beam / Dataflow-Codes hierher fällt:

Beam verfügt über eine eigene SerializableFunction- Schnittstelle, sodass keine Dummy-Schnittstelle oder ausführliche Casts erforderlich sind.

Wenn Sie bereit sind, zu einem anderen Serialisierungsframework wie Kryo zu wechseln , können Sie die Mehrfachgrenzen oder die Anforderung, die die implementierte Schnittstelle implementieren muss, beseitigen Serializable. Der Ansatz ist zu

1. Ändern Sie das, InnerClassLambdaMetafactoryum immer den für die Serialisierung erforderlichen Code zu generieren
2. Rufen Sie die LambdaMetaFactorywährend der Deserialisierung direkt an

Details und Code finden Sie in diesem Blogbeitrag