• Stars
    star
    272
  • Rank 145,698 (Top 3 %)
  • Language
    C#
  • License
    Apache License 2.0
  • Created over 7 years ago
  • Updated 10 months ago

Reviews

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

Repository Details

Polymorphic serialization for .NET

Hyperion

Join the chat at https://gitter.im/akkadotnet/Hyperion

A high performance polymorphic serializer for the .NET framework.

Current status: BETA (v0.9.14).

License

Licensed under Apache 2.0, see LICENSE for the full text.

Polymorphic serializations

Hyperion was designed to safely transfer messages in distributed systems, for example service bus or actor model based systems. In message based systems, it is common to receive different types of messages and apply pattern matching over those messages. If the messages does not carry over all the relevant type information to the receiveing side, the message might no longer match exactly what your system expect.

Consider the following case:

public class Envelope
{
     //untyped property
     public object Payload {get;set;}
     //other properties..
     ...
}

...

var envelope = new Envelope { Payload = (float)1.2 };

If you for example are using a Json based serializer, it is very likely that the value 1.2 will be deserialized as a double as Json has no way to describe the type of the decimal value. While if you use some sort of binary serializer like Google Protobuf, all messages needs to be designed with a strict contract up front. Hyperion solves this by encoding a manifest for each value - a single byte prefix for primitive values, and fully qualified assembly names for complex types.

Surrogates

Sometimes, you might have objects that simply can't be serialized in a safe way, the object might be contextual in some way. Hyperion can solve those problems using "Surrogates", surrogates are a way to translate an object from and back to the context bound representation.

var surrogate = Surrogate.Create<IMyContextualInterface,IMySurrogate>(original => original.ToSurrogate(), surrogate => surrogate.Restore(someContext));
var options = new SerializerOptions(surrogates: new [] { surrogate });
var serializer = new Serializer(options);

This is essential for frameworks like Akka.NET where we need to be able to resolve live Actor References in the deserializing system.

Whitelisting Types On Deserialization

Sometimes we need to limit the types that are allowed to be deserialized for security reasons. For this reason, you can either pass a class instance that implements the ITypeFilter interface into the SerializerOptions or use the TypeFilterBuilder class to build a TypeFilter that Hyperion can use to filter out any possibly harmful injection attack during deserialization.

using the ITypeFilter interface:

public sealed class TypeFilter : ITypeFilter
{
    public ImmutableHashSet<string> FilteredTypes { get; }

    internal TypeFilter(IEnumerable<Type> types)
    {
        FilteredTypes = types.Select(t => t.GetShortAssemblyQualifiedName()).ToImmutableHashSet();
    }
    
    public bool IsAllowed(string typeName)
        => FilteredTypes.Any(t => t == typeName);
}

using the TypeFilterBuilder convenience builder:

var typeFilter = TypeFilterBuilder.Create()
    .Include<AllowedClassA>()
    .Include<AllowedClassB>()
    .Build();

var options = SerializerOptions.Default
    .WithTypeFilter(typeFilter);

var serializer = new Serializer(options);

Convert Whitelist To Blacklist

To do blacklisting instead of whitelisting a list of types, you will need to do a slight modification to the TypeFilter class.

public sealed class TypeFilter : ITypeFilter
{
    public ImmutableHashSet<string> FilteredTypes { get; }

    internal TypeFilter(IEnumerable<Type> types)
    {
        FilteredTypes = types.Select(t => t.GetShortAssemblyQualifiedName()).ToImmutableHashSet();
    }
    
    public bool IsAllowed(string typeName)
        => FilteredTypes.All(t => t != typeName);
}

Version Tolerance

Hyperion has been designed to work in multiple modes in terms of version tolerance vs. performance.

  1. Pre Register Types, when using "Pre registered types", Hyperion will only emit a type ID in the output stream. This results in the best performance, but is also fragile if different clients have different versions of the contract types.
  2. Non Versioned, this is largely the same as the above, but the serializer does not need to know about your types up front. it will embed the fully qualified typename in the output stream. this results in a larger payload and some performance overhead.
  3. Versioned, in this mode, Hyperion will emit both type names and field information in the output stream. This allows systems to have slightly different versions of the contract types where some fields may have been added or removed.

Hyperion has been designed as a wire format, point to point for soft realtime scenarios. If you need a format that is durable for persistence over time. e.g. EventSourcing or for message queues, then Protobuf or MS Bond is probably a better choice as those formats have been designed for true version tolerance.

Performance

Hyperion has been designed with a performance first mindset. It is not the most important aspect of Hyperion, Surrogates and polymorphism is more critical for what we want to solve. But even with its rich featureset, Hyperion performs extremely well.

Hyperion - preregister types
   Serialize                      312 ms
   Deserialize                    261 ms
   Size                           38 bytes
   Total                          573 ms
Hyperion - no version data
   Serialize                      327 ms
   Deserialize                    354 ms
   Size                           73 bytes
   Total                          681 ms
Hyperion - preserve object refs
   Serialize                      400 ms
   Deserialize                    369 ms
   Size                           73 bytes
   Total                          769 ms
MS Bond
   Serialize                      429 ms
   Deserialize                    404 ms
   Size                           50 bytes
   Total                          833 ms
Hyperion - version tolerant
   Serialize                      423 ms
   Deserialize                    674 ms
   Size                           195 bytes
   Total                          1097 ms
Protobuf.NET
   Serialize                      638 ms
   Deserialize                    721 ms
   Size                           42 bytes
   Total                          1359 ms
Jil
   Serialize                      1448 ms
   Deserialize                    714 ms
   Size                           123 bytes
   Total                          2162 ms
Net Serializer
   Serialize                      1289 ms
   Deserialize                    1113 ms
   Size                           39 bytes
   Total                          2402 ms
Json.NET
   Serialize                      3767 ms
   Deserialize                    5936 ms
   Size                           187 bytes
   Total                          9703 ms
Binary formatter
   Serialize                      10784 ms
   Deserialize                    11374 ms
   Size                           362 bytes
   Total                          22158 ms

This test was run using the following object definition:

public class Poco
{
    public string StringProp { get; set; }      //using the text "hello"
    public int IntProp { get; set; }            //123
    public Guid GuidProp { get; set; }          //Guid.NewGuid()
    public DateTime DateProp { get; set; }      //DateTime.Now
}

Big disclaimer: The above results change drastically depending on your contracts, e.g. using smaller messages favor both NetSerializer and Jil. There is no "best" or "fastest" serializer, it all depends on context and requirements.

More Repositories

1

akka.net

Canonical actor model implementation for .NET with local + distributed actors in C# and F#.
C#
4,497
star
2

HOCON

C# implementation of Lightbend's HOCON (Human-Optimized Object Configuration Notation)
C#
128
star
3

Alpakka

Akka Streams Connectors - Alpakka
C#
108
star
4

Akka.Streams.Kafka

Kafka Akka.Streams connectors - part of the Alpakka project
C#
65
star
5

Akka.Persistence.SqlServer

Akka.Persistence.SqlServer provider
C#
59
star
6

Akka.Quartz.Actor

Quartz scheduling actor
C#
54
star
7

getakka.net

Trying out Assemble.io for site generation
JavaScript
43
star
8

Akka.Hosting

Akka.Hosting - standardized Akka.NET hosting without any HOCON configuration. Ties into Microsoft.Extensions.Configuration, Logging, Hosting, and DependencyInjection.
C#
43
star
9

Akka.Persistence.PostgreSql

Akka.Persistence.PostgreSql provider
C#
33
star
10

Akka.Persistence.Redis

Redis storage for Akka.NET Persistence
C#
29
star
11

Akka.Persistence.MongoDB

MongoDB support for Akka.Persistence
C#
29
star
12

Akka.Persistence.Cassandra

Akka.Persistence.Cassandra plugin
C#
23
star
13

Akka.Management

Akka.NET cluster management, bootstrapping, and more.
C#
22
star
14

Akka.Logger.Serilog

Akka.NET logging integration for Serilog library
C#
20
star
15

Akka.DI.AutoFac

Akka.NET integration plugin for AutoFac dependency injection library
PowerShell
13
star
16

akkadotnet-templates

Production-ready dotnet new templates for Akka.NET.
C#
13
star
17

Akka.Serialization.MessagePack

Akka.NET serialization with MessagePack
C#
11
star
18

Akka.Logger.NLog

Akka.NET logging integration for NLog library
F#
8
star
19

Akka.Persistence.MySql

MySQL implementation for Akka.Persistence
C#
8
star
20

dockerfiles

Dockerfile templates used in Akka.NET Continuous Integration
6
star
21

Akka.MultiNodeTestRunner

Infrastructure for facilitating multi-node testing in Akka.NET
C#
6
star
22

akka.net-integration-tests

Nightly integration tests using the latest dev builds of Akka.NET
C#
6
star
23

Akka.Persistence.Sql

Linq2Db implementation of Akka.Persistence.Sql. Common implementation for SQL Server, Sqlite, Postgres, Oracle, and MySql.
C#
6
star
24

generator-akkadotnet

yo for akka.net projects
JavaScript
5
star
25

akka.analyzers

Roslyn analyzers for Akka.NET developers.
C#
5
star
26

Akka.TestKit.NUnit

Akka.NET TestKit integration plugin for NUnit
C#
4
star
27

Akka.Hosting.Maui

MAUI support for Akka.Hosting
C#
2
star
28

.github

Akka.NET Community Defaults
2
star
29

akkadotnet.github.com

akka.net website
JavaScript
1
star
30

Akka.TestKit.MSTest

Akka.NET TestKit integration plugin for MSTest
C#
1
star
31

Media

Media resources related to Akka.NET; Logos, illustrations etc
1
star
32

Akka.Serialization.Compressed

Akka serialization plugin that supports compression
C#
1
star