MSMQ 和 ProtoBuf-Net 序列化 C#

Question

我有一个具有许多属性的类，其中之一是 byte[] 属性。我想使用 MSMQ 将此类发送到另一台服务器。但在发送之前，我想使用 ProtoBuf-Net 对其进行序列化。是否可以将 ProtoBuf-Net 序列化器附加到 MSMQ？

坦率地说，我不明白如何将课程发送到队列。我尝试使用下面的代码将类放入 MSMQ 队列，但出现异常“生成 XML 文档时出错。”

EntityBase 是我想发送的一个类。以前，我使用自己的基于文件系统的消息传递系统和 ProtoBuf-Net 来序列化类。

const string queueName = @".\private$\TestQueue";

private static void SendMessageToQueue(EntityBase entity)
{
    // check if queue exists, if not create it
    MessageQueue msMq = null;
    if (!MessageQueue.Exists(queueName))
    {
        msMq = MessageQueue.Create(queueName);
    }
    else
    {
        msMq = new MessageQueue(queueName);
    }
    try
    {

        msMq.Send(entity);
    }
    catch (MessageQueueException ee)
    {
        Console.Write(ee.ToString());
    }
    catch (Exception eee)
    {
        Console.Write(eee.ToString());
    }
    finally
    {
        msMq.Close();
    }
    Console.WriteLine("Message sent ......");
}

Answer 1

我的建议是：发送 string 或 byte[] 作为消息；您可以执行以下操作：

byte[] body;
using(var ms = new MemoryStream()) {
    Serializer.Serialize(ms, entity);
    body = ms.ToArray();
}

然后 Send(body)，或者如果您想要 字符串，则 Send(Convert.ToBase64String(body))。并将其反转为另一端。

看起来还有一种机制可以将 Message 与 IMessageFormatter 一起传递，但我不确定它是否值得。读取示例：

Message msg = // receive
byte[] body = (byte[])msg.Body;
EntityBase entity;
using(var ms = new MemoryStream(body)) {
    entity = Serializer.Deserialize<EntityBase>(ms);
}

或（如果选择传递字符串）：

string base64 = (string)msg.Body;
byte[] body = Convert.FromBase64String(base64);
// as before