Akka.NET: невозможно отправить список сообщений в другую систему ActorSystem

Question

Я новичок в Akka.NET. Я недавно начал заниматься своим университетским проектом и столкнулся со странной проблемой. У меня есть две ActorSystems в двух разных настольных приложениях. В первой системе ActorSystem я отправляю сообщение ZippedAddressListMessage между двумя действующими лицами, используя Akka.Remote.

public class ZippedAddressListMessage
    {
        public ZippedAddressListMessage(List<string> list)
        {
            this.Values = list.AsReadOnly();
        }

        public IReadOnlyCollection<string> Values { get; private set; }

    }

Это работает нормально, но когда я пытаюсь отправить это сообщение в другую ActorSystem, я получаю огромный список ошибок: снимок экрана #1 в окне консоли с ошибкой

Тем не менее, если я отправлю простое сообщение, которое состоит только из одного целого числа, все работает хорошо. Вероятно, есть проблема с сериализацией, но я не мог понять, как ее решить. Я искал везде, но до сих пор не нашел ответа. Пожалуйста, не могли бы вы объяснить мне, как решить эту проблему?

Актер из первой системы ActorSystem:

    using Akka.Actor;
    using System;
    using System.Collections;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using ChatMessages;
    using System.Diagnostics;
    using Akka.Serialization;
    using Akka.Actor.Internal;
    using Akka.Remote;

namespace Agent
{
    public class ActorHelper: ReceiveActor 
    {
        int N; 
        int fromId;
        int count;
        IActorRef chiefAgent;
        List<recordItem> agentList; 
    public ActorHelper()
    {
        count = 0;
        agentList = new List<recordItem>();

        Receive<CreateHelpersMessage>(msg =>
        {
            chiefAgent = Sender;
            fromId = msg.fromID;
            N = msg.N;

            for (int i = 0; i < msg.N; i++)
            {
                Process.Start("C:\\Users\\Artemij\\Source\\Repos\\Client\\AgentHelper\\AgentHelper\\bin\\Debug\\AgentHelper.exe",
                                "akka.tcp://Agent@localhost:8000/user/AgentActor/ActorHelper" + " " + i);
            }

        });


        Receive<NewAgentHelperMessage>(msg =>
        {
            Console.WriteLine(msg.name + " " + Sender.Path.ToString() + " || " + (count+1) + "/" + N);
            agentList.Add(new recordItem(fromId + count, msg.name, Sender));
            count++;

            Context.Watch(Sender);

            if (count == N)
            {
                chiefAgent.Tell(new AddressListMessage(agentList), Self);

            }


        });

        Receive<AddressListMessage>(msg =>
        {
            Console.WriteLine("All is ready");
            List<string> temp = new List<string>();
            foreach (recordItem i in msg.Values)
            {
                temp.Add(i.ID + " " + i.name + " " + Serialization.SerializedActorPath(i.address));
            }

            foreach (recordItem i in agentList)
            {
                Console.WriteLine(i.address);

                //PROBLEM HERE!
                i.address.Tell(new ZippedAddressListMessage(temp), Self);

            }



        });




    }

}

}

Актер из другой системы ActorSystem:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Akka.Actor;
using ChatMessages;
using System.Diagnostics;

namespace AgentHelper
{

class AgentHelperActor: ReceiveActor
{
    int priority;
    ActorSelection seniorAgentActor;       
    List<recordItem> fullList;


    public AgentHelperActor(string addressSenior, string rank)
    {
        fullList = new List<recordItem>();

        seniorAgentActor = Context.ActorSelection(addressSenior);
        Int32.TryParse(rank, out priority);

        seniorAgentActor.Tell(new NewAgentHelperMessage("agent"+priority, ""), Self);

        //RECEIVING A LIST!!
        Receive<ZippedAddressListMessage>(msg =>
        {
            Console.WriteLine("The entire list");


        });


        Receive<NewAgentHelperMessage>(msg =>
        {
            Console.WriteLine(msg.name);

        });


    }


    public void updateList(IReadOnlyCollection<recordItem> list)
    {
        fullList = new List<recordItem>(list);
        foreach (recordItem i in fullList)
        {
            Console.WriteLine(i.ToString());
        }
    }


}

}

ОБНОВЛЕНО: Вот скриншот ошибки в начале. снимок экрана #2 окна консоли с ошибкой. В нем написано, что формат System.String[] не совместим с сериализацией JSON.

Answer 1

Проблема решена! Проблема была в сериализаторе: я использовал сериализатор Newtonsoft.Json. Когда дело доходит до отправки сообщения в удаленную систему ActorSystem, он не может сериализовать список. Newtonsoft объясняет, что System.String[] является несовместимым типом.

Решением является установка сериализатора Hyperion: http://getakka.net/docs/Serialization