2

我是 Akka.NET 的新手。我最近开始做我的大学项目，遇到了一个奇怪的问题。我在两个不同的桌面应用程序中有两个 ActorSystems。在第一个 ActorSystem 中，我使用 Akka.Remote 在两个 Actor 之间发送消息 ZippedAddressListMessage。

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

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

    }

这工作正常，但是当我尝试将此消息发送到其他 ActorSystem 时，我得到了大量的错误列表： 带有错误的控制台窗口的屏幕截图 #1

不过，如果我发送一条仅包含一个整数的简单消息，则一切正常。可能存在序列化问题，但我无法弄清楚它必须如何解决。我到处搜索，但仍然没有找到答案。拜托，你能解释一下如何解决这个问题吗？

来自第一个 ActorSystem 的 Actor：

    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 的 Actor：

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 序列化不兼容。

4

1 回答 1

1

问题解决了！问题与序列化程序有关：我使用的是 Newtonsoft.Json 序列化程序。在向远程 ActorSystem 发送消息时，它不能序列化列表。Newtonsoft 解释说 System.String[] 是不兼容的类型。

解决方案是安装 Hyperion 序列化器：http: //getakka.net/docs/Serialization#how-to-setup-wire-as-default-serializer

于 2017-04-24T19:12:51.207 回答