C # protobuf Deserialize erreur avec ZMQ, écriture de type non valide

voix
1

J'ai deux programmes. avec le serveur et créer DiscoverServerMessage sérialisation par protobuf et l'envoyer par ZMQ. En côté client désérialiser message, mais erreur:

Ivalid wire-type; this usually means you have over-written a file without truncating or setting the length.

Je classe ci-dessous dans le projet dll.

[ProtoContract]
public class DiscoverServerMessage 
{
    [ProtoMember(1)]
    public int Port { get; set; }
    [ProtoMember(2)]
    public string IP { get; set; }
    [ProtoMember(3)]
    public string ServerName { get; set; }
    public DiscoverServerMessage() { }
}

Dans Project Server ont ce code:

public class Server
{
    static void Main(string[] args)
    {
        ZContext ctx = new ZContext();
        ZSocket broadcastSrocket = new ZSocket(ctx, ZSocketType.PUB);
        broadcastSrocket.Connect(tcp://127.0.0.1:2666);
        ZFrame zfr;
        DiscoverServerMessage message = new DiscoverServerMessage() { Port = 2667 , ServerName = My };
        message.IP = 127.0.0.1;
        using (MemoryStream str = new MemoryStream())
        {
            Serializer.SerializeWithLengthPrefix(str,message,PrefixStyle.Fixed32);
            zfr = new ZFrame(str.ToArray());
        }
        broadcastSrocket.Send(zfr);
    }
}

Dans le programme client:

public class Server
{
    static void Main(string[] args)
    {
        ZContext ctx = new ZContext();
        ZSocket subSocket = new ZSocket(ctx, ZSocketType.SUB);
        subSocket.Connect(tcp://127.0.0.1:2666);
        subSocket.SubscribeAll();
        ZError err;
        ZFrame zfr = subSocket.ReceiveFrame(out err);
        DiscoverServerMessage message;
        using (MemoryStream stream = new MemoryStream(zfr.Read()))
        {
            message = Serializer.DeserializeWithLengthPrefix<DiscoverServerMessage >(stream,PrefixStyle.Fixed32);
        }
    }
}

quel est mon erreur?

Créé 18/12/2018 à 11:11
source utilisateur
Dans d'autres langues...                            


1 réponses

voix
0

La première chose à faire est d' oublier de la part de sérialisation, et simplement vérifier si ce que vous envoyez est ce que vous avez reçu, donc - obtenir une copie de ce qui str.ToArray()est (serveur) et le comparer à ce qui zfr.Read()est (client). Si les deux charges utiles ne sont pas identiques: tous les autres paris sont éteints . La meilleure façon de le faire est généralement via hexadécimal, donc:

(serveur):

byte[] blob = str.ToArray();
string hex = BitConverter.ToString(blob); // <== get a copy of this somehow
zfr = new ZFrame(blob);
...

(client)

byte[] blob = zfr.Read();
string hex = BitConverter.ToString(blob); // <== get a copy of this somehow
using (MemoryStream stream = new MemoryStream(blob))
...

et juste vérifier: sont les deux séquences identiques hexagonales?

Remarque: puisque vous utilisez un protocole de cadrage ( ZFrame), vous ne avez pas réellement besoin du préfixe de longueur ici , mais ... il ne devrait pas faire du mal. Il semble que vous utilisez le code approprié à chaque extrémité ici - et les éléments suivants (influencé par votre code) fonctionne très bien:

static class Program
{
    static void Main()
    {
        byte[] blob;

        // taken from server code
        using (MemoryStream str = new MemoryStream())
        {
            DiscoverServerMessage message = new DiscoverServerMessage() { Port = 2667, ServerName = "My" };
            message.IP = "127.0.0.1";

            Serializer.SerializeWithLengthPrefix(str, message, PrefixStyle.Fixed32);
            blob = str.ToArray();
        }
        System.Console.WriteLine(BitConverter.ToString(blob));

        // taken from client code
        using (MemoryStream stream = new MemoryStream(blob))
        {
            DiscoverServerMessage message;
            message = Serializer.DeserializeWithLengthPrefix<DiscoverServerMessage>(stream, PrefixStyle.Fixed32);
            Console.WriteLine(message.Port);
            Console.WriteLine(message.ServerName);
            Console.WriteLine(message.IP);
        }

    }
}

La sortie est ici:

12-00-00-00-08-EB-14-12-09-31-32-37-2E-30-2E-30-2E-31-1A-02-4D-79
2667
My
127.0.0.1

Si nous faisons la même chose juste en utilisant Serialize/ Deserialize(sans préfixe de longueur), nous obtenons ( on pouvait s'y attendre):

08-EB-14-12-09-31-32-37-2E-30-2E-30-2E-31-1A-02-4D-79
2667
My
127.0.0.1

Donc , il devrait fonctionner avec ou sans le préfixe de longueur, tant que le client d' accord et le serveur (lequel ils apparaissent dans votre code).

Créé 18/12/2018 à 16:52
source utilisateur

Cookies help us deliver our services. By using our services, you agree to our use of cookies. Learn more