Skip to content

About

πŸ“¦ .NET nanoFramework MessagePack serealizer/deserializer library

Topics

Resources

Code of conduct

Contributing

Security policy

Stars

3 stars

Watchers

3 watching

Forks

Latest commit

Β 

History

68 Commits

Folders and files

NameName
Last commit message
Last commit date
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 

Repository files navigation

ο»ΏQuality Gate Status Reliability Rating NuGet #yourfirstpr Discord

nanoFramework logo


Welcome to the .NET nanoFramework MessagePack repository

This repository contains the MessagePack library for the .NET nanoFramework. It provides high-performance serialization and deserialization with the smallest possible payload, MessagePack is an object serialization specification like JSON.

Build status

Component Build Status NuGet Package
nanoFramework.MessagePack Build Status NuGet

nanoFramework.MessagePack

MessagePack is a simple, lightweight serialization library, inspired by MsgPack.Light, that can be used in .NET nanoFramework projects.

Usage

Serialization to byte array

var value = new TestClass();
var bytes = MessagePackSerializer.Serialize(value);

Deserialization

var result = (TestClass)MessagePackSerializer.Deserialize(typeof(TestClass), bytes);

Your type serialization/deserialization

If you want to work with your own types, first thing you need to add is a type converter. Although the library provides almost complete coverage of the serialization/deserialization of any objects, there are certain cases where it is difficult to do without a custom converter.

The general principle of implementing a custom converter

  1. In the code of your project, you need to create a converter class that inherits the IConverter interface and implement the Read and Write interface methods:

         public class SimpleCustomConverter : IConverter
         {
             #nullable enable
             public void Write(object? value, [NotNull] IMessagePackWriter writer)
             {
                 //TODO Your code is here
             }
     
             public object? Read([NotNull] IMessagePackReader reader)
             {
                var yourObject = new YourObject();
                //TODO Your code is here
                return yourObject;
             }
         }
  2. Register your custom converter in the context of serialization:

          public class Program
          {
              public static void Main()
              {
                    var simpleCustomConverter = new SimpleCustomConverter();
                    ConverterContext.Add(typeof(YourObject), simpleCustomConverter);
              }
          }

After completing these steps, the serialization/deserialization of the object for which your converter is added will occur in the methods of the custom converter.

A few examples of the implementation of custom converters
  1. Case with enumeration elements as strings:

        namespace samples
        {
            public enum FieldType
            {
                _ = -1,
                Str,
                Num,
                Any
            }
    
            public class FieldTypeConverter : IConverter
            {
                internal FieldType Read(IMessagePackReader reader)
                {
                    var stringConverter = ConverterContext.GetConverter(typeof(string));
        
                    var enumString = (string)stringConverter.Read(reader);
        
                    return enumString switch
                    {
                        "Str" => FieldType.Str,
                        "Num" => FieldType.Num,
                        "*" => FieldType.Any,
                        _ => throw new Exception($"Unexpected enum {typeof(FieldType)} underlying type: {enumString}"),
                    };
                }
        
                internal void Write(FieldType value, [NotNull] IMessagePackWriter writer)
                {
                    var stringConverter = ConverterContext.GetConverter(typeof(string));
        
                    switch (value)
                    {
                        case FieldType.Str:
                            stringConverter.Write("Str", writer);
                            break;
                        case FieldType.Num:
                            stringConverter.Write("Num", writer);
                            break;
                        case FieldType.Any:
                            stringConverter.Write("*", writer);
                            break;
                        default:
                            throw new Exception($"Enum {value.GetType()} value: {value} expected");
                    }
                }
        
        #nullable enable
                object? IConverter.Read([NotNull] IMessagePackReader reader)
                {
                    return Read(reader);
                }
        
                public void Write(object? value, [NotNull] IMessagePackWriter writer)
                {
                    Write((FieldType)value!, writer);
                }
            }
        }
  2. Case compression or concealment of transmitted strings between sender and recipient if sender and recipient share the same vocabulary of words:

        namespace samples
        {
            public static class SharedWordDictionary
            {
                static SharedWordDictionary()
                {
                    WordDictionary = new ArrayList
                    {
                        "MessagePack",
                        "Hello",
                        "at",
                        "nanoFramework!",
                        " "
                    };
                }
        
                public static ArrayList WordDictionary { get; }
            }
        
            public class SecureMessage
            {
                public SecureMessage(string message)
                {
                    Message = message;
                }
        
                public string Message { get; private set; }
            }
        
            public class SecureMessageConverter : IConverter
            {
                public SecureMessage Read([NotNull] IMessagePackReader reader)
                {
                    StringBuilder sb = new();
                    var length = reader.ReadArrayLength();
                    var intConverter = ConverterContext.GetConverter(typeof(int));
    
                    for (int i = 0; i < length; i++)
                    {
                        int wordIndex = (int)intConverter.Read(reader)!;
                        sb.Append(SharedWordDictionary.WordDictionary[wordIndex]);
                        sb.Append(' ');
                    }
                    if (sb.Length > 0)
                        sb.Remove(sb.Length - 1, 1);
    
                    return new SecureMessage(sb.ToString());
                }
    
                public void Write(SecureMessage value, [NotNull] IMessagePackWriter writer)
                {
                    var messageWords = value.Message.Split(' ');
    
                    uint length = (uint)messageWords.Length;
                    writer.WriteArrayHeader(length);
    
                    var intConverter = ConverterContext.GetConverter(typeof(int));
    
                    foreach (var word in messageWords)
                    {
                        int wordIndex = SharedWordDictionary.WordDictionary.IndexOf(word);
                        intConverter.Write(wordIndex, writer);
                    }
                }
        
        #nullable enable
                object? IConverter.Read([NotNull] IMessagePackReader reader)
                {
                    return Read(reader);
                }
        
                public void Write(object? value, [NotNull] IMessagePackWriter writer)
                {
                    Write((SecureMessage)value!, writer);
                }
            }
        
            public class Program
            {
                public static void Main()
                {
                    var secureMessageConverter = new SecureMessageConverter();
                    ConverterContext.Add(typeof(SecureMessage), secureMessageConverter);
        
                    var secureMessage = new SecureMessage("Hello MessagePack at nanoFramework!");
        
                    //At sender
                    var buffer = MessagePackSerializer.Serialize(secureMessage);
                    Debug.WriteLine($"The message:\n{secureMessage.Message}\nbeing sent has been serialized into {buffer.Length} bytes.");
                    //and sent to recipient
                    //
                    //..........................
                    Debug.WriteLine("=============================================");
        
                    //At recipient, after receiving the byte array
                    Debug.WriteLine($"Received {buffer.Length} bytes");
        
                    var recipientSecureMessage = (SecureMessage)MessagePackSerializer.Deserialize(typeof(SecureMessage), buffer)!;
        
                    Debug.WriteLine($"Message received:\n{recipientSecureMessage.Message}");
                }
            }
        }

Benchmarks

Comparing data:

{
 "StartDate": "2026-01-27T00:00:00.0000000Z",
 "WorkingTime": "00:02:00",
 "TestObjects": [
   {
     "UID": "e8048178-b787-4f22-85bc-891b6637d353",
     "Id": 1
   },
   {
     "UID": "41B07FC4-AE08-4F9B-B9A7-27E8877708D2",
     "Id": 2
   }
 ],
 "IntArrayData": [ 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 ],
 "Users": [
   {
     "Role": {
       "Name": "Admin",
       "Id": 1
     },
     "IsActive": true,
     "Name": "Test"
   }
 ],
 "HashData": {
   "a": "Test",
   "b": 123
 }
}

Size after serialization:

===============================================================
==========         Comparative benchmarks data       ==========
==========                                           ==========
========== Json string size:           336 bytes     ==========
========== MessagePack array size:     197 bytes     ==========
========== BinaryFormatter array size: 186 bytes     ==========
==========                                           ==========
===============================================================

The measurements were carried out on the developer's local computer in a virtual nanoDevice:

********** Starting benchmarks on Virtual nanoDevice **********

| ------------------------------------------------------------------------------- |
| MethodName                          | IterationCount | Mean    | Min   | Max    |
| ------------------------------------------------------------------------------- |
| JsonDeserializationBenchmark        | 5              | 94.8 ms | 83 ms | 112 ms |
| MessagePackDeserializationBenchmark | 5              | 49.4 ms | 48 ms | 51 ms  |
| BinaryDeserializationBenchmark      | 5              | 0.4 ms  | 0 ms  | 1 ms   |
| ------------------------------------------------------------------------------- |

| ------------------------------------------------------------------------------------------ |
| MethodName                        | IterationCount | Mean                  | Min   | Max   |
| ------------------------------------------------------------------------------------------ |
| JsonSerializationBenchmark        | 5              | 57 ms                 | 51 ms | 63 ms |
| MessagePackSerializationBenchmark | 5              | 41.399999999999997 ms | 40 ms | 44 ms |
| BinarySerializationBenchmark      | 5              | 0.2 ms                | 0 ms  | 1 ms  |
| ------------------------------------------------------------------------------------------ |
********** Completed benchmarks **********

*Remark:
One iteration is 20 consecutive repetitions!

Measurements taken on the ESP32 WROOM device:

********** Starting benchmarks on ESP32_REV3 **********

| ------------------------------------------------------------------------------- |
| MethodName                          | IterationCount | Mean   | Min    | Max    |
| ------------------------------------------------------------------------------- |
| JsonDeserializationBenchmark        | 5              | 386 ms | 380 ms | 390 ms |
| MessagePackDeserializationBenchmark | 5              | 188 ms | 180 ms | 190 ms |
| BinaryDeserializationBenchmark      | 5              | 4 ms   | 0 ms   | 10 ms  |
| ------------------------------------------------------------------------------- |

| ----------------------------------------------------------------------------- |
| MethodName                        | IterationCount | Mean   | Min    | Max    |
| ----------------------------------------------------------------------------- |
| JsonSerializationBenchmark        | 5              | 226 ms | 220 ms | 230 ms |
| MessagePackSerializationBenchmark | 5              | 126 ms | 120 ms | 130 ms |
| BinarySerializationBenchmark      | 5              | 2 ms   | 0 ms   | 10 ms  |
| ----------------------------------------------------------------------------- |
********** Completed benchmarks **********

Measurements taken on the XIAO-ESP32-C3 device:

********** Starting benchmarks on XIAO_ESP32C3 **********

| ------------------------------------------------------------------------------- |
| MethodName                          | IterationCount | Mean   | Min    | Max    |
| ------------------------------------------------------------------------------- |
| JsonDeserializationBenchmark        | 5              | 208 ms | 200 ms | 210 ms |
| MessagePackDeserializationBenchmark | 5              | 98 ms  | 90 ms  | 100 ms |
| BinaryDeserializationBenchmark      | 5              | 0 ms   | 0 ms   | 0 ms   |
| ------------------------------------------------------------------------------- |

| ----------------------------------------------------------------------------- |
| MethodName                        | IterationCount | Mean   | Min    | Max    |
| ----------------------------------------------------------------------------- |
| JsonSerializationBenchmark        | 5              | 140 ms | 140 ms | 140 ms |
| MessagePackSerializationBenchmark | 5              | 80 ms  | 80 ms  | 80 ms  |
| BinarySerializationBenchmark      | 5              | 0 ms   | 0 ms   | 0 ms   |
| ----------------------------------------------------------------------------- |
********** Completed benchmarks **********

Measurements taken on the XIAO-ESP32-C6 device:

********** Starting benchmarks on ESP32_C6_THREAD **********

| ------------------------------------------------------------------------------- |
| MethodName                          | IterationCount | Mean   | Min    | Max    |
| ------------------------------------------------------------------------------- |
| JsonDeserializationBenchmark        | 5              | 112 ms | 110 ms | 120 ms |
| MessagePackDeserializationBenchmark | 5              | 60 ms  | 60 ms  | 60 ms  |
| BinaryDeserializationBenchmark      | 5              | 2 ms   | 0 ms   | 10 ms  |
| ------------------------------------------------------------------------------- |

| -------------------------------------------------------------------------- |
| MethodName                        | IterationCount | Mean  | Min   | Max   |
| -------------------------------------------------------------------------- |
| JsonSerializationBenchmark        | 5              | 68 ms | 60 ms | 70 ms |
| MessagePackSerializationBenchmark | 5              | 48 ms | 40 ms | 50 ms |
| BinarySerializationBenchmark      | 5              | 2 ms  | 0 ms  | 10 ms |
| -------------------------------------------------------------------------- |
********** Completed benchmarks **********

As it can be seen from the benchmark results above, in what concerns speed and compaction, MessagePack performs better than the Json serializer. Coming at no surprise, Binary serialization is the most performant one.

Acknowledgements

The initial version of the MessagePack library was coded by Spirin Dmitriy, who has kindly handed over the library to the .NET nanoFramework project.

Feedback and documentation

For documentation, providing feedback, issues, and finding out how to contribute, please refer to the Home repo.

Join our Discord community here.

Credits

The list of contributors to this project can be found at CONTRIBUTORS.

License

The nanoFramework WebServer library is licensed under the MIT license.

Code of Conduct

This project has adopted the code of conduct defined by the Contributor Covenant to clarify expected behaviour in our community. For more information see the .NET Foundation Code of Conduct.

.NET Foundation

This project is supported by the .NET Foundation.

About

πŸ“¦ .NET nanoFramework MessagePack serealizer/deserializer library

Topics

Resources

Code of conduct

Contributing

Security policy

Stars

3 stars

Watchers

3 watching

Forks

Releases

Sponsor this project

Used by

Contributors

Languages